Hazelcast Jet如何使用命名参数JDBC查询或直接传入ResultSet作数据源？

• Hazelcast Jet 原生JDBC数据源是否支持命名参数写法，能否对接Spring JdbcTemplate复用这类能力
• Hazelcast Jet 是否支持直接将已创建的ResultSet对象作为数据源接入流水线

命名参数查询的适配方式 #

Hazelcast Jet 原生不内置命名参数的解析能力。它的JDBC源接口完全基于标准JDBC规范实现，而标准JDBC本身仅支持?形式的位置占位符，不会识别:param这类自定义命名占位符语法。
你可以完全对接Spring的命名参数能力实现需求，不需要修改Jet的核心逻辑：

• 利用Spring JDBC模块内置的NamedParameterUtils工具类，提前把带命名参数的SQL解析为符合JDBC规范的位置占位符SQL
• 在Jet JDBC源的语句生成lambda中，按照解析得到的参数顺序绑定对应的值，即可实现命名参数的使用体验
  示例代码：

import org.springframework.jdbc.core.namedparam.NamedParameterUtils;
import org.springframework.jdbc.core.namedparam.ParsedSql;

// 定义带命名参数的原始SQL
String namedSql = "SELECT * FROM person WHERE MOD(id, :parallelMod) = :partitionIndex";
// 解析命名参数，生成标准JDBC兼容SQL
ParsedSql parsedSql = NamedParameterUtils.parseSqlStatement(namedSql);
String standardJdbcSql = NamedParameterUtils.substituteNamedParameters(parsedSql, null);

Pipeline p = Pipeline.create();
p.readFrom(Sources.jdbc(
    () -> DriverManager.getConnection("jdbc:mysql://localhost:3306/mysql"),
    (con, parallelism, index) -> {
        PreparedStatement stmt = con.prepareStatement(standardJdbcSql);
        // 按解析后的参数顺序绑定值，和命名参数一一对应
        stmt.setInt(1, parallelism);
        stmt.setInt(2, index);
        return stmt.executeQuery();
    },
    resultSet -> new Person(resultSet.getInt(1), resultSet.getString(2))
)).writeTo(Sinks.logger());

如果需要复杂的参数绑定逻辑，还可以直接在读取lambda中初始化NamedParameterJdbcTemplate实例，传入参数Map完成绑定，完全复用Spring JdbcTemplate的生态能力。

直接传入ResultSet作为数据源的可行性 #

Hazelcast Jet 没有提供直接接收已存在ResultSet对象的内置数据源，且这种用法本身不符合Jet的分布式运行模型。
根本原因是：Jet的作业是分布式调度执行的，源的读取逻辑会在集群的多个节点上独立运行。而你在客户端本地生成的ResultSet对象是和客户端的数据库连接、游标状态强绑定的，无法序列化传递到远端集群节点，自然不能直接作为数据源传入。
如果有把已有查询结果接入Jet流水线的需求，可以根据场景选择正确的实现方式：

• 小批量固定结果：先把ResultSet遍历为Java实体对象列表，通过Jet内置的内存集合源Sources.list()传入流水线
• 大结果集复用查询逻辑：把ResultSet的生成逻辑封装为方法，在Jet JDBC源的读取lambda中直接调用、生成ResultSet后做行映射，本质还是走Jet标准的JDBC源接口

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