无法在查询中设置List<...>参数问题求助

问题根源 #

R2DBC的Statement不支持直接将List绑定到IN子句的单个占位符，核心原因是不同数据库对批量值的语法处理存在差异：

• 直接传List会触发编码错误，因为驱动无法将List序列化为数据库可识别的参数类型
• 传入数组时，数据库会将其视为单个复合值，而非IN子句所需的多个独立值，导致查询无匹配结果，看起来像“未执行”

解决方案 #

方案1：动态生成IN子句占位符（通用所有数据库） #

根据List的长度动态生成对应数量的占位符，再逐个绑定List中的元素，这是同时兼容PostgreSQL和MSSQL的通用方案。

修改后的代码：

public <S, T> Mono<Boolean> update(ConnectionFactory connectionFactory, String baseQuery, S param, List<T> listId) {
    if (listId.isEmpty()) {
        return Mono.just(false); // 空列表无需执行更新
    }
    // 动态生成IN子句的占位符，比如$2,$3,...$n
    String placeholders = IntStream.range(2, 2 + listId.size())
            .mapToObj(i -> "$" + i)
            .collect(Collectors.joining(","));
    // 替换原查询中的$2为生成的占位符
    String query = baseQuery.replace("$2", placeholders);

    return Mono.usingWhen(connectionFactory.create(),
                    connection -> {
                        Statement statement = connection.createStatement(query);
                        statement.bind("$1", param);
                        // 逐个绑定List中的元素
                        for (int i = 0; i < listId.size(); i++) {
                            statement.bind("$" + (2 + i), listId.get(i));
                        }
                        return Mono.from(statement.execute());
                    },
                    Connection::close)
            .map(updateResult -> updateResult.getRowsUpdated() > 0) // 根据实际更新行数判断是否成功
            .doOnSuccess(success -> {
                if (success) {
                    log.info("Update Success! Rows updated: {}", ((UpdateResult) success).getRowsUpdated());
                } else {
                    log.info("No rows updated.");
                }
            })
            .onErrorResume(e -> {
                log.error("ERROR update : \n{}", e.getMessage());
                return Mono.just(false);
            });
}

使用时原查询语句保持不变："update \"schema\".\"table\" SET \"column\" = $1 where \"id\" in ( $2 )"，代码会自动替换$2为对应数量的占位符。

方案2：针对PostgreSQL使用数组语法 #

PostgreSQL支持数组参数配合=ANY操作符替代IN子句，可直接绑定List：

1. 修改查询语句为：

update "schema"."table" SET "column" = $1 where "id" = ANY($2)

2. 绑定参数时直接传入List，PostgreSQL的R2DBC驱动会自动将List转换为数组：

statement.bind("$2", listId);

方案3：针对MSSQL使用表值参数（进阶） #

MSSQL支持表值参数，需先在数据库中创建对应表类型：

CREATE TYPE IdList AS TABLE (Id INT); -- 根据你的id类型调整

然后修改代码绑定表值参数：

// 转换为MSSQL专属Statement
SqlServerStatement statement = connection.createStatement(query).unwrap(SqlServerStatement.class);
statement.bind("$1", param);
// 构建表值参数内容
SqlServerTableParameter tableParam = SqlServerTableParameter.builder()
        .addColumn("Id", T.class) // 对应表类型的列名和类型
        .rows(listId.stream().map(Collections::singletonList).collect(Collectors.toList()))
        .build();
statement.bind("$2", tableParam);

该方式适合批量数据较大的场景，但需要预先创建数据库对象。

注意事项 #

• 原代码中map(el -> true)会忽略实际更新行数，建议改为判断updateResult.getRowsUpdated() > 0来准确反映更新是否生效
• 空List的情况需提前处理，避免生成无效的IN ()子句
• 确保数据库驱动版本为最新，R2DBC驱动对List/数组参数的支持在新版本中可能有优化

内容的提问来源于stack exchange，提问作者Арчи