PolarDB:DBMS_JOB

使用上の注意

• 特権アカウントのみがDBMS_JOB拡張機能を使用できます。 特権アカウントの作成方法の詳細については、「データベースアカウントの作成」をご参照ください。

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

テストデータの準備

CREATE TABLE jobrun (
    id              serial               NOT NULL PRIMARY KEY,
    runtime         VARCHAR2(40)
);

CREATE PROCEDURE job_proc
IS
BEGIN
    INSERT INTO jobrun(runtime) VALUES ('job_proc run at ' || TO_CHAR(SYSDATE, 'yyyy-mm-dd hh24:mi:ss'));
END;

DBMS_JOB拡張子の削除

DROP EXTENSION dbms_job CASCADE;

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

SUBMIT(job OUT BINARY_INTEGER, what 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,'yyyy'), 12) + 1/24

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

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

DECLARE
   jobid           INTEGER;
BEGIN
   DBMS_JOB.SUBMIT(jobid,'job_proc;', SYSDATE, 'SYSDATE + 1/(24 * 60)');
END;

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)$$);

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

SELECT * FROM sys.user_jobs;

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

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

BEGIN
    DBMS_JOB.CHANGE(1,NULL,TO_DATE('29-DEC-20','DD-MON-YY'),$$Trunc(sysdate,'hh') + (60+15)/(24*60)$$);
END;

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

INTERVAL(job BINARY_INTEGER, interval VARCHAR2)

BEGIN
    DBMS_JOB.INTERVAL(1,'TRUNC(sysdate) + 1 + 1/(24)');
END;

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

NEXT_DATE(job BINARY_INTEGER, next_date DATE)

BEGIN
    DBMS_JOB.NEXT_DATE(1, TO_DATE('30-DEC-20','DD-MON-YY'));
END;

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

WHAT(job BINARY_INTEGER, what VARCHAR2)

BEGIN
    DBMS_JOB.WHAT(1,'job_proc2');
END;

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

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

BEGIN
    DBMS_JOB.BROKEN(1,true);
END;

BEGIN
    DBMS_JOB.BROKEN(1,false);
END;

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

RUN(job BINARY_INTEGER)

BEGIN
    DBMS_JOB.RUN(1);
END;

ERROR: syntax error at end of input
CONTEXT: polar-spl function dbms_job._run_job(integer,boolean) line 151 at RAISE line 547 of package body

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

REMOVE(job BINARY_INTEGER)

BEGIN
    DBMS_JOB.REMOVE(1);
END;

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

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       serial NOT NULL PRIMARY KEY,
         runtime  VARCHAR2(40)
     );

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

     CREATE PROCEDURE public.job_proc
     IS
     BEGIN
         INSERT INTO jobrun(runtime) VALUES ('job_proc run at ' || TO_CHAR(SYSDATE, 'yyyy-mm-dd hh24:mi:ss'));
     END;

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

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

   次のサンプル文は例を示します。

   DECLARE
      jobid           INTEGER;
   BEGIN
      DBMS_JOB.SUBMIT(jobid,'job_proc;', SYSDATE, 'SYSDATE + 1/(24 * 60)','test');
   END;

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

   • スケジュールされたジョブを照会する:

     SELECT * FROM sys.user_jobs;

     次の出力が返されます。

      job | jobloguser | job_user | database |           job_created            |           job_changed            |            last_date             | last_sec |         next_date         | next_sec |   total_time    | broken |                 interval                 | failures |                                                      what                                                       | instance
     -----+------------+----------+----------+----------------------------------+----------------------------------+----------------------------------+----------+---------------------------+----------+-----------------+--------+------------------------------------------+----------+-----------------------------------------------------------------------------------------------------------------+----------
        1 | DBUSER     | dbuser   | postgres | 29-OCT-20 02:38:49.478494 +00:00 | 29-OCT-20 02:38:49.478494 +00:00 | 29-OCT-20 02:51:12.025001 +00:00 | 02:51:12 | 29-OCT-20 02:53:12 +00:00 | 02:53:12 | 00:00:00.243224 | N      | BEGIN return SYSDATE + 1/(24 * 30); END; |        0 |  BEGIN EXECUTE IMMEDIATE 'SELECT dbmsjob.dbms_job_internal_job_link(''BEGIN job_proc; END;'', ''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 run at 2020-10-29 02:38:50
     2 | job_proc run at 2020-10-29 02:39:50
     3 | job_proc run at 2020-10-29 02:40:50

BEGIN
    DBMS_JOB.CHANGE(1,NULL,SYSDATE,'SYSDATE + 1/(24 * 30)','test');
END;