如何用类SQL语法查询Java Stream且无需硬编码与真实数据库？

你完全可以不需要依赖真实数据库或内存数据库，直接在Java Stream上解析并执行类SQL查询，既能满足外部输入查询语句的需求，又能保持和无索引全表扫描相当的性能（本质就是单次遍历Stream）。以下是几个成熟的实现方案：

1. jOOQ（推荐） #

jOOQ是知名的ORM工具，除了操作数据库，它原生支持在内存中对集合/Stream执行类SQL查询，完美匹配你的场景：

• 支持解析外部输入的SQL语句，无需硬编码
• 直接在Stream上流式处理，不需要将数据插入到任何数据库
• 性能接近原生Stream API，因为内部会把SQL转化为filter、map、collect等Stream操作

适配你的代码示例的实现：

import org.jooq.DSLContext;
import org.jooq.Record;
import org.jooq.Result;
import org.jooq.impl.DSL;
import static org.jooq.impl.DSL.field;

class A {
    private String name;

    // 务必提供getter，jOOQ需要读取字段值
    public String getName() { return name; }
    public void setName(String name) { this.name = name; }
}

public class StreamQueryExample {
    public static Stream<Integer> query(Stream<A> stream, String sql) {
        DSLContext ctx = DSL.using(org.jooq.SQLDialect.DEFAULT);
        
        // 将A对象流转换为jOOQ可识别的Record流
        Stream<Record> recordStream = stream.map(a -> 
            ctx.newRecord(field("name", String.class))
               .set(field("name"), a.getName())
        );
        
        // 执行SQL查询，直接传入Stream作为数据源
        Result<Record> result = ctx.fetch(sql, recordStream);
        
        // 转换为目标结果流
        return result.stream().map(rs -> rs.getInt("number_of_x"));
    }

    public static void main(String[] args) {
        Stream<A> myStream = Stream.of(
            new A() {{ setName("x"); }},
            new A() {{ setName("y"); }},
            new A() {{ setName("x"); }}
        );

        Stream<Integer> result = query(myStream, "select count(*) as number_of_x from stream where name = 'x'");
        System.out.println(result.toList()); // 输出 [2]
    }
}

2. Querydsl #

Querydsl以类型安全的查询API著称，同样支持对Java集合/Stream的查询。你可以通过它的SQL解析模块将外部输入的SQL转化为Querydsl查询模型，然后直接应用到Stream上：

• 优势是类型安全，查询逻辑可追踪
• 无需依赖数据库，全程在内存流式处理

3. 轻量方案：Apache Commons JEXL + 自定义SQL解析 #

如果你的查询需求比较简单（仅过滤、基础聚合），可以用JEXL来处理表达式，自己封装一层SQL语法解析逻辑：

• 将SQL的WHERE条件转化为JEXL表达式，用Stream.filter执行过滤
• 聚合操作（如count、sum）用Stream.collect实现
• 优点是轻量无重型依赖，缺点是需要自己实现SQL语法的子集解析，适合简单场景

为什么不推荐内存数据库？ #

H2、SQLite这类内存数据库需要先将Stream中的数据全部插入到内存表中，会额外消耗内存和插入时间，对于超大Stream甚至可能导致OOM。而上述方案都是直接在Stream上流式处理，边遍历边计算，内存占用极低，性能更接近原生Stream操作。

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