PostgreSQL 存儲過程 通過設定條件，返回指定的數據表記錄

PL/pgSQL是 PostgreSQL 數據庫系統的一個可裝載的過程語言。

PL/pgSQL的設計目標是創建一種可裝載的過程語言，可以可用於創建函數和觸發器過程， 在SQL語言中添加控制結構功能， 能夠進行復雜的計算， 繼承所有用戶自定義類型，函數和操作符， 能夠定義被服務器信任（的語言）， 容易使用。

用PL/pgSQL創建的函數可以用在內置函數用的任何地方，例如，可以創建復雜的計算函數，並之后用它們來定義操作符或者在索引表達式中使用它們。

（PL/pgSQL - SQL存儲過程語言：https://wiki.postgresql.org/wiki/9.1%E7%AC%AC%E4%B8%89%E5%8D%81%E4%B9%9D%E7%AB%A0）

 

示例1.

--通過唯一ID，獲取數據表記錄
CREATE OR REPLACE FUNCTION getRealUsers()
    RETURNS SETOF t_user
    LANGUAGE 'plpgsql'
AS $BODY$
declare
    mysql text;
    idx integer;
    
    js_id text;
    
    user_info t_user;
    
    user_refcursor refcursor;  --多游標
begin
    idx := 0;
    mysql:='SELECT * FROM public.t_user ORDER BY js_id';
    
    open user_refcursor for execute mysql;  --打開游標
    loop  --開始循環
        fetch user_refcursor into user_info;  --將游標指定的值賦值給變量
           
        if found then  --處理邏輯
            --raise notice 'delete_flag: %',user_info.delete_flag;
            --raise notice 'js_id: %',user_info.js_id;
            if idx = 0 then 
                js_id := user_info.js_id;
                if user_info.delete_flag = 'f' then 
                    return next user_info;
                end if;
            else 
                if js_id = user_info.js_id then
                    if user_info.delete_flag = 'f' then 
                        return next user_info;
                    end if;
                else 
                    js_id := user_info.js_id;
                    if user_info.delete_flag = 'f' then 
                        return next user_info;
                    end if;
                end if;
            end if;
            idx := idx + 1;
        else 
            exit; 
        end if; 
    end loop;  --結束循環
    close user_refcursor;  --關閉游標
end;
$BODY$;

 

示例2.

--通過最新時間，獲取數據表記錄
CREATE OR REPLACE FUNCTION getRealUsers()
    RETURNS SETOF t_user
    LANGUAGE 'plpgsql'
AS $BODY$
declare
    mysql text;  --SQL
    js_id text;  --ID
    user_info t_user;  --數據表對象
    user_refcursor refcursor;  --多游標
begin
    js_id := '';
    mysql:='SELECT * FROM public.t_user ORDER BY js_id ASC, update_datetime DESC';
    
    open user_refcursor for execute mysql;  --打開游標
    loop  -- Start
        fetch user_refcursor into user_info;  --把游標的記錄設定到用戶情報
        
        if found then
            --把最新的ID記錄留下
            if js_id != user_info.js_id then
                js_id := user_info.js_id;
                return next user_info;
            end if;
        else 
            exit; 
        end if; 
    end loop;  -- End
    close user_refcursor;  --關閉游標
    
end;
$BODY$;

 

調用：

-- select * from t_user
select * from getRealUsers()  --跟數據表一樣使用

 

End