PolarDB：DBMS_JOB

Catatan penggunaan

• Hanya akun dengan hak istimewa yang dapat menggunakan ekstensi DBMS_JOB. Untuk informasi lebih lanjut tentang pembuatan akun dengan hak istimewa, lihat Buat Akun Database.

• Ekstensi dbms_job hanya dapat dibuat di dalam database postgres. Jika ingin mengonfigurasi tugas terjadwal untuk database lainnya, konfigurasikan tugas lintas-database di dalam database postgres. Untuk detail lebih lanjut, lihat Jalankan Tugas Terjadwal Lintas-Databse.

Siapkan data uji

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;

Hapus ekstensi DBMS_JOB

DROP EXTENSION dbms_job CASCADE;

Buat tugas terjadwal

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

Kueri tugas terjadwal

SELECT * FROM sys.user_jobs;

Ubah konten, waktu mulai, dan interval eksekusi tugas terjadwal

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;

Ubah interval eksekusi tugas terjadwal

INTERVAL(job BINARY_INTEGER, interval VARCHAR2)

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

Ubah waktu mulai tugas terjadwal

NEXT_DATE(job BINARY_INTEGER, next_date DATE)

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

Ubah konten tugas terjadwal

WHAT(job BINARY_INTEGER, what VARCHAR2)

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

Hentikan dan jalankan ulang tugas terjadwal

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

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

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

Paksa tugas terjadwal untuk berjalan

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

Hapus tugas terjadwal

REMOVE(job BINARY_INTEGER)

BEGIN
    DBMS_JOB.REMOVE(1);
END;

Kueri catatan eksekusi tugas terjadwal

SELECT * FROM dbmsjob.pga_joblog;

Jalankan tugas terjadwal lintas-database

Ekstensi DBMS_JOB hanya berlaku untuk database postgres. Untuk mengonfigurasi tugas terjadwal pada database lain, atur tugas terjadwal lintas-database di dalam database postgres.

Contoh berikut menjelaskan cara mengonfigurasi tugas terjadwal lintas-database. Dalam contoh ini, ekstensi DBMS_JOB dikonfigurasi di dalam database postgres, sedangkan tugas terjadwal dikonfigurasi untuk berjalan di dalam database bernama test. Tujuan dari contoh ini adalah menyisipkan satu rekaman data per menit ke dalam tabel di dalam database test. Untuk informasi lebih lanjut tentang pembuatan database, lihat Buat Database.

1. Buat tabel bernama jobrun dan prosedur tersimpan bernama job_proc di dalam database test.

   • Gunakan pernyataan berikut untuk membuat tabel bernama jobrun:

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

   • Gunakan pernyataan berikut untuk membuat prosedur tersimpan bernama 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. Buat tugas terjadwal di dalam database postgres.

   Tambahkan nama database tempat Anda ingin menjalankan tugas terjadwal ke fungsi DBMS_JOB.SUBMIT(). Dalam contoh ini, tugas terjadwal dijalankan di dalam database bernama test. Untuk informasi lebih lanjut tentang parameter lainnya, lihat Buat Tugas Terjadwal.

   Contoh berikut memberikan ilustrasi:

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

3. Kueri status dan catatan eksekusi tugas terjadwal di dalam database postgres.

   • Kueri tugas terjadwal:

     SELECT * FROM sys.user_jobs;

     Keluaran berikut akan ditampilkan:

      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

   • Kueri catatan eksekusi:

     SELECT * FROM dbmsjob.pga_joblog;

     Keluaran berikut akan ditampilkan:

      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. Kueri data dalam tabel jobrun di dalam database test.

   Gunakan pernyataan berikut:

   SELECT * FROM jobrun;

   Keluaran berikut akan ditampilkan:

    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;