PolarDB:DBMS_JOB

Usage

• 特権アカウントのみがDBMS_JOBパッケージを使用できます。 特権アカウントの作成方法の詳細については、「データベースアカウントの作成」をご参照ください。
• セキュリティ上の理由から、dbms_job拡張子を手動で作成することはできません。 dbms_job拡張子を作成するには、Quota Centerに移動します。 polardb_pg_dbms_jobに対応する [操作] 列で [適用] をクリックします。
• 既存のdbms_job拡張子がある場合は、このトピックで説明されている手順に従って削除して再インストールします。 次の構文を使用して、拡張機能を削除できます。
  警告 拡張子を削除すると、拡張子に関連するスケジュール済みジョブが削除されます。 拡張機能を削除する前に、データをバックアップします。

  drop extension dbms_job;

• dbms_job拡張子は、postgresデータベースにのみ作成できます。 他のデータベースのスケジュール済みジョブを構成する場合は、postgresデータベースでクロスデータベースのスケジュール済みジョブを構成します。 詳細については、「データベース間でのスケジュールされたジョブの実行」をご参照ください。

テストデータの準備

    idシリアルNOT NULL PRIMARYキー、
    ランタイムVARCHAR2(40)
); 

IS
開始
    INSERT INTO jobrun(runtime) VALUES ('job_proc run at '| | TO_CHAR(SYSDATE, 'yyyy-mm-dd hh24:mi:ss));
エンド; 

DBMS_JOBパッケージの削除

DROP EXTENSION dbms_job CASCADE;

スケジュールされたジョブの作成

送信 (ジョブOUT BINARY_INTEGER、何VARCHAR2
[, next_date DATE [, interval VARCHAR2 ]]) 

TRUNC(sysdate、'mi') + 1/(24*60)

TRUNC(sysdate) + 1 + 1/(24)

TRUNC(next_day(sysdate,'monday')) + 1/24

TRUNC(LAST_DAY(SYSDATE)) + 1 + 1/24

TRUNC(ADD_MONTHS(SYSDATE、3) 、'Q') + 1/24

ADD_MONTHS(trunc(sysdate, 'yyy'), 12) + 1/24

Trunc(Sysdate + 1) + (8*60 + 10)/24*60

Trunc(sysdate,'hh') + (60 + 15)/(24 * 60)

。
   jobid INTEGER;
開始
   DBMS_JOB.SUBMIT(jobid,'job_proc;', SYSDATE, 'SYSDATE + 1/(24*60)');
エンド; 

DBMS_JOB.SUBMIT(jobid,'job_proc;', SYSDATE, 'TRUNC(sysdate,'mi') + 1/(24*60)');

DBMS_JOB.SUBMIT(jobid、'job_proc;'、SYSDATE、$$TRUNC(sysdate、'mi') + 1/(24*60)$);

スケジュールされたジョブの内容、開始時刻、実行間隔の変更

CHANGE(job BINARY_INTEGER what VARCHAR2, next_date DATE,interval VARCHAR2)

    DBMS_JOB.CHANGE(1、NULL、TO_DATE('29-DEC-20 '、'DD-MON-YY')) 、$$ Trunc(sysdate、'hh') + (60 + 15)/(24*60)$);
エンド; 

スケジュールされたジョブの実行間隔の変更

INTERVAL(job BINARY_INTEGER, interval VARCHAR2)

    DBMS_JOB.INTERVAL(1、'TRUNC(sysdate) + 1 + 1/(24)');
エンド; 

スケジュールされたジョブの開始時刻の変更

NEXT_DATE(job BINARY_INTEGER, next_date DATE)

    DBMS_JOB.NEXT_DATE(1, TO_DATE('30-DEC-20 ','DD-MON-YY'));
エンド; 

スケジュールされたジョブの内容を変更する

何 (job BINARY_INTEGER, WHAT VARCHAR2)

    DBMS_JOB.WHAT(1、'job_proc2');
エンド; 

スケジュールされたジョブの停止と開始

BROKEN(job BINARY_INTEGER, broken BOOLEAN [, next_date DATE ])

    DBMS_JOB.BROKEN(1,true);
END; 

    DBMS_JOB.BROKEN(1、false);
エンド; 

スケジュールされたジョブを強制的に実行する

RUN(job BINARY_INTEGER)

    DBMS_JOB.RUN(1);
エンド; 

スケジュール済みタスクの削除

REMOVE(job BINARY_INTEGER)

    DBMS_JOB.REMOVE(1);
エンド; 

スケジュールされたジョブの照会

select * fro m sys.us er_jobs;

スケジュールされたジョブの実行レコードの照会

select * from dbmsjob.pga_joblog;

データベース間でスケジュールされたジョブを実行する

DBMS_JOBパッケージは、postgresデータベースにのみ適用されます。 他のデータベースのスケジュール済みジョブを構成する場合は、postgresデータベースでクロスデータベースのスケジュール済みジョブを構成します。

例を使用して、データベース間でスケジュールされたジョブを構成する方法を説明します。 この例では、DBMS_JOBパッケージはpostgresデータベースで構成されています。 スケジュールされたジョブは、testという名前のデータベースで実行されるように構成されます。 この例では、testデータベースのテーブルに1分あたり1つのデータレコードを挿入します。 データベースの作成方法の詳細については、「データベースの作成」をご参照ください。

1. jobrunという名前のテーブルとjob_procという名前のストアドプロシージャをtestデータベースに作成します。
   • 次のステートメントを実行して、jobrunという名前のテーブルを作成します。

     create table public.jobrun ()
         idシリアルNOT NULL PRIMARYキー、
         ランタイムVARCHAR2(40)
     ); 

   • 次のステートメントを実行して、job_procという名前のストアドプロシージャを作成します。

     create procedure public.job_proc
     IS
     開始
         INSERT INTO jobrun(runtime) VALUES ('job_proc run at '| | TO_CHAR(SYSDATE, 'yyyy-mm-dd hh24:mi:ss));
     エンド; 

2. postgresデータベースにスケジュールされたジョブを作成します。

   スケジュールされたジョブを実行するデータベースをDBMS_JOB.SUBMIT() 関数に追加する必要があります。 この例では、スケジュールされたジョブが実行されるデータベースの名前はtestです。 その他のパラメーターの詳細については、「スケジュールされたジョブの作成」をご参照ください。

   次のサンプルステートメントの例を示します。

   
      jobid INTEGER;
   開始
      DBMS_JOB.SUBMIT(jobid,'job_proc;', SYSDATE, 'SYSDATE + 1/(24*60)','test');
   エンド; 

3. postgresデータベース内のスケジュールされたジョブの状態と実行レコードを照会します。
   • スケジュールされたジョブを照会する:

     select * fro m sys.us er_jobs;

     次の出力が返されます:

     job | jobloguser | job_user | データベース | job_created | job_changed | last_date | last_sec | next_date | next_sec | total_time | interval | 障害 | what | instance
     ---- ------------ ---------------------- ---------------------------------- ---------------------------------- ---------------------------------- -------------------------------- ----------------- -----------------------
        1 | DBUSER | postgres | 29-OCT-20 02:38:49.478494 + 00:00 | BE-OCT-20 02:38:49.478494 + 00:00 | 29-OCT-20 02:51:12.025001 + 00:00 | 02:51:12 | 29-Ojms_END SELE_00:00 | GIdb_00:00 /N; GIobs_243224 * N ''、''test'');' ; END | 0 

   • 実行レコードのクエリ:

     select * from dbmsjob.pga_joblog;

     次の出力が返されます:

     jlgid | jlgjobid | jlgstatus | jlgstart | jlgduration
     ------- --------- --------------- ---------------------------------- -----------------
          1 | 1 | s | 29-OCT-20 02:38:49.762995 + 00:00 | 00:00:00.017495
          2 | 1 | s | 29-OCT-20 02:39:50.061113 + 00:00 | 00:00:00.016463
          3 | 1 | s | 29-OCT-20 02:40:50.062331 + 00:00 | 00:00:00.016244 

4. testデータベースのjobrunテーブルのデータを照会します。

   実行するステートメントは、次のとおりです。

   select * from jobrun;

   次の出力が返されます:

   id | runtime
   ---- + -------------------------------------
     1 | job_procは2020-10-29 02:38:50で実行します
     2 | job_procは2020-10-29 02:39:50で実行します
     3 | job_procは2020-10-29 02:40:50

   で実行

を実行します。
    DBMS_JOB.CHANGE(1,NULL,SYSDATE,'SYSDATE + 1/(24*30)','test');
エンド;