PolarDB:DBMS_JOB

テストデータの準備

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;

定期タスクの作成

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

定期タスクの内容、実行時刻、実行間隔の変更

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;

定期タスクの削除

REMOVE(job BINARY_INTEGER)

BEGIN
    DBMS_JOB.REMOVE(1);
END;

定期タスクの表示

SELECT * FROM sys.user_jobs;

タスク実行レコードの表示

SELECT * FROM all_scheduler_job_run_details;

データベース間の定期タスクの実行

DBMS_JOB エクステンションは postgres データベースでのみ設定できます。他のデータベースに定期タスクを設定するには、データベース間のタスクを設定する必要があります。

次の例では、DBMS_JOB エクステンションは postgres データベースで設定され、test データベースで実行されます。このタスクは、test データベースのテーブルに 1 分ごとに 1 つのデータレコードを挿入します。データベースの作成方法の詳細については、「データベース管理」をご参照ください。

1. test データベースで、jobrun という名前のテーブルと job_proc という名前のストアドプロシージャを作成します。

   • 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)', false, '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 all_scheduler_job_run_details;

     コマンドは次の結果を返します。

      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 データベースに切り替えて、テーブル内のデータをクエリします。

   以下はクエリコマンドです。

   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;