在 ignite 中加入 2 个缓存时找不到数据库

Question

我正在研究利用多个 ignite 缓存之间的分布式连接。我在两个缓存中都加载了所需的数据，并且在执行连接时它在解析 SQL 建议 "Database not found" 时失败（请参阅堆栈跟踪）。

Caused by: org.h2.jdbc.JdbcSQLException: Database "OFFER" not found; SQL statement:
SELECT "customOrganizationCache".Organization._key, "customOrganizationCache".Organization._val from Organization as organization, "customOfferCache".Offer as offer where organization._id = offer.relationships.customer.targets.key and organization._id = ? [90013-191]
at org.h2.message.DbException.getJdbcSQLException(DbException.java:345)
at org.h2.message.DbException.get(DbException.java:179)

下面是我的 ignite 配置文件：

<beans xmlns="http://www.springframework.org/schema/beans"
   xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="
    http://www.springframework.org/schema/beans
    http://www.springframework.org/schema/beans/spring-beans.xsd">

<bean id="offerCacheStoreFactory" class="javax.cache.configuration.FactoryBuilder" factory-method="factoryOf">
<constructor-arg><value>com.xyz.exploreignite.cache.CustomOfferCacheStore</value></constructor-arg>
</bean>

<bean id="organizationCacheStoreFactory" class="javax.cache.configuration.FactoryBuilder" factory-method="factoryOf">
<constructor-arg><value>com.xyz.exploreignite.cache.CustomOrganizationCacheStore</value></constructor-arg>
</bean>

<bean id="ignite.cfg" class="org.apache.ignite.configuration.IgniteConfiguration">
    <property name="peerClassLoadingEnabled" value="false"/>
<property name="clientMode" value="false"/>
<property name="gridName" value="clusterGrid"/>
    <property name="cacheConfiguration">
        <list>               
    <bean class="org.apache.ignite.configuration.CacheConfiguration">
                <property name="atomicityMode" value="ATOMIC"/>
                <property name="backups" value="1"/>
                <property name="name" value="customOrganizationCache"/>
                <property name="readThrough" value="true"/>
                <property name="writeThrough" value="true"/>
                <property name="cacheMode" value="PARTITIONED"/>
                <property name="writeBehindEnabled" value="true"/>
                <property name="copyOnRead" value="false"/>
                <property name="memoryMode" value="OFFHEAP_TIERED"/>
                <property name="atomicWriteOrderMode" value="PRIMARY"/>
                <property name="indexedTypes" >
        <list>
            <value>java.lang.String</value>
            <value>com.xyz.exploreignite.pojo.Organization</value>
        </list>
        </property>
        <!-- Cache store. -->
        <property name="cacheStoreFactory" ref="organizationCacheStoreFactory"/>
        <property name="swapEnabled" value="false"/>
        <property name="offHeapMaxMemory" value="0"/>
        <property name="evictionPolicy">
        <!-- LRU eviction policy. -->
        <bean class="org.apache.ignite.cache.eviction.lru.LruEvictionPolicy">
            <!-- Set the maximum cache size to 1 million (default is 100,000). -->
            <property name="maxSize" value="1000000"/>
        </bean>
        </property>
            </bean>
    <bean class="org.apache.ignite.configuration.CacheConfiguration">
                <property name="atomicityMode" value="ATOMIC"/>
                <property name="backups" value="1"/>
                <property name="name" value="customOfferCache"/>
                <property name="readThrough" value="true"/>
                <property name="writeThrough" value="true"/>
                <property name="cacheMode" value="PARTITIONED"/>
                <property name="writeBehindEnabled" value="true"/>
                <property name="copyOnRead" value="false"/>
                <property name="memoryMode" value="OFFHEAP_TIERED"/>
                <property name="atomicWriteOrderMode" value="PRIMARY"/>
                <property name="indexedTypes" >
        <list>
            <value>java.lang.String</value>
            <value>com.xyz.exploreignite.pojo.Offer</value>
        </list>
        </property>
        <!-- Cache store. -->
        <property name="cacheStoreFactory" ref="offerCacheStoreFactory"/>
        <property name="swapEnabled" value="false"/>
        <property name="offHeapMaxMemory" value="0"/>
        <property name="evictionPolicy">
        <!-- LRU eviction policy. -->
        <bean class="org.apache.ignite.cache.eviction.lru.LruEvictionPolicy">
            <!-- Set the maximum cache size to 1 million (default is 100,000). -->
            <property name="maxSize" value="1000000"/>
        </bean>
        </property>
            </bean>
        </list>
    </property>


    <!-- Explicitly configure TCP discovery SPI to provide list of initial nodes. -->
    <property name="discoverySpi">
        <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi">
            <property name="ipFinder">
                <!--
                    Ignite provides several options for automatic discovery that can be used
                    instead os static IP based discovery. For information on all options refer
                    to our documentation: http://apacheignite.readme.io/docs/cluster-config
                -->
                <!-- Uncomment static IP finder to enable static-based discovery of initial nodes. -->
                <!--<bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">-->
                <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder">
                    <property name="addresses">
                        <list>
                            <value>127.0.0.1:47500..47509</value>
                        </list>
                    </property>
                </bean>
            </property>
        </bean>
    </property>
</bean>

下面是我在执行连接时使用的代码：

try (Ignite ignite = Ignition.start(
            // "/home/impadmin/ignite/apache-ignite-fabric-1.7.0-bin/examples/config/example-cache-ss-cluster.xml"))
            // {
            "/home/xyz/msheth/install/apache-ignite-fabric-1.7.0-bin/examples/config/example-cache-ss-cluster.xml")) {

        try (IgniteCache<String, Offer> customOfferCache = ignite.getOrCreateCache("customOfferCache");

                IgniteCache<String, Organization> customOrganizationCache = ignite
                        .getOrCreateCache("customOrganizationCache")) {


            SqlFieldsQuery joinQuery = new SqlFieldsQuery("select organization.displayName "
                    + "from Organization as organization, \"customOfferCache\".Offer as offer"
                    + " where organization._id = offer.relationships.customer.targets.key "
                    + "and organization._id = ?");

            joinQuery.setDistributedJoins(true);

            long startTime = System.currentTimeMillis();
            try (QueryCursor<List<?>> joinCursor = customOrganizationCache
                    .query(joinQuery.setArgs("542de0b83b2d445f0a0e0f53"))) {
                for (List<?> organizationEntry : joinCursor)
                    System.out.println("Organizations display name: " + organizationEntry);
            }

            System.out.println("Time to fetch join based record:" + (System.currentTimeMillis() - startTime));

        }

    }

请帮我找出根本原因。

Answer 1

问题出在这个表达式中：

offer.relationships.customer.targets.key

关于此的几个注意事项：

您可以嵌套对象，但 Ignite 将创建平面架构。例如，customer 字段可以作为 Offer table 的成员访问，您不应为此提供完整路径。通常，在使用 SQL 时应尽量避免嵌套对象，而是创建简单的 POJO 类。
但是，您不能在集合内部进行查询。在您的情况下，targets 的整个集合都保存为单个对象，您不能根据其内容 select。您应该为 Target 个对象设置单独的缓存，并将其与其他 table 个对象合并。

在 ignite 中加入 2 个缓存时找不到数据库

Not able to find database while joining 2 cache in ignite

ignite