Backend - postgresSQL DB 存储过程(数据库存储过程)

2024-05-24 09:20

本文主要是介绍Backend - postgresSQL DB 存储过程(数据库存储过程),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

目录

一、存储过程的特性

(一)作用

(二)特点

(三)编码结构的区别

二、定时执行存储过程

三、2种编码结构

 (一)函数结构

1. SQL代码

 2. 举例

(1)例1-循环批量插入数据

① 首先,声明函数

② 调用函数

(2)例2-计算面积

① 首先,声明函数

② 调用函数

(二)存储过程结构

1. SQL代码

 2. 举例

(1)首先声明存储过程

(2)调用存储过程

(3)结果是  

​编辑

(三)注意

四、异常处理

1. 异常写法

2. OTHERS

3. RAISE EXCEPTION

4. SQLERRM

五、raise level format 语句

(一)作用

(二)异常等级

(三)举例

1. 展示正常信息

(1)声明时

(2)调用时

(3)结果是

2. 显示异常

(1)声明时

(2)调用时

(3)结果是

六、查询获取数据库的值

1. 声明时

2. 调用时

七、查询多笔记录

(一)第一种

1. 声明时

2. 调用时

3. 结果是

(二)第二种

1. 声明时

2. 调用时

3. 结果是

七、控制结构

(一)if条件

(二)循环

1. while … loop

(1)代码

(2)例子

① 声明时

② 调用存储过程时

2. for 

(1)声明时

(2)调用存储过程时


一、存储过程的特性

(一)作用

        可以将SQL语句存放在数据库服务器上。

(二)特点

        存储于数据库服务器。

        一次编译后,可多次调用。

        有两种编码结构:函数和存储过程。

(三)编码结构的区别

        函数可以在select、update等SQL语句中被调用,而存储过程不能。

        存储过程无需return返回值,函数必须有return返回值。

        存储过程必须用call调用,函数可用select即可。

二、定时执行存储过程

        针对pgadmin软件,使用pg_cron插件或pg_agent插件。但是pg_cron是安装在Unix上,pg_agent

        目前也没有实现Windows安装。

        所以,现在只能用代码调用存储过程。

三、2种编码结构

 (一)函数结构

1. SQL代码

create [or replace] function 函数名(参数名 参数类型, … ) 
returns 返回值类型 as$body$declare 变量名 变量类型;变量名 类型 := 值;变量名 类型; 变量名 := 值;begin 函数体; exception when others then raise exception '(%)', sqlerrm;end$body$
language plpgsql;

 2. 举例

(1)例1-循环批量插入数据
① 首先,声明函数
create or replace function test001 (num int
) returns void as 
$$
begin while num <10loop insert into public.rep_updhist(id, lastupdate, tablename, starttimekey, endtimekey) values (num, '2024-03-27 15:33:14.014 +0800', 'test0521', '20240101073054822149', '20240327153311867313');num = num +1;end loop;
exception when others then raise exception '(%)', sqlerrm;
end
$$ 
language plpgsql;
② 调用函数
select test001(8);
(2)例2-计算面积
① 首先,声明函数
create or replace function test002 (w int, h int
) returns int as 
$calculator_area$
declare res int := 0;
beginres := w * h;return res;
exception when others then raise exception '(%)', sqlerrm;
end
$calculator_area$ 
language plpgsql;
② 调用函数
select test002(4,5);

(二)存储过程结构

1. SQL代码

create [or replace] procedure 存储过程名(参数名 参数类型, … )
language plpgsql as
$body$declare 变量名 变量类型;变量名 类型 := 值;变量名 类型; 变量名 := 值;begin SQL 语句; exception when others then rollback;end
$body$

 2. 举例

(1)首先声明存储过程
create or replace procedure testpro001("w" in integer, "h" in integer, "msg" inout text)
language plpgsql as
$$
declareres_area integer := 0;
begin res_area := w * h;msg := msg||res_area;raise notice '控制台展示面积数据:%', res_area;
end;
$$
(2)调用存储过程
call testpro001(4,6, '面积的计算结果是');
(3)结果是  

(三)注意

1. 每句末尾必须带分号隔开。

2. 字串相加的连接符号是 ||,而不是+。

3. format部分中,%是占位符,接收变量的值。例如, aa变量值是23, bb := '结果是%',aa;  则bb的值是'结果是23'。

4. 在函数中,若returns返回值类型是void,则无需return,否则得写上 return 变量名。

