Java 8之后如何用JOOQ实现MySQL多SELECT语句的Union查询？

嘿，这个场景我经常碰到！用Java 8的Stream API配合jOOQ确实能写出非常优雅的动态Union代码，完全不用手动堆砌重复的UNION语句。下面给你一步步拆解实现方式：

1. 抽离单查询逻辑 #

首先，把对应单个y值的查询逻辑抽成一个单独的方法，这样每个y值对应的多表Join查询可以复用逻辑，避免冗余：

// 假设dslContext是你的jOOQ DSLContext实例
private Select<?> buildSingleYValueQuery(String yValue) {
    return dslContext.select(
        A.ID, A.NAME, B.DESCRIPTION, C.VALUE
        // 这里要保证所有查询返回的字段列表完全一致（数量、类型、顺序）
    )
    .from(A)
    .innerJoin(B).on(A.ID.eq(B.A_ID))
    .innerJoin(C).on(B.ID.eq(C.B_ID))
    // 这里可以添加其他需要的关联表
    .where(A.Y.eq(yValue));
}

注意：SQL的UNION要求所有子查询返回的字段结构完全一致，所以这个方法里的select部分必须固定，jOOQ在编译阶段也会帮你做校验，避免出错。

2. 用Stream.reduce实现动态Union #

接下来，利用Java 8 Stream的reduce操作，把所有单个查询合并成一个完整的Union查询——reduce会自动帮你完成n-1次Union操作，完美匹配你的需求：

// 假设这是表A的y列所有可能值的列表
List<String> targetYValues = Arrays.asList("y_val_1", "y_val_2", "y_val_3");

// 生成并合并所有查询
Optional<Select<?>> unionQuery = targetYValues.stream()
    .map(this::buildSingleYValueQuery)
    .reduce(Select::union);

// 执行查询（处理空列表的边界情况）
unionQuery.ifPresent(query -> {
    Result<?> result = query.fetch();
    // 在这里处理查询结果
});

• 如果需要用UNION ALL（不去重，性能更好），只需要把Select::union换成Select::unionAll即可。
• 如果targetYValues为空，Optional会是空值，用ifPresent可以安全处理这种边界情况，避免空指针。

额外优化：考虑IN子句替代（如果适用） #

如果你的所有子查询除了y值的筛选条件完全一致，其实可以直接用IN子句代替Union，这样SQL会更简洁，性能也可能更好：

Result<?> result = dslContext.select(...)
    .from(A)
    .innerJoin(B).on(A.ID.eq(B.A_ID))
    .innerJoin(C).on(B.ID.eq(C.B_ID))
    .where(A.Y.in(targetYValues))
    .fetch();

不过如果每个y值对应的关联逻辑或筛选条件有差异（比如不同y值要Join不同的表，或者附加不同的where条件），那还是用动态Union的方案更合适。

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