用PL/pgSQL写postgreSQL的存储过程

前端之家收集整理的这篇文章主要介绍了用PL/pgSQL写postgreSQL的存储过程前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。

今天学会了用 PL/pgsql 写 postgresql 的存储过程,网上资料实在少得可怜,唯一能搜到的一些还是抄来抄去的;还是翻postgresql的文档吧,把今天解决的问题说一下吧,希望对其他人有帮助。
问题是这样的,有一张message表:
CREATE TABLE message
(
id int8 NOT NULL,
receiveuserid int8,
senduserid int8,
receivedelete bool DEFAULT false,
senddelete bool DEFAULT false,
……
CONSTRAINT usermessage_pkey PRIMARY KEY (id)
)
略去其他字段,senduserid是发信息的用户id,senddelete如为true则表示这条消息被发信人所删除;至于receive我就不用说了。一条信息只有被发信人和收信人都删除,才能真正从表里删除(这是显然的,否则收信人删了一条消息后,发信人的“发件箱”里就会找不到这条消息)。
所以删除消息(可能是多条消息)的时候要进行各种判断(是否是发信人?是否是收信人?是否真正删除?),用单条sql语句完成这个工作显然有些困难(当然用循环嵌套select不考虑效率的话也是可以实现的),只好写存储过程了。
顺便介绍常用的PL/pgsql结构和语法吧:

  • 结构@H_502_22@

    PL/pgsql是一种块结构的语言,比较方便的是用pgAdmin III新建Function,填入一些参数就可以了。基本上是这样的:

    CREATE OR REPLACE FUNCTION 函数名(参数1,[整型 int4,整型数组 _int4,...])
    RETURNS 返回值类型 AS
    $BODY$
    DECLARE
    变量声明
    BEGIN
    函数
    END;
    $BODY$
    LANGUAGE ‘plpgsql’ VOLATILE;

  • 变量类型@H_502_22@

    除了postgresql内置的变量类型外,常用的还有 RECORD ,表示一条记录。

  • 赋值@H_502_22@

    赋值和Pascal有点像:“变量 := 表达式;”
    有些奇怪的是连接字符串的是“||”,比如 sql := ‘SELECT * FROM’ || table || ‘WHERE …’;

  • 判断@H_502_22@

    判断又和VB有些像:
    IF 条件 THEN

    ELSEIF 条件 THEN

    ELSE

    END IF;

  • 循环@H_502_22@

    循环有好几种写法:
    WHILE expression LOOP
    statements
    END LOOP;
    还有常用的一种是:(从1循环到9可以写成FOR i IN 1..9 LOOP)
    FOR name IN [ REVERSE ] expression .. expression LOOP
    statements
    END LOOP;

  • 其他@H_502_22@

    还有几个常用的函数
    SELECT INTO record …; 表示将select的结果赋给record变量(RECORD类型)
    PERFORM query; 表示执行query并丢弃结果
    EXECUTE sql; 表示执行sql语句,这条可以动态执行sql语句(特别是由参数传入构造sql语句的时候特别有用)

最后,贴出解决上面这个问题的存储过程吧:

  1. CREATEORREPLACEFUNCTIONmessage_deletes(ids"varchar",useridint8)@H_502_22@
  2. RETURNSint4AS@H_502_22@
  3. $BODY$@H_502_22@
  4. DECLARE@H_502_22@
  5. rRECORD;@H_502_22@
  6. delbool;@H_502_22@
  7. numint4:=0;@H_502_22@
  8. sql"varchar";@H_502_22@
  9. BEGIN@H_502_22@
  10. sql:='select id,receiveuserid,senduserid,senddelete,receivedelete from message where id in ('||ids||')';@H_502_22@
  11. FORrINEXECUTEsqlLOOP@H_502_22@
  12. del:=false;@H_502_22@
  13. IFr.receiveuserid=useridandr.senduserid=useridTHEN@H_502_22@
  14. del:=true;@H_502_22@
  15. ELSEIFr.receiveuserid=useridTHEN@H_502_22@
  16. IFr.senddelete=falseTHEN@H_502_22@
  17. updatemessagesetreceivedelete=truewhereid=r.id;@H_502_22@
  18. ELSE@H_502_22@
  19. del:=true;@H_502_22@
  20. ENDIF;@H_502_22@
  21. ELSEIFr.senduserid=useridTHEN@H_502_22@
  22. IFr.receivedelete=falseTHEN@H_502_22@
  23. updatemessagesetsenddelete=truewhereid=r.id;@H_502_22@
  24. ELSE@H_502_22@
  25. del:=true;@H_502_22@
  26. ENDIF;@H_502_22@
  27. ENDIF;@H_502_22@
  28. IFdelTHEN@H_502_22@
  29. deletefrommessagewhereid=r.id;@H_502_22@
  30. num:=num+1;@H_502_22@
  31. ENDIF;@H_502_22@
  32. ENDLOOP;@H_502_22@
  33. returnnum;@H_502_22@
  34. END;@H_502_22@
  35. $BODY$@H_502_22@
  36. LANGUAGE'plpgsql'VOLATILE;@H_502_22@

测试使用:

猜你在找的Postgre SQL相关文章