5. 报错

        SQL 错误 [42725]: ERROR: procedure testpro001(integer, integer, integer) is not unique
  Hint: Could not choose a best candidate procedure. You might need to add explicit type casts.
  Position: 6

        解决:查看存储过程文件夹中,是否有重复的方法名(或存储过程名)。

6. 执行函数时,若函数名已经存在,但参数类型有变,则会生成函数名重复的函数。同理,执行过程也是。

7. 保留大小写,需要加上双引号。

        解决:使用“”,或者使用quote_ident('XXX'),给字符串加上双引号

四、异常处理

1. 异常写法

exception when others then rollback;raise exception '异常是%', sqlerrm;

2. OTHERS

        表示除了声明外的错误。

3. RAISE EXCEPTION

        抛出异常。

        举例:raise exception '出现了异常,请检查!'; 

4. SQLERRM

        储存当前错误的详细信息。

        举例:raise exception '异常是%', sqlerrm;

五、raise level format 语句

(一)作用

        显示消息或异常。

(二)异常等级

        DEBUG(向服务器日志写信息)、

        LOG(向服务器日志写信息,优先级更高)、

        INFO、NOTICE和WARNING(把信息写到服务器日志以及转发到客户端应用,优先级逐步升高)、

        EXCEPTION抛出一个错误(强制关闭当前事务)

(三)举例

1. 展示正常信息

(1)声明时
create or replace function get_data()
returns void as 
$$
declare strval text;
begin strval := '一个大写字母' || quote_ident('B') || '!';raise notice '这是%', strval;
exception when others thenraise WARNING '出现异常:(%)', sqlerrm;
end;
$$
language plpgsql;
(2)调用时
select get_data();
(3)结果是

2. 显示异常

(1)声明时
create or replace function get_data()
returns void as 
$$
declarestrval text;
begin raise notice '这是%', xx;
exception when others then-- raise EXCEPTION '出现异常:(%)', sqlerrm;raise WARNING '出现异常:(%)', sqlerrm;
end;
$$
language plpgsql;
(2)调用时
select get_data();
(3)结果是

六、查询获取数据库的值

1. 声明时

create or replace procedure testpro001()
language plpgsql as
$calculator_area$
declare qry_book text := '';qry_author text := '';
beginselect name into qry_book from public."myApp_book" where bid = 3; -- 第1种execute 'select author from public."myApp_book" where bid = 3' into qry_author; -- 第2种raise notice '书籍ID为是3的书名是:%,作者是:%', qry_book, qry_author;
end;
$calculator_area$

2. 调用时

call testpro001();

七、查询多笔记录

(一)第一种

        在声明函数时,定义输出的值(指定out参数,使用return next)

1. 声明时

create or replace function get_record(out out_bid int, out out_card character varying)
returns setof record as 
$$
declare r record;
begin for i in 1..5 loopselect * into r from public."myApp_book" where bid=i;out_bid := r.bid;out_card := r.card;return next;end loop;
end
$$
language plpgsql;

2. 调用时

select * from get_record();

3. 结果是

(二)第二种

        在调用时,定义获取的值(使用return query)

1. 声明时

create or replace function get_record()
returns setof record as 
$$
declare r record;
begin for i in 1..5 loopreturn query(select bid, card from public."myApp_book" where bid=i);end loop;
end
$$
language plpgsql;

2. 调用时

select * from get_record() as t(id integer, card character varying);

3. 结果是

七、控制结构

(一)if条件

if … then … elseif … then … else … end if;

其中,end if的后面一定要带上分号;elseif的写法是连接在一起的,中间无空格隔开。

例子:

create or replace procedure testpro001("w" in integer, "h" in integer, "msg" inout text)
language plpgsql as
$$
declareres_area integer := 0;
begin res_area := w * h;msg := msg||res_area;if res_area <= 10 thenraise notice '面积数据:%,小于10', res_area;elseif res_area <= 20 thenraise notice '面积数据:%,小于20', res_area;elseraise notice '面积数据:%,大于20', res_area;end if;
end;
$$
call testpro001(3,6, '求w的值');

(二)循环

1. while … loop

(1)代码
while … loop # 函数体;
end loop;
(2)例子
① 声明时
create or replace procedure testpro001("w" in integer, "h" in integer, "msg" inout text)
language plpgsql as
$$
declareres_area integer := 0;
begin while w<=h loopw = w+1;end loop;msg := 'w的值是' || w;
end;
$$
② 调用存储过程时
call testpro001(3,6, '求w的值');

