ignite-1.9 - test added
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/3a496d82 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/3a496d82 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/3a496d82 Branch: refs/heads/ignite-4932 Commit: 3a496d82d56b005f2468eab5834e4a45133742b0 Parents: 841887e Author: Sergi Vladykin <[email protected]> Authored: Sat Mar 18 14:46:00 2017 +0300 Committer: Sergi Vladykin <[email protected]> Committed: Sat Mar 18 14:46:00 2017 +0300 ---------------------------------------------------------------------- .../query/IgniteSqlSplitterSelfTest.java | 28 ++++++++++++++++++++ 1 file changed, 28 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/3a496d82/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java ---------------------------------------------------------------------- diff --git a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java index 8eae549..7570184 100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/IgniteSqlSplitterSelfTest.java @@ -153,6 +153,34 @@ public class IgniteSqlSplitterSelfTest extends GridCommonAbstractTest { } /** + * + */ + public void testReplicatedOnlyTables() { + IgniteCache<Integer,Value> p = ignite(0).getOrCreateCache(cacheConfig("p", true, + Integer.class, Value.class)); + IgniteCache<Integer,Value> r = ignite(0).getOrCreateCache(cacheConfig("r", false, + Integer.class, Value.class)); + + try { + int cnt = 1000; + + for (int i = 0; i < cnt; i++) + r.put(i, new Value(i, -i)); + + // Query data from replicated table using partitioned cache. + assertEquals(cnt, p.query(new SqlFieldsQuery("select 1 from \"r\".Value")).getAll().size()); + + List<List<?>> res = p.query(new SqlFieldsQuery("select count(1) from \"r\".Value")).getAll(); + assertEquals(1, res.size()); + assertEquals(cnt, ((Number)res.get(0).get(0)).intValue()); + } + finally { + p.destroy(); + r.destroy(); + } + } + + /** * @throws Exception If failed. */ public void testSortedMergeIndex() throws Exception {
