云服务器特惠 99/年起
  1. 腾讯云优惠网首页
  2. 腾讯云产品

TDSQL PostgreSQL版 控制结构（存储过程开发）

• 腾讯云产品

postgres=# CREATE OR REPLACE PROCEDURE p_if() AS$$ BEGIN IF random()>0.5 THEN RAISE NOTICE ‘随机数大于0.5’; END IF;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_if();NOTICE: 随机数大于0.5CALLpostgres=#。

相关产品
TDSQL PostgreSQL版 产品页，含版本规格、价格与购买入口。

三、IF…THEN…ELSE…END IF

postgres=# CREATE OR REPLACE PROCEDURE p_if_else() AS$$ BEGIN IF random()>0.99 THEN RAISE NOTICE '随机数大于0.99'; ELSE RAISE NOTICE '随机数小于或等于0.99'; END IF;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_if_else();NOTICE: 随机数小于或等于0.99CALLpostgres=#

四、IF…THEN…ELSIF…THEN…ELSE…END IF

postgres=# CREATE OR REPLACE PROCEDURE p_if_elsif() AS$$ DECLARE v_float8 float8 := random();BEGIN IF v_float8>0.99 THEN RAISE NOTICE '随机数大于0.99'; ELSIF v_float8>0.5 THEN RAISE NOTICE '随机数大于0.50'; ELSIF v_float8>0.25 THEN RAISE NOTICE '随机数大于0.25'; ELSE RAISE NOTICE '随机数小于或等于0.25'; END IF;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_if_elsif();NOTICE: 随机数大于0.50CALL

五、CASE 语句

postgres=# CREATE OR REPLACE PROCEDURE p_case() AS$$ DECLARE v_float8 float8 := random();BEGIN CASE WHEN v_float8>0.99 THEN RAISE NOTICE '随机数大于0.99'; WHEN v_float8>0.5 THEN RAISE NOTICE '随机数大于0.50'; WHEN v_float8>0.25 THEN RAISE NOTICE '随机数大于0.25'; ELSE RAISE NOTICE '随机数小于或等于0.25'; END CASE;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_case();NOTICE: 随机数小于或等于0.25CALLpostgres=#

七、LOOP 循环

postgres=# CREATE OR REPLACE PROCEDURE p_loop() AS$$ DECLARE v_id INTEGER := 1;BEGIN LOOP RAISE NOTICE '%',v_id; EXIT WHEN random()>0.8; v_id := v_id + 1; END LOOP ;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_loop();NOTICE: 1NOTICE: 2NOTICE: 3CALLpostgres=#

八、WHILE 循环

postgres=# CREATE OR REPLACE PROCEDURE p_while() AS$$ DECLARE v_id INTEGER := 1; v_random float8 ;BEGIN LOOP RAISE NOTICE '%',v_id; v_id := v_id + 1; v_random := random(); IF v_random > 0.8 THEN RETURN; END IF; END LOOP ;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_while();NOTICE: 1CALL

九、FOR 循环

postgres=# CREATE OR REPLACE PROCEDURE p_for() AS$$ BEGIN FOR i IN 1..3 LOOP RAISE NOTICE 'i = %',i; END LOOP;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_for();NOTICE: i = 1NOTICE: i = 2NOTICE: i = 3CALLpostgres=# CREATE OR REPLACE PROCEDURE p_for_reverse() AS$$ BEGIN FOR i IN REVERSE 3..1 LOOP RAISE NOTICE 'i = %',i; END LOOP;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_for_reverse();NOTICE: i = 3NOTICE: i = 2NOTICE: i = 1CALL

使用 REVERSE 递减。

postgres=# CREATE OR REPLACE PROCEDURE p_for_by() AS$$ BEGIN FOR i IN 1..8 BY 2 LOOP RAISE NOTICE 'i = %',i; END LOOP;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_for_by();NOTICE: i = 1NOTICE: i = 3NOTICE: i = 5NOTICE: i = 7CALLpostgres=#

使用 BY 设置步长。

十、FOR 循环查询结果

postgres=# CREATE OR REPLACE PROCEDURE p_for_record() AS$$ DECLARE v_rec RECORD;BEGIN FOR v_rec IN SELECT relname,relkind FROM pg_class limit 2 LOOP RAISE NOTICE '%',v_rec; END LOOP;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_for_record();NOTICE: (pg_stat_statements,v)NOTICE: (pg_proc,v)CALLpostgres=#

十一、FOREACH 循环一个数组

