1.背景
在实际开发中,我们可能会利用存储过程批量处理业务,
对应有些存储过程可能会执行很长时间,这时我们需要客户端点操作后,存储过程异步执行
具体实现如下
1.创建处理业务的存储过程:sp_test_handle
2.创建触发业务的job:TEST_HANDLE_JOBS
3.创建客户端调用的存储过程:sp_test_handle_run
4.客户端调用存储过程sp_test_handle_run即可实现对sp_test_handle的异步调用;
2.实现步骤
1.创建处理业务的存储过程:sp_test_handle
create or replace procedure sp_test_handle(v_task_id number --任务编号 ) as ----------------------------------------------------------------------- -- 功能: 存储过程异步处理测试 -- 创建: lidongping 2020-9-30 ----------------------------------------------------------------------- begin -- 参数检查 if (v_task_id is null) then dbms_output.put_line(‘v_task_id 为空‘); return; end if; -- 处理业务 dbms_output.put_line(‘处理复杂的业务:‘ || v_task_id); exception when others then rollback; dbms_output.put_line(‘处理异常:‘ || v_task_id); end;
2.创建触发业务的job:TEST_HANDLE_JOBS
3.创建客户端调用的存储过程:sp_test_handle_run
create or replace procedure sp_test_handle_run(v_task_id number, -- 批次号 v_out_code out number, -- 错误码 v_out_msg out varchar2) -- 错误消息 as ----------------------------------------------------------------------- -- 功能: 执行任务 ----------------------------------------------------------------------- l_job_name varchar2(128) := ‘TEST_HANDLE_JOBS‘; begin -- 设置存储过程参数 dbms_scheduler.set_job_argument_value(job_name => l_job_name, argument_position => 1, argument_value => v_task_id); -- 启动job dbms_scheduler.enable(l_job_name); v_out_code := error_code.success; v_out_msg := ‘操作成功‘; exception when others then rollback; v_out_code := error_code.failed; v_out_msg := ‘过程异常:‘ || sqlerrm; end;
4.客户端调用存储过程sp_test_handle_run即可实现对sp_test_handle的异步调用;
完美!