如何将 SQL UNION 与 Ignite 缓存一起使用

Question

我正在使用 ignite 缓存并执行以下 sql 查询。

    IgniteCache<String, ClassName> cache = ignite.cache(CACHE_NAME);
    private static final String sql = "Select timestamp from cache1 where  orderId = ? and timestamp <= ? and timestamp >= ? ";
    SqlFieldsQuery sqlQ = new SqlFieldsQuery(sql).setArgs(id, t1, t2);
        try (QueryCursor<List<?>> cursor = cache.query(sqlQ)) {
            for (List<?> row : cursor) {
                    timestamps.add((Long) row.get(0));          
            }

现在我想从两个不同的缓存中查询并获取联合。我能够成功编写 SQL 联合操作。

private static final String sqlTwoCaches = "Select timestamp from cache1 union all Select timestamp from cache2 order by timestamp";

我想将两个缓存中的时间戳结果添加到单个数组列表中。我想知道如何使用查询游标？现在有两个缓存，这部分怎么做？ (QueryCursor<List<?>> cursor = cache.query(sqlTwoCaches))

或者有没有其他方法可以做到这一点？

Answer 1

您需要“完全限定”第二个缓存名称，否则，它应该可以正常工作。

例子：

IgniteCache<String, ClassName1> cache1 = ignite.cache("table1");
IgniteCache<String, ClassName2> cache2 = ignite.cache("table2");
private static final String sql = "select timestamp from ClassName1 UNION ALL select timestamp from table2.ClassName2 ";
SqlFieldsQuery sqlQ = new SqlFieldsQuery(sql);
try (QueryCursor<List<?>> cursor = cache1.query(sqlQ)) {
    for (List<?> row : cursor) {
            timestamps.add((Long) row.get(0));          
    }
 }