Merge branch 'ignite-sprint-3' into ignite-437-sqltests-p2
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/dd6d1110 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/dd6d1110 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/dd6d1110 Branch: refs/heads/ignite-437-sqltests-p2 Commit: dd6d111022f0e0b8f666c42d41c67cc36f686fd1 Parents: 3dbd6f8 d20d29b Author: Artem Shutak <ashu...@gridgain.com> Authored: Tue Apr 7 12:01:02 2015 +0300 Committer: Artem Shutak <ashu...@gridgain.com> Committed: Tue Apr 7 12:01:02 2015 +0300 ---------------------------------------------------------------------- DEVNOTES.txt | 2 +- examples/README.txt | 11 +- examples/config/example-ignite.xml | 2 +- .../streaming/StreamTransformerExample.java | 101 + .../streaming/StreamVisitorExample.java | 171 + .../streaming/marketdata/CacheConfig.java | 44 - .../streaming/marketdata/Instrument.java | 106 - .../marketdata/QueryTopInstruments.java | 73 - .../streaming/marketdata/StreamMarketData.java | 103 - .../examples/streaming/numbers/CacheConfig.java | 46 - .../streaming/numbers/QueryPopularNumbers.java | 74 - .../streaming/numbers/StreamRandomNumbers.java | 78 - .../streaming/wordcount/CacheConfig.java | 48 + .../streaming/wordcount/QueryWords.java | 77 + .../streaming/wordcount/StreamWords.java | 68 + .../streaming/wordcount/alice-in-wonderland.txt | 3735 ++++++++++++++++++ .../streaming/wordcount/package-info.java | 22 + .../streaming/StreamTransformerExample.java | 97 + .../java8/streaming/StreamVisitorExample.java | 168 + .../java8/streaming/marketdata/CacheConfig.java | 44 - .../java8/streaming/marketdata/Instrument.java | 106 - .../marketdata/QueryTopInstruments.java | 73 - .../streaming/marketdata/StreamMarketData.java | 101 - .../java8/streaming/numbers/CacheConfig.java | 46 - .../streaming/numbers/QueryPopularNumbers.java | 74 - .../streaming/numbers/StreamRandomNumbers.java | 74 - .../ignite/cache/affinity/AffinityUuid.java | 50 + .../cache/eviction/fifo/FifoEvictionPolicy.java | 58 +- .../eviction/fifo/FifoEvictionPolicyMBean.java | 16 + .../store/jdbc/CacheAbstractJdbcStore.java | 104 +- .../processors/query/GridQueryProcessor.java | 8 +- .../ignite/internal/util/IgniteUtils.java | 46 +- .../ignite/internal/visor/cache/VisorCache.java | 19 +- .../VisorCacheConfigurationCollectorJob.java | 76 + .../VisorCacheConfigurationCollectorTask.java | 39 + .../VisorIgfsProfilerUniformityCounters.java | 6 +- .../visor/node/VisorGridConfiguration.java | 38 - .../visor/node/VisorIgfsConfiguration.java | 2 +- .../visor/node/VisorRestConfiguration.java | 1 + .../internal/visor/util/VisorTaskUtils.java | 3 +- .../org/apache/ignite/stream/StreamVisitor.java | 2 +- .../eviction/GridCacheEvictionAbstractTest.java | 5 +- ...ridCacheFifoBatchEvictionPolicySelfTest.java | 385 ++ .../query/h2/sql/GridSqlQuerySplitter.java | 22 +- .../h2/twostep/GridReduceQueryExecutor.java | 2 +- .../query/h2/sql/BaseH2CompareQueryTest.java | 7 + .../query/h2/sql/GridQueryParsingTest.java | 1 + modules/schedule/pom.xml | 20 + .../commands/cache/VisorCacheCommand.scala | 26 +- .../config/VisorConfigurationCommand.scala | 15 +- .../visor/commands/gc/VisorGcCommand.scala | 15 +- .../scala/org/apache/ignite/visor/visor.scala | 34 +- .../yardstick/config/benchmark-store.properties | 5 +- parent/pom.xml | 1 + pom.xml | 63 +- 55 files changed, 5429 insertions(+), 1184 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd6d1110/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/BaseH2CompareQueryTest.java ---------------------------------------------------------------------- diff --cc modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/BaseH2CompareQueryTest.java index 1c9866e,0000000..49e326b mode 100644,000000..100644 --- a/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/BaseH2CompareQueryTest.java +++ b/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/BaseH2CompareQueryTest.java @@@ -1,784 -1,0 +1,791 @@@ +/* @java.file.header */ + +/* _________ _____ __________________ _____ + * __ ____/___________(_)______ /__ ____/______ ____(_)_______ + * _ / __ __ ___/__ / _ __ / _ / __ _ __ `/__ / __ __ \ + * / /_/ / _ / _ / / /_/ / / /_/ / / /_/ / _ / _ / / / + * \____/ /_/ /_/ \_,__/ \____/ \__,_/ /_/ /_/ /_/ + */ + +package org.apache.ignite.internal.processors.query.h2.sql; + +import org.apache.ignite.cache.*; +import org.apache.ignite.cache.affinity.*; +import org.apache.ignite.cache.query.annotations.*; +import org.apache.ignite.configuration.*; + +import java.io.*; +import java.sql.*; +import java.sql.Date; +import java.util.*; + +/** + * Base set of queries to compare query results from h2 database instance and mixed ignite caches (replicated and partitioned) + * which have the same data models and data content. + */ +public class BaseH2CompareQueryTest extends AbstractH2CompareQueryTest { + + public static final int ORG_CNT = 3; + public static final int ADDR_CNT = 10; + public static final int PERS_CNT = 5; + public static final int PROD_CNT = 10; + public static final int PURCH_CNT = PROD_CNT * 2; + + /** {@inheritDoc} */ + @Override protected void setIndexedTypes(CacheConfiguration<?, ?> cc, CacheMode mode) { + if (mode == CacheMode.PARTITIONED) + cc.setIndexedTypes( + Integer.class, Organization.class, + AffinityKey.class, Person.class, + AffinityKey.class, Purchase.class + ); + else if (mode == CacheMode.REPLICATED) + cc.setIndexedTypes( + Integer.class, Product.class, + Integer.class, Address.class + ); + else + throw new IllegalStateException("mode: " + mode); + } + + /** {@inheritDoc} */ + @SuppressWarnings("unchecked") + @Override protected void initCacheAndDbData() throws SQLException { + int idGen = 0; + + // Organizations. + List<Organization> organizations = new ArrayList<>(); + + for (int i = 0; i < ORG_CNT; i++) { + int id = idGen++; + + Organization org = new Organization(id, "Org" + id); + + organizations.add(org); + + pCache.put(org.id, org); + + insertInDb(org); + } + + // Adresses. + List<Address> addreses = new ArrayList<>(); + + for (int i = 0; i < ADDR_CNT; i++) { + int id = idGen++; + + Address addr = new Address(id, "Addr" + id); + + addreses.add(addr); + + rCache.put(addr.id, addr); + + insertInDb(addr); + } + + // Persons. + List<Person> persons = new ArrayList<>(); + + for (int i = 0; i < PERS_CNT; i++) { + int id = idGen++; + + Person person = new Person(id, organizations.get(i % organizations.size()), + "name" + id, "lastName" + id, id * 100.0, addreses.get(i % addreses.size())); + + // Add a Person without lastname. + if (id == organizations.size() + 1) + person.lastName = null; + + persons.add(person); + + pCache.put(person.key(), person); + + insertInDb(person); + } + + // Products. + List<Product> products = new ArrayList<>(); + + for (int i = 0; i < PROD_CNT; i++) { + int id = idGen++; + + Product product = new Product(id, "Product" + id, id*1000); + + products.add(product); + + rCache.put(product.id, product); + + insertInDb(product); + } + + // Purchases. + for (int i = 0; i < PURCH_CNT; i++) { + int id = idGen++; + + Purchase purchase = new Purchase(id, products.get(i % products.size()), persons.get(i % persons.size())); + + pCache.put(purchase.key(), purchase); + + insertInDb(purchase); + } + } + + /** {@inheritDoc} */ + @Override protected void checkAllDataEquals() throws Exception { + compareQueryRes0("select _key, _val, id, name from \"part\".Organization"); + + compareQueryRes0("select _key, _val, id, firstName, lastName, orgId, salary from \"part\".Person"); + + compareQueryRes0("select _key, _val, id, personId, productId from \"part\".Purchase"); + + compareQueryRes0(rCache, "select _key, _val, id, name, price from \"repl\".Product"); + } + + /** + * * + * @throws Exception + */ + public void testAllExamples() throws Exception { +// compareQueryRes0("select ? limit ? offset ?"); + +// compareQueryRes0("select cool1()"); +// compareQueryRes0("select cool1() z"); +// +// compareQueryRes0("select b,a from table0('aaa', 100)"); +// compareQueryRes0("select * from table0('aaa', 100)"); +// compareQueryRes0("select * from table0('aaa', 100) t0"); +// compareQueryRes0("select x.a, y.b from table0('aaa', 100) x natural join table0('bbb', 100) y"); +// compareQueryRes0("select * from table0('aaa', 100) x join table0('bbb', 100) y on x.a=y.a and x.b = 'bbb'"); +// compareQueryRes0("select * from table0('aaa', 100) x left join table0('bbb', 100) y on x.a=y.a and x.b = 'bbb'"); +// compareQueryRes0("select * from table0('aaa', 100) x left join table0('bbb', 100) y on x.a=y.a where x.b = 'bbb'"); +// compareQueryRes0("select * from table0('aaa', 100) x left join table0('bbb', 100) y where x.b = 'bbb'"); + + final String addStreet = "Addr" + ORG_CNT + 1; + + List<List<?>> res = compareQueryRes0("select avg(old) from \"part\".Person left join \"repl\".Address " + + " on Person.addrId = Address.id where lower(Address.street) = lower(?)", addStreet); + + assertNotSame(0, res); + + compareQueryRes0("select avg(old) from \"part\".Person join \"repl\".Address on Person.addrId = Address.id " + + "where lower(Address.street) = lower(?)", addStreet); + + compareQueryRes0("select avg(old) from \"part\".Person left join \"repl\".Address where Person.addrId = Address.id " + + "and lower(Address.street) = lower(?)", addStreet); + + compareQueryRes0("select avg(old) from \"part\".Person, \"repl\".Address where Person.addrId = Address.id " + + "and lower(Address.street) = lower(?)", addStreet); + + compareQueryRes0("select firstName, date from \"part\".Person"); + compareQueryRes0("select distinct firstName, date from \"part\".Person"); + + final String star = " _key, _val, id, firstName, lastName, orgId, salary, addrId, old, date "; + + compareQueryRes0("select " + star + " from \"part\".Person p"); + compareQueryRes0("select " + star + " from \"part\".Person"); + compareQueryRes0("select distinct " + star + " from \"part\".Person"); + compareQueryRes0("select p.firstName, date from \"part\".Person p"); + + compareQueryRes0("select p._key, p._val, p.id, p.firstName, p.lastName, p.orgId, p.salary, p.addrId, p.old, " + + " p.date, a._key, a._val, a.id, a.street" + + " from \"part\".Person p, \"repl\".Address a"); +// compareQueryRes0("select p.* from \"part\".Person p, \"repl\".Address a"); +// compareQueryRes0("select person.* from \"part\".Person, \"repl\".Address a"); +// compareQueryRes0("select p.*, street from \"part\".Person p, \"repl\".Address a"); + compareQueryRes0("select p.firstName, a.street from \"part\".Person p, \"repl\".Address a"); + compareQueryRes0("select distinct p.firstName, a.street from \"part\".Person p, \"repl\".Address a"); + compareQueryRes0("select distinct firstName, street from \"part\".Person, \"repl\".Address group by firstName, street "); + compareQueryRes0("select distinct firstName, street from \"part\".Person, \"repl\".Address"); + // TODO uncomment and investigate (Rows count has to be equal.: Expected :2500, Actual :900) +// compareQueryRes0("select p1.firstName, a2.street from \"part\".Person p1, \"repl\".Address a1, \"part\".Person p2, \"repl\".Address a2"); + + //TODO look at it (org.h2.jdbc.JdbcSQLException: Feature not supported: "VARCHAR +" // at H2) +// compareQueryRes0("select p.firstName n, a.street s from \"part\".Person p, \"repl\".Address a"); + compareQueryRes0("select p.firstName, 1 as i, 'aaa' s from \"part\".Person p"); + +// compareQueryRes0("select p.firstName + 'a', 1 * 3 as i, 'aaa' s, -p.old, -p.old as old from \"part\".Person p"); +// compareQueryRes0("select p.firstName || 'a' + p.firstName, (p.old * 3) % p.old - p.old / p.old, p.firstName = 'aaa', " + +// " p.firstName is p.firstName, p.old > 0, p.old >= 0, p.old < 0, p.old <= 0, p.old <> 0, p.old is not p.old, " + +// " p.old is null, p.old is not null " + +// " from \"part\".Person p"); + + compareQueryRes0("select p.firstName from \"part\".Person p where firstName <> 'ivan'"); + compareQueryRes0("select p.firstName from \"part\".Person p where firstName like 'i%'"); + compareQueryRes0("select p.firstName from \"part\".Person p where firstName regexp 'i%'"); + compareQueryRes0("select p.firstName from \"part\".Person p, \"repl\".Address a where p.firstName <> 'ivan' and a.id > 10 or not (a.id = 100)"); + + compareQueryRes0("select case p.firstName when 'a' then 1 when 'a' then 2 end as a from \"part\".Person p"); + compareQueryRes0("select case p.firstName when 'a' then 1 when 'a' then 2 else -1 end as a from \"part\".Person p"); + + compareQueryRes0("select abs(p.old) from \"part\".Person p"); + compareQueryRes0("select cast(p.old as numeric(10, 2)) from \"part\".Person p"); + compareQueryRes0("select cast(p.old as numeric(10, 2)) z from \"part\".Person p"); + compareQueryRes0("select cast(p.old as numeric(10, 2)) as z from \"part\".Person p"); + + compareQueryRes0("select " + star + " from \"part\".Person p where p.firstName in ('a', 'b', '_' + RAND())"); // test ConditionIn + compareQueryRes0("select " + star + " from \"part\".Person p where p.firstName in ('a', 'b', 'c')"); // test ConditionInConstantSet + compareQueryRes0("select " + star + " from \"part\".Person p where p.firstName in (select a.street from \"repl\".Address a)"); // test ConditionInConstantSet + + compareQueryRes0("select (select a.street from \"repl\".Address a where a.id = p.addrId) from \"part\".Person p"); // test ConditionInConstantSet + + compareQueryRes0("select p.firstName, ? from \"part\".Person p where firstName regexp ? and p.old < ?"); + + compareQueryRes0("select count(*) as a from \"part\".Person"); + compareQueryRes0("select count(*) as a, count(p.*), count(p.firstName) from \"part\".Person p"); + compareQueryRes0("select count(distinct p.firstName) from \"part\".Person p"); + + compareQueryRes0("select p.firstName, avg(p.old), max(p.old) from \"part\".Person p group by p.firstName"); + compareQueryRes0("select p.firstName n, avg(p.old) a, max(p.old) m from \"part\".Person p group by p.firstName"); + compareQueryRes0("select p.firstName n, avg(p.old) a, max(p.old) m from \"part\".Person p group by n"); + + compareQueryRes0("select p.firstName n, avg(p.old) a, max(p.old) m from \"part\".Person p group by p.addrId, p.firstName"); + compareQueryRes0("select p.firstName n, avg(p.old) a, max(p.old) m from \"part\".Person p group by p.firstName, p.addrId"); + compareQueryRes0("select p.firstName n, max(p.old) + min(p.old) / count(distinct p.old) from \"part\".Person p group by p.firstName"); + compareQueryRes0("select p.firstName n, max(p.old) maxOld, min(p.old) minOld from \"part\".Person p group by p.firstName having maxOld > 10 and min(p.old) < 1"); + + compareQueryRes0("select p.firstName n, avg(p.old) a, max(p.old) m from \"part\".Person p group by p.firstName order by n"); + compareQueryRes0("select p.firstName n, avg(p.old) a, max(p.old) m from \"part\".Person p group by p.firstName order by p.firstName"); + compareQueryRes0("select p.firstName n, avg(p.old) a, max(p.old) m from \"part\".Person p group by p.firstName order by p.firstName, m"); + compareQueryRes0("select p.firstName n, avg(p.old) a, max(p.old) m from \"part\".Person p group by p.firstName order by p.firstName, max(p.old) desc"); + compareQueryRes0("select p.firstName n, avg(p.old) a, max(p.old) m from \"part\".Person p group by p.firstName order by p.firstName nulls first"); + compareQueryRes0("select p.firstName n, avg(p.old) a, max(p.old) m from \"part\".Person p group by p.firstName order by p.firstName nulls last"); + compareQueryRes0("select p.firstName n from \"part\".Person p order by p.old + 10"); + compareQueryRes0("select p.firstName n from \"part\".Person p order by p.old + 10, p.firstName"); + compareQueryRes0("select p.firstName n from \"part\".Person p order by p.old + 10, p.firstName desc"); + + compareQueryRes0("select p.firstName n from \"part\".Person p, (select a.street from \"repl\".Address a where a.street is not null) "); + compareQueryRes0("select street from \"part\".Person p, (select a.street from \"repl\".Address a where a.street is not null) "); + compareQueryRes0("select addr.street from \"part\".Person p, (select a.street from \"repl\".Address a where a.street is not null) addr"); + + compareQueryRes0("select p.firstName n from \"part\".Person p order by p.old + 10"); + + compareQueryRes0("select 'foo' as bar union select 'foo' as bar"); + compareQueryRes0("select 'foo' as bar union all select 'foo' as bar"); + } + + /** + * @throws Exception If failed. + */ + public void testSimpleReplSelect() throws Exception { + compareQueryRes0("select id, name, price from \"repl\".Product"); + } + + /** + * @throws Exception If failed. + */ + public void testParamSubstitution() throws Exception { + compareQueryRes0("select ? from \"part\".Person", "Some arg"); + } + + /** ++ * @throws SQLException If failed. ++ */ ++ public void testAggregateOrderBy() throws SQLException { ++ compareOrderedQueryRes0("select firstName name, count(*) cnt from \"part\".Person group by name order by cnt desc"); ++ } ++ ++ /** + * @throws Exception If failed. + */ + public void testNullParamSubstitution() throws Exception { + List<List<?>> rs1 = compareQueryRes0("select id from \"part\".Person where lastname is ?", null); + + // Ensure we find something. + assertNotSame(0, rs1.size()); + } + + /** + * @throws Exception If failed. + */ + public void testEmptyResult() throws Exception { + compareQueryRes0("select id from \"part\".Person where 0 = 1"); + } + + /** + * @throws Exception If failed. + */ + public void testSqlQueryWithAggregation() throws Exception { + compareQueryRes0("select avg(salary) from \"part\".Person, \"part\".Organization where Person.orgId = Organization.id and " + + "lower(Organization.name) = lower(?)", "Org1"); + } + + /** + * @throws Exception If failed. + */ + public void testSqlFieldsQuery() throws Exception { + compareQueryRes0("select concat(firstName, ' ', lastName) from \"part\".Person"); + } + + /** + * @throws Exception If failed. + */ + public void testSqlFieldsQueryWithJoin() throws Exception { + compareQueryRes0("select concat(firstName, ' ', lastName), " + + "Organization.name from \"part\".Person, \"part\".Organization where " + + "Person.orgId = Organization.id"); + } + + /** + * @throws Exception If failed. + */ + public void testOrdered() throws Exception { + compareOrderedQueryRes0("select firstName, lastName" + + " from \"part\".Person" + + " order by lastName, firstName" + ); + } + + /** + * //TODO Investigate. + * + * @throws Exception If failed. + */ + public void testSimpleJoin() throws Exception { + // Have expected results. + compareQueryRes0("select id, firstName, lastName" + + " from \"part\".Person" + + " where Person.id = ?", 3); + + // Ignite cache return 0 results... + compareQueryRes0("select Person.firstName" + + " from \"part\".Person, \"part\".Purchase" + + " where Person.id = ?", 3); + } + + /** + * @throws Exception If failed. + */ + public void testSimpleReplicatedSelect() throws Exception { + compareQueryRes0(rCache, "select id, name from \"repl\".Product"); + } + + /** + * @throws Exception If failed. + */ + public void testCrossCache() throws Exception { + //TODO Investigate (should be 20 results instead of 0). + compareQueryRes0("select firstName, lastName" + + " from \"part\".Person, \"part\".Purchase" + + " where Person.id = Purchase.personId"); + + //TODO Investigate. + compareQueryRes0("select concat(firstName, ' ', lastName), Product.name " + + " from \"part\".Person, \"part\".Purchase, \"repl\".Product " + + " where Person.id = Purchase.personId and Purchase.productId = Product.id" + + " group by Product.id"); + + //TODO Investigate. + compareQueryRes0("select concat(firstName, ' ', lastName), count (Product.id) " + + " from \"part\".Person, \"part\".Purchase, \"repl\".Product " + + " where Person.id = Purchase.personId and Purchase.productId = Product.id" + + " group by Product.id"); + } + + /** {@inheritDoc} */ + @Override protected void initializeH2Schema() throws SQLException { + Statement st = conn.createStatement(); + + st.execute("CREATE SCHEMA \"part\""); + st.execute("CREATE SCHEMA \"repl\""); + + st.execute("create table \"part\".ORGANIZATION" + + " (_key int not null," + + " _val other not null," + + " id int unique," + + " name varchar(255))"); + + st.execute("create table \"part\".PERSON" + + " (_key other not null ," + + " _val other not null ," + + " id int unique, " + + " firstName varchar(255), " + + " lastName varchar(255)," + + " orgId int not null," + + " salary double," + + " addrId int," + + " old int," + + " date Date )"); + + st.execute("create table \"repl\".PRODUCT" + + " (_key int not null ," + + " _val other not null ," + + " id int unique, " + + " name varchar(255), " + + " price int)"); + + st.execute("create table \"part\".PURCHASE" + + " (_key other not null ," + + " _val other not null ," + + " id int unique, " + + " personId int, " + + " productId int)"); + + st.execute("create table \"repl\".ADDRESS" + + " (_key int not null ," + + " _val other not null ," + + " id int unique, " + + " street varchar(255))"); + + conn.commit(); + } + + /** + * Insert {@link Organization} at h2 database. + * + * @param org Organization. + * @throws SQLException If exception. + */ + private void insertInDb(Organization org) throws SQLException { + try(PreparedStatement st = conn.prepareStatement( + "insert into \"part\".ORGANIZATION (_key, _val, id, name) values(?, ?, ?, ?)")) { + st.setObject(1, org.id); + st.setObject(2, org); + st.setObject(3, org.id); + st.setObject(4, org.name); + + st.executeUpdate(); + } + } + + /** + * Insert {@link Person} at h2 database. + * + * @param p Person. + * @throws SQLException If exception. + */ + private void insertInDb(Person p) throws SQLException { + try(PreparedStatement st = conn.prepareStatement("insert into \"part\".PERSON " + + "(_key, _val, id, firstName, lastName, orgId, salary, addrId, old, date) values(?, ?, ?, ?, ?, ?, ?, ?, ?, ?)")) { + st.setObject(1, p.key()); + st.setObject(2, p); + st.setObject(3, p.id); + st.setObject(4, p.firstName); + st.setObject(5, p.lastName); + st.setObject(6, p.orgId); + st.setObject(7, p.salary); + st.setObject(8, p.addrId); + st.setObject(9, p.old); + st.setObject(10, p.date); + + st.executeUpdate(); + } + } + + /** + * Insert {@link Product} at h2 database. + * + * @param p Product. + * @throws SQLException If exception. + */ + private void insertInDb(Product p) throws SQLException { + try(PreparedStatement st = conn.prepareStatement( + "insert into \"repl\".PRODUCT (_key, _val, id, name, price) values(?, ?, ?, ?, ?)")) { + st.setObject(1, p.id); + st.setObject(2, p); + st.setObject(3, p.id); + st.setObject(4, p.name); + st.setObject(5, p.price); + + st.executeUpdate(); + } + } + + /** + * Insert {@link Purchase} at h2 database. + * + * @param p Purchase. + * @throws SQLException If exception. + */ + private void insertInDb(Purchase p) throws SQLException { + try(PreparedStatement st = conn.prepareStatement( + "insert into \"part\".PURCHASE (_key, _val, id, personId, productId) values(?, ?, ?, ?, ?)")) { + st.setObject(1, p.key()); + st.setObject(2, p); + st.setObject(3, p.id); + st.setObject(4, p.personId); + st.setObject(5, p.productId); + + st.executeUpdate(); + } + } + + /** + * Insert {@link Address} at h2 database. + * + * @param a Address. + * @throws SQLException If exception. + */ + private void insertInDb(Address a) throws SQLException { + try(PreparedStatement st = conn.prepareStatement( + "insert into \"repl\".ADDRESS (_key, _val, id, street) values(?, ?, ?, ?)")) { + st.setObject(1, a.id); + st.setObject(2, a); + st.setObject(3, a.id); + st.setObject(4, a.street); + + st.executeUpdate(); + } + } + + @QuerySqlFunction + public static int cool1() { + return 1; + } + + @QuerySqlFunction + public static ResultSet table0(Connection c, String a, int b) throws SQLException { + return c.createStatement().executeQuery("select '" + a + "' as a, " + b + " as b"); + } + + /** + * Person class. Stored at partitioned cache. + */ + private static class Person implements Serializable { + /** Person ID (indexed). */ + @QuerySqlField(index = true) + private int id; + + /** Organization ID (indexed). */ + @QuerySqlField(index = true) + private int orgId; + + /** First name (not-indexed). */ + @QuerySqlField + private String firstName; + + /** Last name (not indexed). */ + @QuerySqlField + private String lastName; + + /** Salary (indexed). */ + @QuerySqlField(index = true) + private double salary; + + /** Address Id (indexed). */ + @QuerySqlField(index = true) + private int addrId; + + /** Date. */ + @QuerySqlField(index = true) + public Date date = new Date(System.currentTimeMillis()); + + /** Old. */ + @QuerySqlField(index = true) + public int old = 17; + + + /** + * Constructs person record. + * + * @param org Organization. + * @param firstName First name. + * @param lastName Last name. + * @param salary Salary. + */ + Person(int id, Organization org, String firstName, String lastName, double salary, Address addr) { + this.id = id; + this.firstName = firstName; + this.lastName = lastName; + this.salary = salary; + orgId = org.id; + addrId = addr.id; + } + + /** + * @return Custom affinity key to guarantee that person is always collocated with organization. + */ + public AffinityKey<Integer> key() { + return new AffinityKey<>(id, orgId); + } + + /** {@inheritDoc} */ + @Override public boolean equals(Object o) { + return this == o || o instanceof Person && id == ((Person)o).id; + + } + + /** {@inheritDoc} */ + @Override public int hashCode() { + return id; + } + + /** {@inheritDoc} */ + @Override public String toString() { + return "Person [firstName=" + firstName + + ", lastName=" + lastName + + ", id=" + id + + ", orgId=" + orgId + + ", salary=" + salary + + ", addrId=" + addrId + ']'; + } + } + + /** + * Organization class. Stored at partitioned cache. + */ + private static class Organization implements Serializable { + /** Organization ID (indexed). */ + @QuerySqlField(index = true) + private int id; + + /** Organization name (indexed). */ + @QuerySqlField(index = true) + private String name; + + /** + * Create Organization. + * + * @param id Organization ID. + * @param name Organization name. + */ + Organization(int id, String name) { + this.id = id; + this.name = name; + } + + /** {@inheritDoc} */ + @Override public boolean equals(Object o) { + return this == o || o instanceof Organization && id == ((Organization)o).id; + + } + + /** {@inheritDoc} */ + @Override public int hashCode() { + return id; + } + + /** {@inheritDoc} */ + @Override public String toString() { + return "Organization [id=" + id + ", name=" + name + ']'; + } + } + + /** + * Product class. Stored at replicated cache. + */ + private static class Product implements Serializable { + /** Primary key. */ + @QuerySqlField(index = true) + private int id; + + /** Product name. */ + @QuerySqlField + private String name; + + /** Product price */ + @QuerySqlField + private int price; + + /** + * Create Product. + * + * @param id Product ID. + * @param name Product name. + * @param price Product price. + */ + Product(int id, String name, int price) { + this.id = id; + this.name = name; + this.price = price; + } + + /** {@inheritDoc} */ + @Override public boolean equals(Object o) { + return this == o || o instanceof Product && id == ((Product)o).id; + + } + + /** {@inheritDoc} */ + @Override public int hashCode() { + return id; + } + + /** {@inheritDoc} */ + @Override public String toString() { + return "Product [id=" + id + ", name=" + name + ", price=" + price + ']'; + } + } + + /** + * Purchase class. Stored at partitioned cache. + */ + private static class Purchase implements Serializable { + /** Primary key. */ + @QuerySqlField(index = true) + private int id; + + /** Product ID. */ + @QuerySqlField + private int productId; + + /** Person ID. */ + @QuerySqlField + private int personId; + + /** + * Create Purchase. + * + * @param id Purchase ID. + * @param product Purchase product. + * @param person Purchase person. + */ + Purchase(int id, Product product, Person person) { + this.id = id; + productId = product.id; + personId = person.id; + } + + /** + * @return Custom affinity key to guarantee that purchase is always collocated with person. + */ + public AffinityKey<Integer> key() { + return new AffinityKey<>(id, personId); + } + + /** {@inheritDoc} */ + @Override public boolean equals(Object o) { + return this == o || o instanceof Purchase && id == ((Purchase)o).id; + } + + /** {@inheritDoc} */ + @Override public int hashCode() { + return id; + } + + /** {@inheritDoc} */ + @Override public String toString() { + return "Purchase [id=" + id + ", productId=" + productId + ", personId=" + personId + ']'; + } + } + + /** + * Address class. Stored at replicated cache. + */ + private static class Address implements Serializable { + @QuerySqlField(index = true) + private int id; + + @QuerySqlField(index = true) + private String street; + + Address(int id, String street) { + this.id = id; + this.street = street; + } + + /** {@inheritDoc} */ + @Override public boolean equals(Object o) { + return this == o || o instanceof Address && id == ((Address)o).id; + } + + /** {@inheritDoc} */ + @Override public int hashCode() { + return id; + } + + /** {@inheritDoc} */ + @Override public String toString() { + return "Address [id=" + id + ", street=" + street + ']'; + } + } +} http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/dd6d1110/modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/GridQueryParsingTest.java ----------------------------------------------------------------------
