如何实现多组多列条件批量查询，替代循环调用单条查询？

针对你需要批量查询多组(column1、column2、column3)组合条件的场景，以下是几种可行的实现方案：

方案1：利用JPQL的多列IN子句 #

大多数主流数据库（如MySQL 8.0+、PostgreSQL）支持多列IN语法，JPQL也支持将多个字段作为元组放入IN条件中，可直接传递多组条件列表，无需循环调用单条查询。

实现代码 #

方式1：用Object[]传递条件（快速实现）

@Query("SELECT t FROM Invoice t WHERE (t.column1, t.column2, t.column3) IN :criteriaTuples")
Flux<Invoice> findByMultipleColumnTuples(@Param("criteriaTuples") List<Object[]> criteriaTuples);

// 调用示例
List<Object[]> tuples = new ArrayList<>();
for (Criteria criteria : criteriaList) {
    tuples.add(new Object[]{criteria.getColumn1(), criteria.getColumn2(), criteria.getColumn3()});
}
Flux<Invoice> result = repository.findByMultipleColumnTuples(tuples);

方式2：用DTO传递条件（类型更安全）

先定义一个包含三个字段的DTO类：

public class TableCriteria {
    private String column1;
    private String column2;
    private String column3;
    // 构造器、getter/setter
}

再编写Repository方法：

@Query("SELECT t FROM Invoice t WHERE (t.column1, t.column2, t.column3) IN :criteriaList")
Flux<Invoice> findByMultipleColumnCriteria(@Param("criteriaList") List<TableCriteria> criteriaList);

// 调用示例：直接传入已有criteriaList即可
Flux<Invoice> result = repository.findByMultipleColumnCriteria(criteriaList);

注意：部分老版本数据库可能不支持多列IN语法，需确认数据库版本兼容性。

方案2：动态构建Specification（适合复杂场景） #

如果需要更灵活的条件控制（比如部分字段可选），可以用Spring Data JPA的Specification动态拼接多个OR条件组：

// Repository需继承ReactiveJpaSpecificationExecutor
public interface InvoiceRepository extends ReactiveCrudRepository<Invoice, Long>, ReactiveJpaSpecificationExecutor<Invoice> {
}

// 构建批量查询的Specification
public Specification<Invoice> buildBatchCriteriaSpec(List<Criteria> criteriaList) {
    return (root, query, cb) -> {
        List<Predicate> predicates = new ArrayList<>();
        for (Criteria criteria : criteriaList) {
            // 每组内的三个条件用AND拼接，再加入OR条件列表
            Predicate groupPredicate = cb.and(
                cb.equal(root.get("column1"), criteria.getColumn1()),
                cb.equal(root.get("column2"), criteria.getColumn2()),
                cb.equal(root.get("column3"), criteria.getColumn3())
            );
            predicates.add(groupPredicate);
        }
        // 所有条件组用OR拼接
        return cb.or(predicates.toArray(new Predicate[0]));
    };
}

// 调用示例
Specification<Invoice> spec = buildBatchCriteriaSpec(criteriaList);
Flux<Invoice> result = repository.findAll(spec);

方案3：原生SQL拼接（兼容老版本数据库） #

如果JPQL的多列IN不兼容你的数据库，可以用原生SQL结合参数绑定实现，避免SQL注入：

以MySQL为例，用JSON_TABLE解析JSON数组：

@Query(value = "SELECT t.* FROM invoice t " +
    "JOIN JSON_TABLE(" +
    "   :criteriaJson, " +
    "   '$[*]' COLUMNS(" +
    "       column1 VARCHAR(255) PATH '$.column1'," +
    "       column2 VARCHAR(255) PATH '$.column2'," +
    "       column3 VARCHAR(255) PATH '$.column3'" +
    "   )" +
    ") AS c ON t.column1 = c.column1 AND t.column2 = c.column2 AND t.column3 = c.column3",
    nativeQuery = true)
Flux<Invoice> findByMultipleColumnNative(@Param("criteriaJson") String criteriaJson);

// 调用时将条件列表转为JSON字符串
ObjectMapper mapper = new ObjectMapper();
String criteriaJson = mapper.writeValueAsString(criteriaList);
Flux<Invoice> result = repository.findByMultipleColumnNative(criteriaJson);

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