Oracle SQL脚本中如何并行执行两个CTAS任务并等待全部完成？

可行，你可以通过以下几种方式实现两张无关联表的并行CTAS创建，待任务全部完成后再执行关联查询：

方法1：使用Oracle DBMS_SCHEDULER创建并行调度任务 #

通过创建两个独立的调度任务同时执行CTAS语句，然后等待任务完成后再执行关联查询，适合需要自动化管控的场景。示例代码如下：

-- 创建第一个建表任务
BEGIN
  DBMS_SCHEDULER.CREATE_JOB(
    job_name        => 'CTAS_TABLE1_JOB',
    job_type        => 'PLSQL_BLOCK',
    job_action      => 'BEGIN EXECUTE IMMEDIATE ''CREATE TABLE table1 AS SELECT * FROM source_table1;''; END;',
    start_date      => SYSTIMESTAMP,
    enabled         => TRUE,
    auto_drop       => TRUE
  );
END;
/

-- 创建第二个建表任务
BEGIN
  DBMS_SCHEDULER.CREATE_JOB(
    job_name        => 'CTAS_TABLE2_JOB',
    job_type        => 'PLSQL_BLOCK',
    job_action      => 'BEGIN EXECUTE IMMEDIATE ''CREATE TABLE table2 AS SELECT * FROM source_table2;''; END;',
    start_date      => SYSTIMESTAMP,
    enabled         => TRUE,
    auto_drop       => TRUE
  );
END;
/

-- 等待两个任务全部完成
BEGIN
  DBMS_SCHEDULER.WAIT_FOR_JOB('CTAS_TABLE1_JOB', NULL);
  DBMS_SCHEDULER.WAIT_FOR_JOB('CTAS_TABLE2_JOB', NULL);
END;
/

-- 执行后续关联查询
SELECT * FROM table1 t1 JOIN table2 t2 ON t1.id = t2.id;

注意：执行此方案需要拥有CREATE JOB系统权限。

方法2：SQL Developer多窗口手动并行执行 #

打开两个SQL Developer工作表，分别在每个窗口中执行一条CTAS语句，待两个窗口的建表任务都执行完成后，再在第三个窗口中运行关联查询。这种方法无需额外权限，适合快速测试场景，但需要手动监控任务状态。

方法3：使用DBMS_PARALLEL_EXECUTE实现并行执行 #

通过Oracle的并行执行包，将两个CTAS任务放入并行块中运行，确保任务同时执行：

DECLARE
  v_task_name VARCHAR2(50) := 'PARALLEL_CTAS_TASK';
BEGIN
  -- 创建并行任务容器
  DBMS_PARALLEL_EXECUTE.CREATE_TASK(v_task_name);
  -- 定义两个并行执行单元
  DBMS_PARALLEL_EXECUTE.CREATE_CHUNKS_BY_SQL(v_task_name,
    'SELECT 1 AS chunk_id FROM DUAL UNION ALL SELECT 2 FROM DUAL');
  -- 启动并行任务
  DBMS_PARALLEL_EXECUTE.RUN_TASK(v_task_name,
    'DECLARE
       v_chunk NUMBER := :chunk_id;
     BEGIN
       IF v_chunk = 1 THEN
         EXECUTE IMMEDIATE ''CREATE TABLE table1 AS SELECT * FROM source_table1;'';
       ELSIF v_chunk = 2 THEN
         EXECUTE IMMEDIATE ''CREATE TABLE table2 AS SELECT * FROM source_table2;'';
       END IF;
     END;',
    DBMS_SQL.NATIVE,
    parallel_level => 2);
  -- 清理任务容器
  DBMS_PARALLEL_EXECUTE.DROP_TASK(v_task_name);
END;
/

-- 执行后续关联查询
SELECT * FROM table1 t1 JOIN table2 t2 ON t1.id = t2.id;

注意事项 #

• 并行执行会占用更多数据库CPU、IO资源，需确保当前数据库负载允许，避免影响其他业务。
• 若CTAS涉及的源表有实时DML操作，需注意数据一致性，可在CTAS语句后添加WITH READ ONLY，或根据业务需求锁定源表。

内容的提问来源于stack exchange，提问作者sbrbot