ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akuznet...@apache.org
Subject ignite git commit: IGNITE-1753 Test to debug NPE in cache store tx-put.
Date Thu, 12 Nov 2015 09:18:29 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-1753-1282 80a7cc5a5 -> a0ab8f9a1


IGNITE-1753 Test to debug NPE in cache store tx-put.


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

Branch: refs/heads/ignite-1753-1282
Commit: a0ab8f9a1940d0a848ef658f2502deeb2e433b90
Parents: 80a7cc5
Author: Alexey Kuznetsov <akuznetsov@apache.org>
Authored: Thu Nov 12 16:18:46 2015 +0700
Committer: Alexey Kuznetsov <akuznetsov@apache.org>
Committed: Thu Nov 12 16:18:46 2015 +0700

----------------------------------------------------------------------
 .../CacheJdbcPojoStoreAbstractSelfTest.java     | 27 +++++++++++++++++---
 1 file changed, 23 insertions(+), 4 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/ignite/blob/a0ab8f9a/modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStoreAbstractSelfTest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStoreAbstractSelfTest.java
b/modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStoreAbstractSelfTest.java
index f6b8294..69c4fa4 100644
--- a/modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStoreAbstractSelfTest.java
+++ b/modules/core/src/test/java/org/apache/ignite/cache/store/jdbc/CacheJdbcPojoStoreAbstractSelfTest.java
@@ -25,6 +25,8 @@ import java.sql.Statement;
 import java.sql.Types;
 import org.apache.ignite.IgniteCache;
 import org.apache.ignite.cache.store.jdbc.dialect.H2Dialect;
+import org.apache.ignite.cache.store.jdbc.model.Person;
+import org.apache.ignite.cache.store.jdbc.model.PersonKey;
 import org.apache.ignite.configuration.CacheConfiguration;
 import org.apache.ignite.configuration.ConnectorConfiguration;
 import org.apache.ignite.configuration.IgniteConfiguration;
@@ -37,6 +39,7 @@ import org.apache.ignite.testframework.junits.common.GridCommonAbstractTest;
 import org.h2.jdbcx.JdbcConnectionPool;
 
 import static org.apache.ignite.cache.CacheAtomicityMode.ATOMIC;
+import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL;
 import static org.apache.ignite.cache.CacheMode.PARTITIONED;
 
 /**
@@ -55,6 +58,9 @@ public abstract class CacheJdbcPojoStoreAbstractSelfTest extends GridCommonAbstr
     /** Person count. */
     protected static final int PERSON_CNT = 100000;
 
+    /** Flag indicating that tests should use transactional cache. */
+    protected static boolean transactional = false;
+
     /** Flag indicating that tests should use primitive classes like java.lang.Integer for
keys. */
     protected static boolean builtinKeys = false;
 
@@ -178,7 +184,7 @@ public abstract class CacheJdbcPojoStoreAbstractSelfTest extends GridCommonAbstr
         CacheConfiguration cc = defaultCacheConfiguration();
 
         cc.setCacheMode(PARTITIONED);
-        cc.setAtomicityMode(ATOMIC);
+        cc.setAtomicityMode(transactional ? TRANSACTIONAL : ATOMIC);
         cc.setSwapEnabled(false);
         cc.setWriteBehindEnabled(false);
 
@@ -242,13 +248,13 @@ public abstract class CacheJdbcPojoStoreAbstractSelfTest extends GridCommonAbstr
     /**
      * Start test grid with specified options.
      *
-     * @param pk {@code True} if keys are built in java types.
+     * @param builtin {@code True} if keys are built in java types.
      * @param noKeyCls {@code True} if keys classes are not on class path.
      * @param noValCls {@code True} if values classes are not on class path.
      * @throws Exception
      */
-    protected void startTestGrid(boolean pk, boolean noKeyCls, boolean noValCls) throws Exception
{
-        builtinKeys = pk;
+    protected void startTestGrid(boolean builtin, boolean noKeyCls, boolean noValCls) throws
Exception {
+        builtinKeys = builtin;
         noKeyClasses = noKeyCls;
         noValClasses = noValCls;
 
@@ -283,4 +289,17 @@ public abstract class CacheJdbcPojoStoreAbstractSelfTest extends GridCommonAbstr
 
         checkCacheContent();
     }
+
+    /**
+     * @throws Exception If failed.
+     */
+    public void testTxPut() throws Exception {
+        transactional = true;
+
+        startTestGrid(false, false, false);
+
+        IgniteCache<PersonKey, Person> c1 = grid().cache(null);
+
+        c1.put(new PersonKey(999), new Person(999, 777, "tx-person", 999));
+    }
 }


Mime
View raw message