如何在三个独立的Ignite缓存中使用SQL UNION并通过Java代码实现结果合并

咱们一步步拆解你的问题，从SQL语法修复到QueryCursor的正确使用，再到可选的实现方案：

1. 先修复SQL语句的核心问题 #

你当前的SQL模板存在两个致命问题：第二个SELECT语句后缺少UNION ALL关键字，导致语法错误；另外参数占位符和后续传入的参数顺序容易错位。先调整成正确的模板：

private static final String EVENT_GET_RHYTHM_BY_ID = 
    "SELECT timestamp FROM \"%s\".ConfirmedEvent WHERE orderId = ? AND startTime < ? AND endTime > ? AND type = ? " +
    "UNION ALL " +
    "SELECT timestamp FROM \"%s\".UnconfirmedEvent WHERE orderId = ? AND startTime < ? AND endTime > ? AND type = ? " +
    "UNION ALL " +
    "SELECT timestamp FROM \"%s\".UnconfirmedEvent WHERE orderId = ? AND startTime < ? AND endTime > ? AND type = ? " +
    "ORDER BY startTime DESC";

这里要注意：

• 用双引号"包裹缓存名（比如"confirmed_event_mc_79"），避免缓存名里的下划线、数字后缀引发解析异常
• 每个子查询之间必须明确添加UNION ALL
• 每个子查询的参数占位符?数量保持一致，方便后续统一传参

2. 正确构建查询并使用QueryCursor #

接下来填充缓存名、类型参数，然后严格匹配参数顺序执行查询：

// 填充三个缓存的具体名称
String sql = String.format(EVENT_GET_RHYTHM_BY_ID,
    String.format(CONFIRMED_EVENT_CACHE, mcId),
    String.format(UNCONFIRMED_NON_URGENT_EVENT_CACHE, mcId),
    String.format(UNCONFIRMED_URGENT_EVENT_CACHE, mcId)
);

// 获取统一的类型值
String rhythmValue = AnnotationConverter.StringToRhythmValue(AFIB);

// 构建查询：每个子查询需要4个参数，三个子查询共12个参数，顺序要严格对应
SqlFieldsQuery sqlQuery = new SqlFieldsQuery(sql)
    .setArgs(
        orderId, endTimestamp, startTimestamp, rhythmValue,  // 第一个子查询参数
        orderId, endTimestamp, startTimestamp, rhythmValue,  // 第二个子查询参数
        orderId, endTimestamp, startTimestamp, rhythmValue   // 第三个子查询参数
    );

// 执行跨缓存查询：用任意一个已初始化的缓存实例即可，SQL引擎会自动解析所有引用的表
try (QueryCursor<List<?>> cursor = confirmedEventCache.query(sqlQuery)) {
    for (List<?> row : cursor) {
        // 注意类型转换的安全性，可添加非空判断
        if (row.get(0) != null) {
            EventsEndTime.add((Long) row.get(0));
        }
    }
}

关于QueryCursor的疑问解答 #

你问的QueryCursor<List<?>> cursor = cache.query(sqlThreeCaches)部分，这里的cache可以是你已经获取的任意一个缓存实例（比如confirmedEventCache、unconfirmedEventCache都没问题）。因为Ignite的SQL引擎会解析你SQL里引用的所有缓存表，不管用哪个缓存实例调用query方法，都会正确执行跨缓存查询。

另外一定要用try-with-resources包裹QueryCursor，确保资源自动释放，避免内存泄漏。

3. 可选实现方案：分别查询后手动合并结果 #

如果你觉得跨缓存UNION查询调试麻烦，或者需要对每个缓存的结果做单独处理，也可以分开查询再合并：

// 封装通用的缓存查询方法
private List<Long> querySingleCache(IgniteCache<?, ?> cache, String sql, Object... args) {
    List<Long> timestamps = new ArrayList<>();
    SqlFieldsQuery query = new SqlFieldsQuery(sql).setArgs(args);
    try (QueryCursor<List<?>> cursor = cache.query(query)) {
        for (List<?> row : cursor) {
            if (row.get(0) != null) {
                timestamps.add((Long) row.get(0));
            }
        }
    }
    return timestamps;
}

// 分别查询三个缓存
String rhythmValue = AnnotationConverter.StringToRhythmValue(AFIB);
String confirmedSql = "SELECT timestamp FROM ConfirmedEvent WHERE orderId = ? AND startTime < ? AND endTime > ? AND type = ?";
List<Long> confirmedTimestamps = querySingleCache(confirmedEventCache, confirmedSql, orderId, endTimestamp, startTimestamp, rhythmValue);

String unconfirmedSql = "SELECT timestamp FROM UnconfirmedEvent WHERE orderId = ? AND startTime < ? AND endTime > ? AND type = ?";
List<Long> unconfirmedTimestamps = querySingleCache(unconfirmedEventCache, unconfirmedSql, orderId, endTimestamp, startTimestamp, rhythmValue);
List<Long> unconfirmedUrgentTimestamps = querySingleCache(unconfirmedUrgentEventCache, unconfirmedSql, orderId, endTimestamp, startTimestamp, rhythmValue);

// 合并所有结果到同一个列表
EventsEndTime.addAll(confirmedTimestamps);
EventsEndTime.addAll(unconfirmedTimestamps);
EventsEndTime.addAll(unconfirmedUrgentTimestamps);

// 按需排序
EventsEndTime.sort(Collections.reverseOrder());

这种方式的优势是：

• 每个查询独立，便于单独调试排查问题
• 可以灵活对每个缓存的结果做预处理（比如过滤、转换）
• 避免跨缓存查询可能带来的性能瓶颈（如果三个缓存数据量极大）

总结 #

• 跨缓存UNION查询的核心是保证SQL语法正确，尤其是UNION ALL的使用和参数占位符的对应
• QueryCursor可以通过任意一个缓存实例调用，只要SQL正确引用了目标表
• 两种实现方式各有优劣：跨缓存查询更简洁，分别查询更灵活

内容的提问来源于stack exchange，提问作者sachith