ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [50/50] incubator-ignite git commit: Merge branch 'ignite-sprint-3' into ignite-437-sqltests-p2
Date Wed, 08 Apr 2015 13:45:23 GMT
Merge branch 'ignite-sprint-3' into ignite-437-sqltests-p2

Conflicts:
	modules/indexing/src/test/java/org/apache/ignite/internal/processors/query/h2/sql/GridQueryParsingTest.java


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

Branch: refs/heads/ignite-437-sqltests-p2
Commit: 04ff84a59708a18574786af6c7b0fa265e7fc9df
Parents: 88bbece 71439bc
Author: Artem Shutak <ashutak@gridgain.com>
Authored: Wed Apr 8 16:43:57 2015 +0300
Committer: Artem Shutak <ashutak@gridgain.com>
Committed: Wed Apr 8 16:43:57 2015 +0300

----------------------------------------------------------------------
 .../src/main/java/org/apache/ignite/Ignite.java |  15 +
 .../apache/ignite/internal/IgniteKernal.java    |  44 +-
 .../org/apache/ignite/internal/IgnitionEx.java  | 171 +++-----
 .../internal/managers/GridManagerAdapter.java   |  34 +-
 .../cache/DynamicCacheChangeRequest.java        |  17 +
 .../cache/DynamicCacheDescriptor.java           |  17 +-
 .../processors/cache/GridCacheIoManager.java    |   2 +-
 .../processors/cache/GridCacheProcessor.java    | 349 +++++++++++++--
 .../dht/GridClientPartitionTopology.java        |   6 +-
 .../distributed/dht/GridDhtLockFuture.java      |  10 +-
 .../dht/GridDhtPartitionTopologyImpl.java       |   6 +-
 .../distributed/dht/GridDhtTxLocalAdapter.java  |  49 ++-
 .../distributed/dht/GridDhtTxPrepareFuture.java |   2 +-
 .../GridDhtPartitionsExchangeFuture.java        |   1 +
 .../cache/transactions/IgniteTxManager.java     |   6 +-
 .../ignite/internal/util/lang/GridFunc.java     |  33 ++
 .../ignite/internal/visor/cache/VisorCache.java |   2 +-
 .../cache/VisorCacheAggregatedMetrics.java      |  38 +-
 .../visor/cache/VisorCacheConfiguration.java    |  17 +-
 .../internal/visor/cache/VisorCacheMetrics.java |  53 ++-
 .../cache/VisorCacheMetricsCollectorTask.java   |  59 ++-
 .../visor/cache/VisorCacheStopTask.java         |  69 +++
 .../resources/META-INF/classnames.properties    |  19 +-
 ...eCacheConfigurationTemplateNotFoundTest.java | 114 +++++
 .../IgniteCacheConfigurationTemplateTest.java   | 364 ++++++++++++++++
 .../cache/IgniteDynamicCacheStartSelfTest.java  |  23 +
 ...ePartitionedBasicStoreMultiNodeSelfTest.java | 110 +----
 .../ignite/testframework/junits/IgniteMock.java |  10 +
 .../ignite/testsuites/IgniteCacheTestSuite.java |   5 +-
 .../processors/query/h2/sql/GridSqlElement.java |   8 -
 .../processors/query/h2/sql/GridSqlQuery.java   | 183 ++++++++
 .../query/h2/sql/GridSqlQueryParser.java        |  97 +++--
 .../query/h2/sql/GridSqlQuerySplitter.java      | 111 ++++-
 .../processors/query/h2/sql/GridSqlSelect.java  | 209 +++------
 .../query/h2/sql/GridSqlSubquery.java           |   8 +-
 .../processors/query/h2/sql/GridSqlUnion.java   | 134 ++++++
 .../h2/twostep/GridReduceQueryExecutor.java     |   2 +-
 .../query/h2/sql/BaseH2CompareQueryTest.java    |  27 +-
 .../query/h2/sql/GridQueryParsingTest.java      |  29 +-
 .../org/apache/ignite/IgniteSpringBean.java     |  14 +
 .../commands/cache/VisorCacheClearCommand.scala |   3 +-
 .../commands/cache/VisorCacheCommand.scala      | 423 +++++++++++--------
 .../commands/cache/VisorCacheStopCommand.scala  | 145 +++++++
 .../scala/org/apache/ignite/visor/visor.scala   |  12 +-
 44 files changed, 2298 insertions(+), 752 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/04ff84a5/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 2821425,0000000..8049b76
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,807 -1,0 +1,822 @@@
 +/*
 + * Licensed to the Apache Software Foundation (ASF) under one or more
 + * contributor license agreements.  See the NOTICE file distributed with
 + * this work for additional information regarding copyright ownership.
 + * The ASF licenses this file to You under the Apache License, Version 2.0
 + * (the "License"); you may not use this file except in compliance with
 + * the License.  You may obtain a copy of the License at
 + *
 + *      http://www.apache.org/licenses/LICENSE-2.0
 + *
 + * Unless required by applicable law or agreed to in writing, software
 + * distributed under the License is distributed on an "AS IS" BASIS,
 + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 + * See the License for the specific language governing permissions and
 + * limitations under the License.
 + */
 +
 +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 {
 +    /** Org count. */
 +    public static final int ORG_CNT = 3;
 +    
 +    /** Address count. */
 +    public static final int ADDR_CNT = 10;
 +    
 +    /** Person count. */
 +    public static final int PERS_CNT = 5;
 +    
 +    /** Product count. */
 +    public static final int PROD_CNT = 10;
 +
 +    /** Purchase count. */
 +    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 {
++    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());
 +    }
 +
 +    /**
++     *
++     */
++    public void testUnion() throws SQLException {
++        String base = "select _val v from \"part\".Person";
++
++        compareQueryRes0(base + " union all " + base);
++        compareQueryRes0(base + " union " + base);
++
++        base = "select firstName||lastName name, salary from \"part\".Person";
++
++        assertEquals(10, compareOrderedQueryRes0(base + " union all " + base + " order by
salary desc").size());
++        assertEquals(5, compareOrderedQueryRes0(base + " union " + base + " order by salary
desc").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 {
++    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);
++        compareQueryRes0("select pe.firstName" +
++            "  from \"part\".Person pe join \"part\".Purchase pu on pe.id = pu.personId
" +
++            "  where pe.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 {
++    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 + ']';
 +        }
 +    }
 +}


Mime
View raw message