Apache NiFi ExecuteSQL执行PostgreSQL事务报错求助

核心原因 #

1. ExecuteSQL事务处理逻辑不匹配
   ExecuteSQL默认以事务模式执行语句，一旦PostgreSQL的DO块内部出现错误（比如约束冲突、变量值不符合预期），PostgreSQL会立即标记当前事务为「中止状态」，而ExecuteSQL不会自动触发回滚，后续即使没有额外命令，也会抛出事务中止的报错。PgAdmin执行时会自动处理事务的回滚/提交，因此不会暴露这个问题。

2. ExecuteSQL设计定位局限
   ExecuteSQL主要用于执行返回结果集的查询语句，对DO块这类无返回结果的匿名代码块支持不佳，执行过程中可能因无法处理无结果的返回状态，导致事务状态异常。

3. 执行上下文配置差异
   即使脚本内容一致，NiFi的数据库连接属性（如自动提交状态、事务隔离级别）可能与PgAdmin默认配置不同，导致事务行为不一致。

解决措施 #

1. 切换到ExecuteSQLScript处理器 #

ExecuteSQLScript专门为执行DDL、DML、匿名代码块这类无结果集的脚本设计，能更好地处理PostgreSQL的DO块，且支持灵活的事务管理。配置时只需将你的脚本填入SQL Script属性，并确保变量替换逻辑正常即可。

2. 调整ExecuteSQL的事务属性（若坚持使用） #

• 开启Auto Commit：将ExecuteSQL的Auto Commit属性设置为true，让每个语句执行后自动提交事务，避免事务被标记为中止后无法处理。
• 匹配事务隔离级别：将Transaction Isolation Level设置为与PgAdmin一致的值（通常是READ COMMITTED），确保事务行为对齐。

3. 在DO块中添加异常捕获 #

在PostgreSQL的DO块内部加入EXCEPTION逻辑，捕获并处理内部错误，避免错误扩散导致整个事务中止。示例脚本：

DO $$$$
BEGIN
    -- 你的订单创建逻辑
    IF EXISTS(SELECT 1 FROM orders WHERE order_no = '${order_no}') THEN
        RAISE EXCEPTION '订单已存在';
    ELSE
        INSERT INTO orders (order_no, amount) VALUES ('${order_no}', ${amount});
    END IF;
EXCEPTION
    WHEN OTHERS THEN
        RAISE NOTICE '执行错误: %', SQLERRM;
        -- 可根据需求添加日志记录逻辑
END $$$$;

4. 验证变量替换后的脚本完整性 #

在NiFi中添加LogAttribute处理器，输出替换后的完整脚本，对比PgAdmin中执行的版本是否完全一致，排查是否存在变量替换导致的语法错误（比如单引号未转义、变量为空等）。

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