PG存储过程是什么

-- 删除函数
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，设值为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;
        -- 定时执行|立即执行
        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,
                -- 执行方式全部更改为‘周期执行’
                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
            -- 周期执行
            tmp_cron_period = cur_row.time_period;
            if tmp_cron_period > 59 then
                tmp_cron_period = 59;
            end if;
            -- 转换为字符串进行拼接
            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,
                -- 执行方式全部更改为‘周期执行’
                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;

-- 分别处理定时执行、周期执行、立即执行
select upgrade_task_device(1);
select upgrade_task_device(2);
select upgrade_task_device(3);

-- 删除函数
drop function if exists upgrade_task_device(integer);