华为云首页 用户手册

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

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

时间：2024-11-13 14:45:47
云数据库 GAUSSDB

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

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

创建存储过程test_proc如下： 
 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
14
15
16
17
18
19
20
21
22
 
// 在数据库创建复合数据类型。
CREATE TYPE compfoo AS (f1 int, f3 text);
// 在数据库中创建table类型。
create type compfoo_table is table of compfoo;
// 在数据库中创建如下存储过程，它带有out参数。
create or replace procedure test_proc
(
    psv_in in compfoo,
    table_in in compfoo_table,
    psv_out out compfoo,
    table_out out compfoo_table
)
as
begin
    psv_out := psv_in;
    table_out:=compfoo_table();
    table_out.extend(table_in.count);
    for i in 1..table_in.count loop
         table_out(i):=table_in(i);
    end loop;
end;
/

调用存储过程test_proc如下：

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

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

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

    1
2
3
4
5
6
7
8
    		 
    PGobject pGobject = new PGobject();
pGobject.setType("public.compfoo"); // 设置复合类型名，格式为“schema.typename”。
pGobject.setValue("(1,demo)"); // 绑定复合类型值，格式为“(value1,value2)”。
cs.setObject(1, pGobject);
pGobject = new PGobject();
pGobject.setType("public.compfoo_table"); // 设置Table类型名，格式为"schema.typename"。
pGobject.setValue("{\"(10,demo10)\",\"(11,demo111)\"}"); //绑定Table类型值，格式为"{\"(value1,value2)\",\"(value1,value2)\",...}"。
cs.setObject(2, pGobject);

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

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

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

    1
    		 
    cs.execute();

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

     1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
    		 
    // 返回结构是自定义类型。
PGobject result = (PGobject)cs.getObject(3);  // 获取out参数 
result.getValue(); // 获取复合类型字符串形式值。
result.getArrayValue(); //获取复合类型数组形式值，以复合数据类型字段顺序排序。
result.getStruct(); //获取复合类型子类型名，按创建顺序排序。
result.getAttributes(); //返回自定义类型每列组成类型的对象，对于array类型和table类型返回的是PgArray,对于自定义类型，封装的是PGobject，对于其他类型数据存储方式为字符串类型。
// 返回结果是Table类型。
PgArray pgArray = (PgArray) cs.getObject(4);
ResultSet rs = pgArray.getResultSet();
while (rs.next()) {
  rs.getObject(2);// table类型每行的数据构建成的对象。
}

    如果出参的table类型组成为自定义类型，例如create type compfoo_table is table of compfoo，此时接收到的返回对象为PgArray，在通过rs.getObject(2)遍历获取到的组成对象也为PgArray，此时无法获取到组成它的compfoo类型对应的每列数据，需要通过getPGobject()获取到PgObject再操作获取。

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

    1
    		 
    cs.close();

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

新客秒杀 2核2G 3M L实例

68元/年

普惠上云 领千元上云礼券

立即前往

企业专享 X实例 4核8G 5M

888元/年

热门域名 1元 随心购

1元/年起

看了此文的人还看了
CDN加速 GaussDB 文字转换成语音 免费的服务器 如何创建网站 域名网站购买 私有云桌面 云主机哪个好 域名怎么备案 手机云电脑 SSL证书申请 云点播服务器 免费OCR是什么 电脑云桌面 域名备案怎么弄 语音转文字 文字图片识别 云桌面是什么 网址安全检测 网站建设搭建 国外CDN加速 SSL免费证书申请 短信批量发送 图片OCR识别 云数据库MySQL 个人域名购买 录音转文字 扫描图片识别文字 OCR图片识别 行驶证识别 虚拟电话号码 电话呼叫中心软件 怎么制作一个网站 Email注册网站 华为VNC 图像文字识别 企业网站制作 个人网站搭建 华为云计算 免费租用云托管 云桌面云服务器 ocr文字识别免费版 HTTPS证书申请 图片文字识别转换 国外域名注册商 使用免费虚拟主机 云电脑主机多少钱 鲲鹏云手机 短信验证码平台 OCR图片文字识别 SSL证书是什么 申请企业邮箱步骤 免费的企业用邮箱 云免流搭建教程 域名价格
云数据库 GAUSSDB-执行SQL语句:创建和调用存储过程（入参为复合数据类型）

搜索反馈

您搜索到想要的结果了吗?

是的 没有

意见反馈

0/200

提交 取消

提交成功！非常感谢您的反馈，我们会继续努力做到更好 反馈提交失败！请稍后重试！
产品专区
推荐文章
更多内容
云硬盘存储EVS Web应用防火墙 人机语音识别 云计算入门 云数据库选择 HDC大会 华为云计算 响应式建站是什么 智慧班牌系统