2

私は私のパッケージです。次のように複数のジョブをキューに入れています。

dbms_scheduler.create_job
  ( job_name     => p_job_name
  , job_type     => 'PLSQL_BLOCK'
  , job_action   => p_sql_code
  , start_date   => SYSDATE
  , enabled      => TRUE
  , comments     => 'Running batch jobs in parallel');

開始したい並列ジョブの数だけこれを実行したら、すべてのジョブが完了するまでブロックする必要があります。

ALL_SCHEDULER_JOB_RUN_DETAILS現在、テーブルをスリープしてポーリングしALL_SCHEDULER_JOBS、ジョブのステータスを確認する必要がありました。それは本当に醜い解決策のようです。私が使用するSQLは次のとおりです。

PROCEDURE run_jobs
  ( p_jobs    StringTableType
  , p_sql     VARCHAR2(4000) )
IS

  l_jobs         StringTableType;
  l_status       sys_type.STRING;
  l_additional_info  sys_type.text;
  l_done         BOOLEAN;
  i              PLS_INTEGER;

BEGIN

  l_jobs := p_jobs;

  -- Submit jobs
  FOR i IN 1..l_jobs.COUNT LOOP

  dbms_scheduler.create_job
    ( job_name     => l_jobs(i)
    , job_type     => 'PLSQL_BLOCK'
    , job_action   => p_sql
    , start_date   => SYSDATE
    , enabled      => TRUE
    , comments     => 'Running batch jobs in parallel');

  END LOOP;

  -- now wait untile all jobs are finished
  l_done := FALSE;

  WHILE NOT l_done LOOP

    DBMS_LOCK.sleep(5);

    l_done := TRUE;

    i := l_jobs.FIRST;
    WHILE i IS NOT NULL LOOP

      WITH jobs_log
           AS (SELECT job_name, state status, '' additional_info
                 FROM all_scheduler_jobs
               UNION
               SELECT job_name, status, additional_info
                 FROM all_scheduler_job_run_details
               )
      SELECT status, additional_info
        INTO l_status, l_additional_info
        FROM jobs_log
       WHERE job_name = p_jobs (i);

      --Analyze job status
      CASE
        WHEN l_status = 'RUNNING' THEN
          l_done := FALSE;

        WHEN l_status = 'SUCCEEDED' THEN
          l_jobs.DELETE(i);

        WHEN l_status = 'FAILED' THEN
          l_jobs.DELETE(i);

        ELSE
          l_done := FALSE;

      END CASE;

      i := l_jobs.NEXT(i);

    END LOOP;

  END LOOP;

END run_jobs;

すべてのジョブが完了するまでコードをブロックするにはどうすればよいですか? これを行うためのより良い方法がある場合、誰かが私に例を挙げてもらえますか?

4

4 に答える 4

1 
DECLARE
  cnt NUMBER:=1;
BEGIN
  WHILE cnt>=1
  LOOP
    SELECT count(1) INTO cnt FROM dba_scheduler_running_jobs srj
    WHERE srj.job_name IN ('TEST_JOB1','TEST_JOB2');
    IF cnt>0 THEN
      dbms_lock.sleep (5);
    END IF;
  END LOOP;
  dbms_output.put_line('ASASA');  
END;
于 2016-02-25T09:45:31.697 に答える
1

ジョブが多くない場合は、DBMS_LOCK パッケージを使用して独自のロック オブジェクトを作成できます。よく知られている名前を付けて、ジョブごとに 1 つ作成します。ジョブにロックを取得させ、マスター ジョブはすべてのロックが解放されるのを待ちます。

于 2013-03-11T01:23:49.113 に答える
1

残念ながら、Oracle のセッション間通信は、OS のプロセス間通信ほど便利ではありません。でも君ならできる

lock table ... in exclusive mode

ジョブ内でジョブ終了待ちを行う

select ... for update
于 2013-03-08T15:10:51.870 に答える