postgres=# CREATE OR REPLACE PROCEDURE p_foreach() AS$$ DECLARE v_random_arr float8[]:=ARRAY[random(),random()]; v_random float8;BEGIN FOREACH v_random IN ARRAY v_random_arr LOOP RAISE NOTICE '%',v_random ; END LOOP;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_foreach();NOTICE: 0.744417542591691NOTICE: 0.804096563253552CALLpostgres=#postgres=# CREATE OR REPLACE PROCEDURE p_foreach_slice() AS$$ DECLARE v_random_arr float8[][]:=ARRAY[ARRAY[random(),random()],ARRAY[random(),random()]]; v_random float8;BEGIN FOREACH v_random SLICE 0 IN ARRAY v_random_arr LOOP RAISE NOTICE '%',v_random ; END LOOP;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_foreach_slice();NOTICE: 0.0220407997258008NOTICE: 0.898449067492038NOTICE: 0.190678883343935NOTICE: 0.103653562255204CALLpostgres=#

循环会通过计算 expression 得到的数组的个体元素进行迭代。

postgres=# CREATE OR REPLACE PROCEDURE p_foreach_slice_1() AS$$ DECLARE v_random_arr float8[][]:=ARRAY[ARRAY[random(),random()],ARRAY[random(),random()]]; v_random float8[];BEGIN FOREACH v_random SLICE 1 IN ARRAY v_random_arr LOOP RAISE NOTICE '%',v_random ; END LOOP;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_foreach_slice_1();NOTICE: {0.248282201588154,0.757913041394204}NOTICE: {0.0194511725567281,0.43799454299733}CALL

通过一个正 SLICE 值，FOREACH 通过数组的切片而不是单一元素迭代。

十三、动态执行

postgres=# CREATE OR REPLACE PROCEDURE p_execute() AS$$ DECLARE v_sql TEXT; v_relname TEXT;BEGIN v_sql := 'SELECT relname FROM pg_class limit 1'; EXECUTE v_sql INTO v_relname; RAISE NOTICE 'relname = %',v_relname;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_execute();NOTICE: relname = pg_stat_statementsCALLpostgres=#

也可以使用 immediate。

postgres=# CREATE OR REPLACE PROCEDURE p_execute() AS$$ DECLARE v_sql TEXT; v_relname TEXT;BEGIN v_sql := 'SELECT relname FROM pg_class limit 1'; EXECUTE immediate v_sql INTO v_relname; RAISE NOTICE 'relname = %',v_relname;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_execute();NOTICE: relname = s1CALLpostgres=#

动态执行就是拼 SQL 语句，然后使用 EXECUTE 命令执行。

十四、执行一个没有结果的命令

postgres=# CREATE OR REPLACE PROCEDURE p_perform() AS$$ BEGIN perform md5(random()::text);END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# call p_perform();CALLpostgres=#

十五、获取执行结果

postgres=# CREATE OR REPLACE PROCEDURE p_found() AS$$ DECLARE v_relname TEXT; BEGIN SELECT relname INTO v_relname FROM pg_class limit 1; IF FOUND THEN RAISE NOTICE '查询到记录，值为%',v_relname; ELSE RAISE NOTICE '查不到记录' ; END IF;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_found();NOTICE: 查询到记录，值为pg_stat_statementsCALL

十六、获取影响行数

postgres=# CREATE OR REPLACE PROCEDURE p_row_count() AS$$ DECLARE v_row_count BIGINT;BEGIN delete from t1; GET DIAGNOSTICS v_row_count = ROW_COUNT; RAISE NOTICE '查询到的记录数为 % ',v_row_count;END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# call p_row_count();NOTICE: 查询到的记录数为 3 CALLpostgres=#

十七、GOTO

postgres=# create or replace procedure p_goto(v_maxnum integer) as$$declare maxnum integer;begin maxnum := v_maxnum;for i in 1..maxnum loop if i=3 then goto label; end if; raise notice 'i=%',i;end loop;<<label>> raise notice 'goto end';end;$$language plpgsql;CREATE PROCEDUREpostgres=# call p_goto(5);NOTICE: i=1NOTICE: i=2NOTICE: goto endCALLpostgres=#

go 用于跳转到某个标签下。

十九、错误俘获处理

postgres=# CREATE OR REPLACE PROCEDURE p_exception(a_id integer,a_nc text) AS$$ BEGIN INSERT INTO t_exception VALUES(a_id,a_nc); RETURN ; EXCEPTION WHEN OTHERS THEN RAISE NOTICE '执行出错'; END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=#postgres=# CALL p_exception(1,'Tdsql_pg');CALLpostgres=# CALL p_exception(1,'Tdsql_pg');NOTICE: 执行出错CALL

20、获取错误相关信息

