# 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"; } };