Mybatis执行PostgreSQL DO块报参数绑定失败、索引越界解决方案

数据老陈

2026-8-26

问题根因

这个报错的核心原因是PostgreSQL的DO $$ ... $$匿名块对JDBC驱动来说是纯字符串常量，块内部的预编译占位符不会被驱动识别：

Mybatis处理带#{REGION}的语句时，会把#{REGION}替换为JDBC预编译占位符?，并按顺序给占位符传入参数值。
但你写的整个PL/pgSQL逻辑被包裹在$$标识的字符串块里，PostgreSQL JDBC驱动解析SQL时，只会识别顶层语法结构里的占位符，不会解析字符串常量内部的?，最终判定整条SQL没有需要传入的参数（也就是报错里的number of columns: 0）。
此时Mybatis仍然尝试给第1个参数位设值，就会直接触发列索引越界的PSQLException，最终包装为Mybatis持久化异常抛出。

修复方案

根据项目实际场景选以下任意一种方案即可：

方案1（推荐，最稳妥）：将匿名块逻辑封装为数据库自定义函数
把PL/pgSQL逻辑移到数据库侧定义为带参函数，从根源上避免参数识别问题，还能收敛数据操作逻辑：

先在PostgreSQL中创建函数：

CREATE OR REPLACE FUNCTION process_far_region_export(p_region VARCHAR)
RETURNS VOID AS $$
DECLARE
    ids varchar(15)[];
    export_in_progress boolean;
BEGIN
    -- 判断是否存在进行中的导出任务
    export_in_progress := (SELECT CASE WHEN EXISTS (
        SELECT 1 FROM clt$task_far_export
        WHERE p_region IS NULL OR REGION = p_region
    ) THEN TRUE ELSE FALSE END);

    IF NOT export_in_progress THEN
        -- 查询待迁移的订单ID
        SELECT ACT_ID INTO ids FROM clt$task_far
        WHERE p_region IS NULL OR REGION = p_region;

        -- 批量写入导出表
        INSERT INTO clt$task_far_export (REGION, COLLECTION_CENTER, ACT_ID, FAZ_SZ)
        SELECT REGION, COLLECTION_CENTER, ACT_ID, FAZ_SZ FROM clt$task_far WHERE ACT_ID LIKE ANY(ids);

        -- 删除原表已迁移数据
        DELETE FROM clt$task_far WHERE ACT_ID LIKE ANY(ids);
    END IF;
END;
$$ LANGUAGE plpgsql;

把Mybatis映射语句简化为函数调用即可：

<update id="export_orders_far_region">
    SELECT process_far_region_export(#{REGION})
</update>

注意：原逻辑没有并发控制，高并发场景下仍可能出现重复导出，可在函数内增加行锁或advisory lock优化。

方案2（轻量改法，需严格控参）：使用Mybatis文本替换直接拼接参数
如果不想额外创建数据库函数，可以把#{REGION}改为Mybatis文本替换语法${REGION}，Mybatis会直接把参数值拼到SQL字符串里，不会生成预编译占位符，自然不会出现参数位越界问题。
风险提示：${}是直接拼接字符串，存在SQL注入风险，必须在业务代码层对REGION参数做严格校验（比如限制必须是预设的区域编码枚举值、固定长度纯数字/字母，过滤特殊字符），禁止直接透传用户传入的未校验参数。
方案3：逻辑上移到业务层
把整个DO块的逻辑拆为多步数据库操作：
1. 开启事务
2. 查询当前区域是否存在进行中的导出任务
3. 无进行中任务时，查询对应区域的ACT_ID集合
4. 批量写入导出表、删除原表对应数据
5. 提交事务
  该方案需要注意加分布式锁避免并发场景下的重复导出问题，和数据库交互次数更多，性能略低于前两种方案。

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