2. for 

(1)声明时
create or replace procedure testpro001()
language plpgsql as
$$
declaresumval int := 0;
begin for i in 1..6 loopsumval := sumval+i;end loop;raise notice '总和值:%',sumval;
end;
$$
(2)调用存储过程时
call testpro001();

这篇关于Backend - postgresSQL DB 存储过程(数据库存储过程)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/998003

相关文章

MySQL 主从复制部署及验证(示例详解)

《MySQL主从复制部署及验证(示例详解)》本文介绍MySQL主从复制部署步骤及学校管理数据库创建脚本,包含表结构设计、示例数据插入和查询语句,用于验证主从同步功能,感兴趣的朋友一起看看吧... 目录mysql 主从复制部署指南部署步骤1.环境准备2. 主服务器配置3. 创建复制用户4. 获取主服务器状态5

SpringBoot中六种批量更新Mysql的方式效率对比分析

《SpringBoot中六种批量更新Mysql的方式效率对比分析》文章比较了MySQL大数据量批量更新的多种方法,指出REPLACEINTO和ONDUPLICATEKEY效率最高但存在数据风险,MyB... 目录效率比较测试结构数据库初始化测试数据批量修改方案第一种 for第二种 case when第三种

MySql基本查询之表的增删查改+聚合函数案例详解

《MySql基本查询之表的增删查改+聚合函数案例详解》本文详解SQL的CURD操作INSERT用于数据插入(单行/多行及冲突处理),SELECT实现数据检索(列选择、条件过滤、排序分页),UPDATE... 目录一、Create1.1 单行数据 + 全列插入1.2 多行数据 + 指定列插入1.3 插入否则更

MySQL深分页进行性能优化的常见方法

《MySQL深分页进行性能优化的常见方法》在Web应用中,分页查询是数据库操作中的常见需求,然而,在面对大型数据集时,深分页(deeppagination)却成为了性能优化的一个挑战,在本文中,我们将... 目录引言:深分页,真的只是“翻页慢”那么简单吗?一、背景介绍二、深分页的性能问题三、业务场景分析四、

MySQL 迁移至 Doris 最佳实践方案(最新整理)

《MySQL迁移至Doris最佳实践方案(最新整理)》本文将深入剖析三种经过实践验证的MySQL迁移至Doris的最佳方案,涵盖全量迁移、增量同步、混合迁移以及基于CDC(ChangeData... 目录一、China编程JDBC Catalog 联邦查询方案(适合跨库实时查询)1. 方案概述2. 环境要求3.

Linux进程CPU绑定优化与实践过程

《Linux进程CPU绑定优化与实践过程》Linux支持进程绑定至特定CPU核心,通过sched_setaffinity系统调用和taskset工具实现,优化缓存效率与上下文切换,提升多核计算性能,适... 目录1. 多核处理器及并行计算概念1.1 多核处理器架构概述1.2 并行计算的含义及重要性1.3 并

Spring boot整合dubbo+zookeeper的详细过程

《Springboot整合dubbo+zookeeper的详细过程》本文讲解SpringBoot整合Dubbo与Zookeeper实现API、Provider、Consumer模式,包含依赖配置、... 目录Spring boot整合dubbo+zookeeper1.创建父工程2.父工程引入依赖3.创建ap

SpringBoot3.X 整合 MinIO 存储原生方案

《SpringBoot3.X整合MinIO存储原生方案》本文详细介绍了SpringBoot3.X整合MinIO的原生方案,从环境搭建到核心功能实现,涵盖了文件上传、下载、删除等常用操作,并补充了... 目录SpringBoot3.X整合MinIO存储原生方案:从环境搭建到实战开发一、前言:为什么选择MinI

SQL server数据库如何下载和安装

《SQLserver数据库如何下载和安装》本文指导如何下载安装SQLServer2022评估版及SSMS工具,涵盖安装配置、连接字符串设置、C#连接数据库方法和安全注意事项,如混合验证、参数化查... 目录第一步:打开官网下载对应文件第二步:程序安装配置第三部:安装工具SQL Server Manageme

C#连接SQL server数据库命令的基本步骤

《C#连接SQLserver数据库命令的基本步骤》文章讲解了连接SQLServer数据库的步骤,包括引入命名空间、构建连接字符串、使用SqlConnection和SqlCommand执行SQL操作,... 目录建议配合使用:如何下载和安装SQL server数据库-CSDN博客1. 引入必要的命名空间2.