You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2016/05/13 09:40:21 UTC
[21/26] ignite git commit: Cachehanged CacheJdbcBlobStore default SQL
statements: key to aKey - Fixes #661.
Cachehanged CacheJdbcBlobStore default SQL statements: key to aKey - Fixes #661.
Signed-off-by: Alexey Kuznetsov <ak...@apache.org>
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5682d8ea
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5682d8ea
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5682d8ea
Branch: refs/heads/ignite-2832
Commit: 5682d8ead60f49ba3bffbf6dc1180d6855928f56
Parents: b4a5d37
Author: Kristian Rosenvold <kr...@apache.org>
Authored: Fri May 13 14:29:34 2016 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Fri May 13 14:29:34 2016 +0700
----------------------------------------------------------------------
.../cache/store/jdbc/CacheJdbcBlobStore.java | 20 ++++++++++----------
1 file changed, 10 insertions(+), 10 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5682d8ea/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java
index 147f6c9..25f0f37 100644
--- a/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java
+++ b/modules/core/src/main/java/org/apache/ignite/cache/store/jdbc/CacheJdbcBlobStore.java
@@ -88,22 +88,22 @@ public class CacheJdbcBlobStore<K, V> extends CacheStoreAdapter<K, V> {
/**
* Default create table query
- * (value is <tt>create table if not exists ENTRIES (key other primary key, val other)</tt>).
+ * (value is <tt>create table if not exists ENTRIES (akey binary primary key, val binary)</tt>).
*/
public static final String DFLT_CREATE_TBL_QRY = "create table if not exists ENTRIES " +
- "(key binary primary key, val binary)";
+ "(akey binary primary key, val binary)";
- /** Default load entry query (value is <tt>select * from ENTRIES where key=?</tt>). */
- public static final String DFLT_LOAD_QRY = "select * from ENTRIES where key=?";
+ /** Default load entry query (value is <tt>select * from ENTRIES where akey=?</tt>). */
+ public static final String DFLT_LOAD_QRY = "select * from ENTRIES where akey=?";
- /** Default update entry query (value is <tt>select * from ENTRIES where key=?</tt>). */
- public static final String DFLT_UPDATE_QRY = "update ENTRIES set val=? where key=?";
+ /** Default update entry query (value is <tt>select * from ENTRIES where akey=?</tt>). */
+ public static final String DFLT_UPDATE_QRY = "update ENTRIES set val=? where akey=?";
- /** Default insert entry query (value is <tt>insert into ENTRIES (key, val) values (?, ?)</tt>). */
- public static final String DFLT_INSERT_QRY = "insert into ENTRIES (key, val) values (?, ?)";
+ /** Default insert entry query (value is <tt>insert into ENTRIES (akey, val) values (?, ?)</tt>). */
+ public static final String DFLT_INSERT_QRY = "insert into ENTRIES (akey, val) values (?, ?)";
- /** Default delete entry query (value is <tt>delete from ENTRIES where key=?</tt>). */
- public static final String DFLT_DEL_QRY = "delete from ENTRIES where key=?";
+ /** Default delete entry query (value is <tt>delete from ENTRIES where akey=?</tt>). */
+ public static final String DFLT_DEL_QRY = "delete from ENTRIES where akey=?";
/** Connection attribute name. */
private static final String ATTR_CONN = "JDBC_STORE_CONNECTION";