如何在存储过程中同时执行多条DDL语句？

Oracle存储过程默认是串行执行语句的，要让这5条建表DDL同时运行，得借助异步作业调度工具，比如DBMS_SCHEDULER（Oracle推荐的新版本工具，功能比旧的DBMS_JOB更完善）。核心思路是给每条DDL单独创建一个异步作业，让这些作业同时启动执行。

修改后的存储过程示例 #

create or replace procedure test is
    a number;
    b number;
    c number;
    d number;
    e number;
    f number;
    g number;
    h number;
    i number;
    j number;
    
    -- 生成唯一作业名，避免重复执行时冲突
    function get_unique_job_name(p_prefix varchar2) return varchar2 is
    begin
        return p_prefix || '_' || replace(sys_guid(), '-', '');
    end;
begin
    -- 这里需自行补充变量的赋值逻辑，示例仅为占位
    a := 1; b := 100;
    c := 1; d := 100;
    e := 1; f := 100;
    g := 1; h := 100;
    i := 1; j := 100;

    -- 为每条DDL创建异步作业并立即执行
    -- 作业1：创建t1
    dbms_scheduler.create_job(
        job_name        => get_unique_job_name('JOB_CREATE_T1'),
        job_type        => 'PLSQL_BLOCK',
        job_action      => 'begin execute immediate ''create table t1 as select * from test1 where id between ' || a || ' and ' || b || ''; end;',
        start_date      => systimestamp,
        enabled         => true,
        auto_drop       => true -- 作业执行完成后自动删除
    );
    
    -- 作业2：创建t2
    dbms_scheduler.create_job(
        job_name        => get_unique_job_name('JOB_CREATE_T2'),
        job_type        => 'PLSQL_BLOCK',
        job_action      => 'begin execute immediate ''create table t2 as select * from test2 where id between ' || c || ' and ' || d || ''; end;',
        start_date      => systimestamp,
        enabled         => true,
        auto_drop       => true
    );
    
    -- 作业3：创建t3
    dbms_scheduler.create_job(
        job_name        => get_unique_job_name('JOB_CREATE_T3'),
        job_type        => 'PLSQL_BLOCK',
        job_action      => 'begin execute immediate ''create table t3 as select * from test3 where id between ' || e || ' and ' || f || ''; end;',
        start_date      => systimestamp,
        enabled         => true,
        auto_drop       => true
    );
    
    -- 作业4：创建t4
    dbms_scheduler.create_job(
        job_name        => get_unique_job_name('JOB_CREATE_T4'),
        job_type        => 'PLSQL_BLOCK',
        job_action      => 'begin execute immediate ''create table t4 as select * from test4 where id between ' || g || ' and ' || h || ''; end;',
        start_date      => systimestamp,
        enabled         => true,
        auto_drop       => true
    );
    
    -- 作业5：创建t5
    dbms_scheduler.create_job(
        job_name        => get_unique_job_name('JOB_CREATE_T5'),
        job_type        => 'PLSQL_BLOCK',
        job_action      => 'begin execute immediate ''create table t5 as select * from test5 where id between ' || i || ' and ' || j || ''; end;',
        start_date      => systimestamp,
        enabled         => true,
        auto_drop       => true
    );

end test;
/

关键注意事项 #

• 权限要求：执行该存储过程的用户需要拥有CREATE JOB系统权限，同时要有对test1-test5表的查询权限、目标表空间的建表权限。
• 动态SQL处理：存储过程中不能直接写DDL语句，必须用EXECUTE IMMEDIATE动态执行，这里将DDL拼接成字符串传入作业的PLSQL块中。
• 作业唯一性：用SYS_GUID()生成唯一作业名，避免重复执行存储过程时出现作业名冲突错误。
• 异步特性：存储过程会立即返回，不会等待所有DDL执行完成，需手动查询表是否创建成功，或在作业中添加日志逻辑跟踪执行状态。
• 旧版本替代方案：如果使用Oracle 10g之前的版本，可改用DBMS_JOB实现，但该工具无自动删除作业功能，需手动调用DBMS_JOB.REMOVE清理废弃作业。

内容的提问来源于stack exchange，提问作者Aman Kumar Singh