PG存儲(chǔ)過程是什么

這篇文章主要講解了“PG存儲(chǔ)過程是什么”,文中的講解內(nèi)容簡(jiǎn)單清晰,易于學(xué)習(xí)與理解,下面請(qǐng)大家跟著小編的思路慢慢深入,一起來研究和學(xué)習(xí)“PG存儲(chǔ)過程是什么”吧!

成都創(chuàng)新互聯(lián)公司長(zhǎng)期為1000+客戶提供的網(wǎng)站建設(shè)服務(wù),團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年,關(guān)注不同地域、不同群體,并針對(duì)不同對(duì)象提供差異化的產(chǎn)品和服務(wù);打造開放共贏平臺(tái),與合作伙伴共同營(yíng)造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為唐山企業(yè)提供專業(yè)的網(wǎng)站建設(shè)、網(wǎng)站制作,唐山網(wǎng)站改版等技術(shù)服務(wù)。擁有十年豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開發(fā)。

-- 刪除函數(shù)
drop function if exists upgrade_task_device(integer);

create or replace function upgrade_task_device(exec_way integer)
    returns integer as
$$
declare
    cron_prefix     varchar default '0 */';
    cron_suffix     varchar default ' * * * ?';
    cron_period     varchar;
    tmp_cron_period integer;
    cron_exp        varchar default '';
    cur_row         record;
    ret             integer default 0;
    task_cursor cursor (exec_way integer) for select t.*
                                              from task t
                                              where t.execution_way = exec_way;
begin
    -- task表如果 time_period > 59,設(shè)值為59
    update task set time_period = 59 where time_period is not null and time_period > 59;
    open task_cursor(exec_way);
    loop
        fetch task_cursor into cur_row;
        exit when not FOUND;
        -- 定時(shí)執(zhí)行|立即執(zhí)行
        if cur_row.execution_way = 1 or cur_row.execution_way = 2 then
            update task_device
            set task_type     = cur_row.task_type,
                task_name     = cur_row.task_name,
                retry         = cur_row.retry,
                start_time=cur_row.start_time,
                end_time=cur_row.end_time,
                -- 執(zhí)行方式全部更改為‘周期執(zhí)行’
                execution_way = 3,
                create_user_id=cur_row.create_user_id
            where task_id = cur_row.id
              and time_rule is null;
        elsif cur_row.execution_way = 3 then
            -- 周期執(zhí)行
            tmp_cron_period = cur_row.time_period;
            if tmp_cron_period > 59 then
                tmp_cron_period = 59;
            end if;
            -- 轉(zhuǎn)換為字符串進(jìn)行拼接
            cron_period = TRIM(to_char(tmp_cron_period, '99'));
            -- cron 拼接
            cron_exp = cron_prefix || cron_period || cron_suffix;
            update task_device
            set task_type     = cur_row.task_type,
                task_name     = cur_row.task_name,
                retry         = cur_row.retry,
                start_time=cur_row.start_time,
                end_time=cur_row.end_time,
                time_rule=cron_exp,
                -- 執(zhí)行方式全部更改為‘周期執(zhí)行’
                execution_way = 3,
                create_user_id=cur_row.create_user_id
            where task_id = cur_row.id
              and time_rule is null;
        end if;
    end loop;
    close task_cursor;
    ret = 1;
    return ret;
end;
$$ language plpgsql;

-- 分別處理定時(shí)執(zhí)行、周期執(zhí)行、立即執(zhí)行
select upgrade_task_device(1);
select upgrade_task_device(2);
select upgrade_task_device(3);

-- 刪除函數(shù)
drop function if exists upgrade_task_device(integer);

感謝各位的閱讀,以上就是“PG存儲(chǔ)過程是什么”的內(nèi)容了,經(jīng)過本文的學(xué)習(xí)后,相信大家對(duì)PG存儲(chǔ)過程是什么這一問題有了更深刻的體會(huì),具體使用情況還需要大家實(shí)踐驗(yàn)證。這里是創(chuàng)新互聯(lián),小編將為大家推送更多相關(guān)知識(shí)點(diǎn)的文章,歡迎關(guān)注!

文章題目:PG存儲(chǔ)過程是什么
當(dāng)前地址:http://www.muchs.cn/article48/jdoshp.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián),為您提供網(wǎng)站制作、建站公司、網(wǎng)站排名、動(dòng)態(tài)網(wǎng)站、自適應(yīng)網(wǎng)站商城網(wǎng)站

廣告

聲明:本網(wǎng)站發(fā)布的內(nèi)容(圖片、視頻和文字)以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主,如果涉及侵權(quán)請(qǐng)盡快告知,我們將會(huì)在第一時(shí)間刪除。文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如需處理請(qǐng)聯(lián)系客服。電話:028-86922220;郵箱:631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載,或轉(zhuǎn)載時(shí)需注明來源: 創(chuàng)新互聯(lián)

h5響應(yīng)式網(wǎng)站建設(shè)