如何在PL/pgSQL中实现跨数据库INSERT插入操作，附现有代码求排查帮助

原函数核心问题 #

• 语法错误：PL/pgSQL 中直接执行SELECT查询但未赋值给变量、也未使用PERFORM丢弃结果，运行时会直接抛出执行异常
• 安全隐患：直接拼接参数到SQL语句，存在SQL注入风险，且参数包含单引号时会直接触发SQL语法错误
• 逻辑缺陷：未校验远程调用的执行结果，无论插入是否成功都会返回成功标识
• 依赖缺失：运行前未确认dblink扩展是否已安装启用

前置操作 #

首先执行以下语句确保dblink扩展已安装：

CREATE EXTENSION IF NOT EXISTS dblink;

修复后完整代码 #

CREATE OR REPLACE FUNCTION "public"."cross_insert"("p_name" varchar, "p_detail" varchar)
  RETURNS SETOF "pg_catalog"."varchar" AS $BODY$
DECLARE
    -- 接收远程函数返回结果，字段类型和数量需和funct_insert2返回匹配
    v_remote_result varchar;
BEGIN
    -- 执行远程调用，format的%L占位符会自动转义参数的单引号，避免注入和语法问题
    SELECT * FROM public.dblink(
        'host=10.10.10.53 port=5432 user=sassuperuser password=password10 dbname=blog2',
        format(
            'SELECT public.funct_insert2(%L, %L)',
            p_name,
            p_detail
        )
    ) AS remote_res(res varchar) INTO v_remote_result;

    -- 若需要可在此处增加v_remote_result的校验逻辑，失败时返回错误信息
    RETURN query SELECT ('SUKSES')::character varying;
END$BODY$
  LANGUAGE plpgsql VOLATILE
  COST 100
  ROWS 1000;

优化建议 #

• 生产环境不要明文存储数据库连接信息，可通过创建外部服务器、用户映射的方式存储连接配置，避免敏感信息泄露
• 可添加EXCEPTION异常捕获块，处理远程连接失败、远程函数执行错误等异常场景
• 如果funct_insert2返回多个字段，需要调整dblink的别名定义，字段数量和类型需和远程返回完全匹配

内容的提问来源于stack exchange，提问作者Bayu Saputro Aji