Repository: incubator-ignite Updated Branches: refs/heads/sber-23 [created] b02d18da2
#sber-23: add test put/get in transaction. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/b02d18da Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/b02d18da Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/b02d18da Branch: refs/heads/sber-23 Commit: b02d18da2d1f6beabdf4b7be504f49c1fea0ac55 Parents: 14bb076 Author: ivasilinets <ivasilin...@gridgain.com> Authored: Tue Jun 9 12:01:13 2015 +0300 Committer: ivasilinets <ivasilin...@gridgain.com> Committed: Tue Jun 9 12:01:13 2015 +0300 ---------------------------------------------------------------------- .../cache/GridCacheOffheapIndexGetSelfTest.java | 61 ++++++++++++++++++++ 1 file changed, 61 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/b02d18da/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffheapIndexGetSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffheapIndexGetSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffheapIndexGetSelfTest.java index 41eb45a..93ab072 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffheapIndexGetSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/cache/GridCacheOffheapIndexGetSelfTest.java @@ -19,14 +19,17 @@ package org.apache.ignite.internal.processors.cache; import org.apache.ignite.*; import org.apache.ignite.cache.query.*; +import org.apache.ignite.cache.query.annotations.*; import org.apache.ignite.configuration.*; import org.apache.ignite.spi.discovery.tcp.*; import org.apache.ignite.spi.discovery.tcp.ipfinder.*; import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; import org.apache.ignite.spi.swapspace.file.*; import org.apache.ignite.testframework.junits.common.*; +import org.apache.ignite.transactions.*; import javax.cache.*; +import java.io.*; import java.util.*; import static org.apache.ignite.cache.CacheAtomicityMode.*; @@ -72,6 +75,7 @@ public class GridCacheOffheapIndexGetSelfTest extends GridCommonAbstractTest { cacheCfg.setMemoryMode(OFFHEAP_TIERED); cacheCfg.setEvictionPolicy(null); cacheCfg.setIndexedTypes(Long.class, Long.class); + cacheCfg.setIndexedTypes(String.class, TestEntity.class); cfg.setCacheConfiguration(cacheCfg); @@ -120,4 +124,61 @@ public class GridCacheOffheapIndexGetSelfTest extends GridCommonAbstractTest { assertNotNull(e.getValue()); } } + + /** + * @throws Exception If failed. + */ + public void testPutGet() throws Exception { + IgniteCache<Object, Object> cache = grid(0).cache(null); + + Map map = new HashMap(); + + try (Transaction tx = grid(0).transactions().txStart(TransactionConcurrency.PESSIMISTIC, + TransactionIsolation.REPEATABLE_READ, 100000, 1000)) { + + for (int i = 4; i < 400; i++) { + map.put("key" + i, new TestEntity("value")); + map.put(i, "value"); + } + + cache.putAll(map); + + tx.commit(); + } + + for (int i = 0; i < 100; i++) { + cache.get("key" + i); + cache.get(i); + } + } + + /** + * Test entry class. + */ + private static class TestEntity implements Serializable { + /** Value. */ + @QuerySqlField(index = true) + private String val; + + /** + * @param value Value. + */ + public TestEntity(String value) { + this.val = value; + } + + /** + * @return Value. + */ + public String getValue() { + return val; + } + + /** + * @param val Value + */ + public void setValue(String val) { + this.val = val; + } + } }
