# IGNITE-32: Fixed test.

Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b48db276
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b48db276
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b48db276

Branch: refs/heads/sprint-1
Commit: b48db276d5a4a5265bf32525083396f6ef38edd7
Parents: 7b9e7d1
Author: AKuznetsov <akuznet...@gridgain.com>
Authored: Thu Feb 5 13:18:22 2015 +0700
Committer: AKuznetsov <akuznet...@gridgain.com>
Committed: Thu Feb 5 13:18:22 2015 +0700

----------------------------------------------------------------------
 .../apache/ignite/cache/store/jdbc/PojoJdbcCacheStoreTest.java | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b48db276/modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/PojoJdbcCacheStoreTest.java
----------------------------------------------------------------------
diff --git 
a/modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/PojoJdbcCacheStoreTest.java
 
b/modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/PojoJdbcCacheStoreTest.java
index e31abaf..64faac7 100644
--- 
a/modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/PojoJdbcCacheStoreTest.java
+++ 
b/modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/PojoJdbcCacheStoreTest.java
@@ -165,11 +165,11 @@ public class PojoJdbcCacheStoreTest extends 
GridCommonAbstractTest {
      * @throws Exception If failed.
      */
     public void testWriteRetry() throws Exception {
+        // Special dialect that will skip updates, to test write retry.
         BasicJdbcDialect dialect = new BasicJdbcDialect() {
             /** {@inheritDoc} */
-            @Override public String updateQuery(String schema, String tblName, 
Collection<String> keyCols,
-                Iterable<String> valCols) {
-                return super.updateQuery(schema, tblName, keyCols, valCols) + 
" AND 1 = 0";
+            @Override public String updateQuery(String tblName, 
Collection<String> keyCols, Iterable<String> valCols) {
+                return super.updateQuery(tblName, keyCols, valCols) + " AND 1 
= 0";
             }
         };
 

Reply via email to