云数据库 GaussDB-执行SQL语句:创建和调用存储过程（入参为复合数据类型）

时间：2025-02-12 15:08:24

云数据库 GaussDB

创建和调用存储过程（入参为复合数据类型）

以下用例展示A兼容模式下，入参为复合数据类型的存储过程创建和调用情况。前置条件是数据库建连完成、连接对象为conn。

创建存储过程test_proc如下：

   
        // 在数据库创建复合数据类型。CREATE TYPE compfoo AS (f1 int, f3 text);// 在数据库中创建如下存储过程，它带有out参数。create or replace procedure test_proc(    psv_in in compfoo,    psv_out out compfoo)asbegin    psv_out := psv_in;end;/

调用存储过程test_proc如下：

设置参数behavior_compat_options='proc_outparam_override'后，调用Connection的prepareCall方法创建调用语句对象cs。

    
         Statement statement = conn.createStatement();statement.execute("set behavior_compat_options='proc_outparam_override'");CallableStatement cs = conn.prepareCall("{ CALL TEST_PROC(?,?) }");

调用CallableStatement的set方法设置参数。

    
         PGobject pGobject = new PGobject();pGobject.setType("public.compfoo"); // 设置复合类型名，格式为“schema.typename”。pGobject.setValue("(1,demo)"); // 绑定复合类型值，格式为“(value1,value2)”。cs.setObject(1, pGobject);

调用CallableStatement的registerOutParameter方法注册输出参数。

    
         // 注册out类型的参数，类型为复合类型,格式为“schema.typename”。cs.registerOutParameter(2, Types.STRUCT, "public.compfoo");

调用CallableStatement的execute方法执行SQL语句。
1

cs.execute();

调用CallableStatement的getObject方法获取输出参数。

    
         PGobject result = (PGobject)cs.getObject(2);  // 获取out参数 result.getValue(); // 获取复合类型字符串形式值。result.getArrayValue(); //获取复合类型数组形式值，以复合数据类型字段顺序排序。result.getStruct(); //获取复合类型子类型名，按创建顺序排序。

调用CallableStatement的close方法关闭调用语句对象cs。
1

cs.close();

A兼容模式开启参数后，调用存储过程必须使用{call proc_name(?,?)}形式调用，调用函数必须使用{? = call func_name(?,?)}形式调用（等号左侧的“？”为函数返回值的占位符，用于注册函数返回值）。
参数behavior_compat_options='proc_outparam_override'变更后，业务需要重新建立连接，否则无法正确调用存储过程和函数。
函数和存储过程中包含复合类型时，参数的绑定与注册需要使用schema.typename形式。

上一篇：云数据库 GaussDB-执行SQL语句:执行预编译SQL语句

下一篇：云数据库 GaussDB-执行SQL语句:创建和调用存储过程