Apache AGE存储过程用PREPARE语句遇两类错误的解决方法

错误原因分析 #

1. 首次调用错误：EXECUTE 调用预处理语句的语法错误，你把预处理语句当成普通函数调用了，PostgreSQL 无法识别该调用方式。
2. 二次调用错误：预处理语句是会话级别的对象，每次执行函数都会重新执行 PREPARE，第二次调用时同名语句已存在，导致冲突。

修正方案 #

方案1：正确使用预处理语句+避免重复定义 #

修改存储过程，先检查并释放已存在的预处理语句，再用标准语法调用：

CREATE OR REPLACE FUNCTION sh_univeronto.f_example() RETURNS TABLE(res ag_catalog.agtype) LANGUAGE plpgsql AS $function$
    begin
        LOAD 'age';
        SET search_path TO ag_catalog, public;

        -- 检查并释放已存在的同名预处理语句
        IF EXISTS (SELECT 1 FROM pg_prepared_statements WHERE name = 'cypher_stored_procedure') THEN
            DEALLOCATE cypher_stored_procedure;
        END IF;

        PREPARE cypher_stored_procedure(ag_catalog.agtype) as
        SELECT *
        FROM ag_catalog.cypher('sh_univeronto', $$
            MATCH (v:gr_main)           
            WHERE v.unoid = $unoid_val
            RETURN v
        $$, $1)
        AS (v agtype);  

        -- 用PostgreSQL标准语法调用预处理语句
        RETURN QUERY EXECUTE 'cypher_stored_procedure' USING ('{"unoid_val": "222eee33"}'::ag_catalog.agtype);

        -- 函数结束前释放预处理语句，避免影响后续会话调用
        DEALLOCATE cypher_stored_procedure;

        -- other code

    END;
$function$;

方案2：直接使用参数化Cypher调用（更简洁推荐） #

无需显式使用 PREPARE，直接通过PL/pgSQL处理参数化Cypher查询，彻底避免会话级预处理语句的冲突问题：

CREATE OR REPLACE FUNCTION sh_univeronto.f_example() RETURNS TABLE(res ag_catalog.agtype) LANGUAGE plpgsql AS $function$
    begin
        LOAD 'age';
        SET search_path TO ag_catalog, public;

        RETURN QUERY
        SELECT *
        FROM ag_catalog.cypher('sh_univeronto', $$
            MATCH (v:gr_main)           
            WHERE v.unoid = $unoid_val
            RETURN v
        $$, '{"unoid_val": "222eee33"}'::ag_catalog.agtype)
        AS (v agtype);  

        -- other code

    END;
$function$;

关键说明 #

• 方案1中，RETURN QUERY EXECUTE ... USING 是PostgreSQL调用预处理语句的标准语法，必须显式指定参数类型（转换为 ag_catalog.agtype）。
• 方案2更推荐，无需维护会话级预处理语句，既保留了查询的参数化特性，又避免了重复定义和手动释放的繁琐操作。

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