postgres=# CREATE OR REPLACE PROCEDURE p_exception_error(a_id integer,a_nc text) AS$$ DECLARE v_sqlstate text; v_context text; v_message_text text;BEGIN INSERT INTO t_exception VALUES(a_id,a_nc); RETURN ; EXCEPTION WHEN OTHERS THEN GET STACKED DIAGNOSTICS v_sqlstate = RETURNED_SQLSTATE, v_message_text = MESSAGE_TEXT, v_context = PG_EXCEPTION_CONTEXT; RAISE NOTICE '错误代码 : %',v_sqlstate; RAISE NOTICE '出错信息 : %',v_message_text; RAISE NOTICE '发生异常语句 : %',v_context; raise notice '错误代码 : % \\n出错信息 : % 发生异常语句 : %',v_sqlstate ,v_message_text,v_context; END;$$LANGUAGE plpgsql;CREATE PROCEDUREpostgres=# CALL p_exception_error(2,'Tdsql_pg');CALLpostgres=# CALL p_exception_error(2,'Tdsql_pg');NOTICE: 错误代码 : 23505NOTICE: 出错信息 : node:dn001, backend_pid:16204, nodename:dn001,backend_pid:16204,message:duplicate key value violates unique constraint "t_exception_id_uidx"NOTICE: 发生异常语句 : SQL statement "INSERT INTO t_exception VALUES(a_id,a_nc)"PL/pgSQL function p_exception_error(integer,text) line 7 at SQL statementNOTICE: 错误代码 : 23505 \\n出错信息 : node:dn001, backend_pid:16204, nodename:dn001,backend_pid:16204,message:duplicate key value violates unique constraint "t_exception_id_uidx" 发生异常语句 : SQL statement "INSERT INTO t_exception VALUES(a_id,a_nc)"PL/pgSQL function p_exception_error(integer,text) line 7 at SQL statementCALLpostgres=#

相关内容：

  1. TDSQL PostgreSQL版 控制结构 postgres=# CREATE OR REPLACE FUNCTION f26() RETURNS VOID ASpostgres-# $$ postgres$# BEGIN postgres$# IF random()>0.5 THENpostgres$# RAISE NOTICE '随机数大于0.5';postgres$# END IF;postgres$# END;postgres$# $$postgres。...
  2. TDSQL PostgreSQL版 变量使用（存储过程开发） 在一个块中使用的所有变量必须在该块的声明小节中事先进行声明，PL/pgSQL 变量可以是任意 SQL 数据类型，可以是一个简单数据类型、复合类型、RECORD、已经存在的表行类型、表字段类型、游标。...
  3. TDSQL PostgreSQL版 参数详细介绍（存储过程开发） 这篇说说TDSQL PostgreSQL版存储过程的参数模式（仅IN）、参数引用（无命名/别名/命名）、参数数据类型（基本、复合、行、游标、多态类型）及默认值，并说明多态类型重载和默认值冲突的注意事项。 参数引用：支持无命名参数、别名引用和命名参数三种方式。 参数数据类型：支持基本类型、复合类型、行类型、游标类型及多态类型，多态类型调用需显式声明类型避免歧义。 参数默认值：可设置默认值，但需注意与无参存储过程重载时可。...
  4. TDSQL PostgreSQL版 存储过程开发 CREATE [OR REPLACE] PROCEDURE [模式名.]存储过程 ([参数模式 [参数名] 数据类型 [default 默认值] [,…]]) AS[标签][DECLARE --变量定义]BEGIN--注释/*注释*/ --语句执行END;[标签]LANGUAGE PLPGSQL。...
  5. TDSQL PostgreSQL版 变量使用 在一个块中使用的所有变量必须在该块的声明小节中事先进行声明，PL/pgSQL 变量可以是任意 SQL 数据类型，可以是一个简单数据类型、复合类型、RECORD、已经存在的表行类型、表字段类型、游标。...
  6. TDSQL PostgreSQL版 参数详细介绍 参数模式总共有三种，分别是 IN(传入参数，这个是默认方式)、OUT(返回值参数)、INOUT(传入返回值参数)，下面介绍这几个参数模式的用法。...
  7. TDSQL PostgreSQL版 应用程序语法介绍 CREATE [OR REPLACE] FUNCTION [模式名.]函数名 ([参数模式 [参数名] 数据类型 [default 默认值] [,…]]) RETRUNS [SETOF] 数据类型 AS[标签][DECLARE --变量定义]BEGIN --注释 /*注释*/ --语句执行END;[标签]LANGUAGE PLPGSQL。...
  8. TDSQL PostgreSQL版 消息及异常输出 postgres=# CREATE OR REPLACE FUNCTION f28() RETURNS VOID ASpostgres-# $$ postgres$# DECLAREpostgres$# v_int INTEGER := 1;postgres$# BEGIN postgres$# RAISE NOTICE 'v_int = %, 随机数 = %',v_int,random();postgres$# E。...
赞 (0)
上一篇 4天前
下一篇 4天前