From 317c269a2ddeac6f643090fb79e6f209970f401a Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E7=96=AF=E7=8B=82=E7=9A=84=E7=8B=AE=E5=AD=90Li?= <15040126243@163.com> Date: Thu, 6 Jul 2023 16:52:13 +0800 Subject: [PATCH] =?UTF-8?q?update=20=E4=BC=98=E5=8C=96=20=E6=8F=90?= =?UTF-8?q?=E4=BE=9Bpowerjob=E5=AE=8C=E6=95=B4sql=E8=84=9A=E6=9C=AC=20?= =?UTF-8?q?=E9=99=8D=E4=BD=8E=E7=94=A8=E6=88=B7=E4=BD=BF=E7=94=A8=E9=9A=BE?= =?UTF-8?q?=E5=BA=A6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- sql/oracle/oracle_ry_job.sql | 694 +++++++++++++++++++++++++++++++ sql/postgres/postgres_ry_job.sql | 258 ++++++++++++ sql/powerjob_demo.sql | 5 - sql/ry-job.sql | 233 +++++++++++ 4 files changed, 1185 insertions(+), 5 deletions(-) create mode 100644 sql/oracle/oracle_ry_job.sql create mode 100644 sql/postgres/postgres_ry_job.sql delete mode 100644 sql/powerjob_demo.sql create mode 100644 sql/ry-job.sql diff --git a/sql/oracle/oracle_ry_job.sql b/sql/oracle/oracle_ry_job.sql new file mode 100644 index 00000000..83ebd410 --- /dev/null +++ b/sql/oracle/oracle_ry_job.sql @@ -0,0 +1,694 @@ +-- ---------------------------- +-- Table structure for PJ_APP_INFO +-- ---------------------------- +CREATE TABLE "PJ_APP_INFO" ( + "ID" NUMBER(19) VISIBLE NOT NULL , + "APP_NAME" VARCHAR2(255 CHAR) VISIBLE , + "CURRENT_SERVER" VARCHAR2(255 CHAR) VISIBLE , + "GMT_CREATE" TIMESTAMP(6) VISIBLE , + "GMT_MODIFIED" TIMESTAMP(6) VISIBLE , + "PASSWORD" VARCHAR2(255 CHAR) VISIBLE +) +TABLESPACE "ROOT" +LOGGING +NOCOMPRESS +PCTFREE 10 +INITRANS 1 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT +) +PARALLEL 1 +NOCACHE +DISABLE ROW MOVEMENT +; + +-- ---------------------------- +-- Records of "PJ_APP_INFO" +-- ---------------------------- +INSERT INTO "PJ_APP_INFO" VALUES ('1', 'ruoyi-worker', '127.0.0.1:10010', NULL, NULL, '123456'); + +-- ---------------------------- +-- Table structure for PJ_CONTAINER_INFO +-- ---------------------------- +CREATE TABLE "PJ_CONTAINER_INFO" ( + "ID" NUMBER(19) VISIBLE NOT NULL , + "APP_ID" NUMBER(19) VISIBLE , + "CONTAINER_NAME" VARCHAR2(255 CHAR) VISIBLE , + "GMT_CREATE" TIMESTAMP(6) VISIBLE , + "GMT_MODIFIED" TIMESTAMP(6) VISIBLE , + "LAST_DEPLOY_TIME" TIMESTAMP(6) VISIBLE , + "SOURCE_INFO" VARCHAR2(255 CHAR) VISIBLE , + "SOURCE_TYPE" NUMBER(10) VISIBLE , + "STATUS" NUMBER(10) VISIBLE , + "VERSION" VARCHAR2(255 CHAR) VISIBLE +) +TABLESPACE "ROOT" +LOGGING +NOCOMPRESS +PCTFREE 10 +INITRANS 1 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT +) +PARALLEL 1 +NOCACHE +DISABLE ROW MOVEMENT +; + +-- ---------------------------- +-- Table structure for PJ_INSTANCE_INFO +-- ---------------------------- +CREATE TABLE "PJ_INSTANCE_INFO" ( + "ID" NUMBER(19) VISIBLE NOT NULL , + "ACTUAL_TRIGGER_TIME" NUMBER(19) VISIBLE , + "APP_ID" NUMBER(19) VISIBLE , + "EXPECTED_TRIGGER_TIME" NUMBER(19) VISIBLE , + "FINISHED_TIME" NUMBER(19) VISIBLE , + "GMT_CREATE" TIMESTAMP(6) VISIBLE , + "GMT_MODIFIED" TIMESTAMP(6) VISIBLE , + "INSTANCE_ID" NUMBER(19) VISIBLE , + "INSTANCE_PARAMS" CLOB VISIBLE , + "JOB_ID" NUMBER(19) VISIBLE , + "JOB_PARAMS" CLOB VISIBLE , + "LAST_REPORT_TIME" NUMBER(19) VISIBLE , + "RESULT" CLOB VISIBLE , + "RUNNING_TIMES" NUMBER(19) VISIBLE , + "STATUS" NUMBER(10) VISIBLE , + "TASK_TRACKER_ADDRESS" VARCHAR2(255 CHAR) VISIBLE , + "TYPE" NUMBER(10) VISIBLE , + "WF_INSTANCE_ID" NUMBER(19) VISIBLE +) +TABLESPACE "ROOT" +LOGGING +NOCOMPRESS +PCTFREE 10 +INITRANS 1 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT +) +PARALLEL 1 +NOCACHE +DISABLE ROW MOVEMENT +; + +-- ---------------------------- +-- Table structure for PJ_JOB_INFO +-- ---------------------------- +CREATE TABLE "PJ_JOB_INFO" ( + "ID" NUMBER(19) VISIBLE NOT NULL , + "ALARM_CONFIG" VARCHAR2(255 CHAR) VISIBLE , + "APP_ID" NUMBER(19) VISIBLE , + "CONCURRENCY" NUMBER(10) VISIBLE , + "DESIGNATED_WORKERS" VARCHAR2(255 CHAR) VISIBLE , + "DISPATCH_STRATEGY" NUMBER(10) VISIBLE , + "EXECUTE_TYPE" NUMBER(10) VISIBLE , + "EXTRA" VARCHAR2(255 CHAR) VISIBLE , + "GMT_CREATE" TIMESTAMP(6) VISIBLE , + "GMT_MODIFIED" TIMESTAMP(6) VISIBLE , + "INSTANCE_RETRY_NUM" NUMBER(10) VISIBLE , + "INSTANCE_TIME_LIMIT" NUMBER(19) VISIBLE , + "JOB_DESCRIPTION" VARCHAR2(255 CHAR) VISIBLE , + "JOB_NAME" VARCHAR2(255 CHAR) VISIBLE , + "JOB_PARAMS" CLOB VISIBLE , + "LIFECYCLE" VARCHAR2(255 CHAR) VISIBLE , + "LOG_CONFIG" VARCHAR2(255 CHAR) VISIBLE , + "MAX_INSTANCE_NUM" NUMBER(10) VISIBLE , + "MAX_WORKER_COUNT" NUMBER(10) VISIBLE , + "MIN_CPU_CORES" FLOAT(126) VISIBLE NOT NULL , + "MIN_DISK_SPACE" FLOAT(126) VISIBLE NOT NULL , + "MIN_MEMORY_SPACE" FLOAT(126) VISIBLE NOT NULL , + "NEXT_TRIGGER_TIME" NUMBER(19) VISIBLE , + "NOTIFY_USER_IDS" VARCHAR2(255 CHAR) VISIBLE , + "PROCESSOR_INFO" VARCHAR2(255 CHAR) VISIBLE , + "PROCESSOR_TYPE" NUMBER(10) VISIBLE , + "STATUS" NUMBER(10) VISIBLE , + "TAG" VARCHAR2(255 CHAR) VISIBLE , + "TASK_RETRY_NUM" NUMBER(10) VISIBLE , + "TIME_EXPRESSION" VARCHAR2(255 CHAR) VISIBLE , + "TIME_EXPRESSION_TYPE" NUMBER(10) VISIBLE +) +TABLESPACE "ROOT" +LOGGING +NOCOMPRESS +PCTFREE 10 +INITRANS 1 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT +) +PARALLEL 1 +NOCACHE +DISABLE ROW MOVEMENT +; + +-- ---------------------------- +-- Records of "PJ_JOB_INFO" +-- ---------------------------- +INSERT INTO "PJ_JOB_INFO" VALUES ('1', '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', '1', '5', NULL, '2', '1', NULL, NULL, NULL, '1', '0', NULL, '单机处理器执行测试', NULL, '{}', '{\"type\":1}', '0', '0', '0.0000000000000000', '0.0000000000000000', '0.0000000000000000', NULL, NULL, 'org.dromara.job.processors.StandaloneProcessorDemo', '1', '2', NULL, '1', '30000', '3'); +INSERT INTO "PJ_JOB_INFO" VALUES ('2', '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', '1', '5', NULL, '1', '2', NULL, NULL, NULL, '0', '0', NULL, '广播处理器测试', NULL, '{}', '{\"type\":1}', '0', '0', '0.0000000000000000', '0.0000000000000000', '0.0000000000000000', NULL, NULL, 'org.dromara.job.processors.BroadcastProcessorDemo', '1', '2', NULL, '1', '30000', '3'); +INSERT INTO "PJ_JOB_INFO" VALUES ('3', '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', '1', '5', NULL, '1', '4', NULL, NULL, NULL, '0', '0', NULL, 'Map处理器测试', NULL, '{}', '{\"type\":1}', '0', '0', '0.0000000000000000', '0.0000000000000000', '0.0000000000000000', NULL, NULL, 'org.dromara.job.processors.MapProcessorDemo', '1', '2', NULL, '1', '1000', '3'); +INSERT INTO "PJ_JOB_INFO" VALUES ('4', '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', '1', '5', NULL, '1', '3', NULL, NULL, NULL, '0', '0', NULL, 'MapReduce处理器测试', NULL, '{}', '{\"type\":1}', '0', '0', '0.0000000000000000', '0.0000000000000000', '0.0000000000000000', NULL, NULL, 'org.dromara.job.processors.MapReduceProcessorDemo', '1', '2', NULL, '1', '1000', '3'); + +-- ---------------------------- +-- Table structure for PJ_OMS_LOCK +-- ---------------------------- +CREATE TABLE "PJ_OMS_LOCK" ( + "ID" NUMBER(19) VISIBLE NOT NULL , + "GMT_CREATE" TIMESTAMP(6) VISIBLE , + "GMT_MODIFIED" TIMESTAMP(6) VISIBLE , + "LOCK_NAME" VARCHAR2(255 CHAR) VISIBLE , + "MAX_LOCK_TIME" NUMBER(19) VISIBLE , + "OWNERIP" VARCHAR2(255 CHAR) VISIBLE +) +TABLESPACE "ROOT" +LOGGING +NOCOMPRESS +PCTFREE 10 +INITRANS 1 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT +) +PARALLEL 1 +NOCACHE +DISABLE ROW MOVEMENT +; + +-- ---------------------------- +-- Table structure for PJ_SERVER_INFO +-- ---------------------------- +CREATE TABLE "PJ_SERVER_INFO" ( + "ID" NUMBER(19) VISIBLE NOT NULL , + "GMT_CREATE" TIMESTAMP(6) VISIBLE , + "GMT_MODIFIED" TIMESTAMP(6) VISIBLE , + "IP" VARCHAR2(255 CHAR) VISIBLE +) +TABLESPACE "ROOT" +LOGGING +NOCOMPRESS +PCTFREE 10 +INITRANS 1 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT +) +PARALLEL 1 +NOCACHE +DISABLE ROW MOVEMENT +; + +-- ---------------------------- +-- Table structure for PJ_USER_INFO +-- ---------------------------- +CREATE TABLE "PJ_USER_INFO" ( + "ID" NUMBER(19) VISIBLE NOT NULL , + "EMAIL" VARCHAR2(255 CHAR) VISIBLE , + "EXTRA" VARCHAR2(255 CHAR) VISIBLE , + "GMT_CREATE" TIMESTAMP(6) VISIBLE , + "GMT_MODIFIED" TIMESTAMP(6) VISIBLE , + "PASSWORD" VARCHAR2(255 CHAR) VISIBLE , + "PHONE" VARCHAR2(255 CHAR) VISIBLE , + "USERNAME" VARCHAR2(255 CHAR) VISIBLE , + "WEB_HOOK" VARCHAR2(255 CHAR) VISIBLE +) +TABLESPACE "ROOT" +LOGGING +NOCOMPRESS +PCTFREE 10 +INITRANS 1 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT +) +PARALLEL 1 +NOCACHE +DISABLE ROW MOVEMENT +; + +-- ---------------------------- +-- Table structure for PJ_WORKFLOW_INFO +-- ---------------------------- +CREATE TABLE "PJ_WORKFLOW_INFO" ( + "ID" NUMBER(19) VISIBLE NOT NULL , + "APP_ID" NUMBER(19) VISIBLE , + "EXTRA" VARCHAR2(255 CHAR) VISIBLE , + "GMT_CREATE" TIMESTAMP(6) VISIBLE , + "GMT_MODIFIED" TIMESTAMP(6) VISIBLE , + "LIFECYCLE" VARCHAR2(255 CHAR) VISIBLE , + "MAX_WF_INSTANCE_NUM" NUMBER(10) VISIBLE , + "NEXT_TRIGGER_TIME" NUMBER(19) VISIBLE , + "NOTIFY_USER_IDS" VARCHAR2(255 CHAR) VISIBLE , + "PEDAG" CLOB VISIBLE , + "STATUS" NUMBER(10) VISIBLE , + "TIME_EXPRESSION" VARCHAR2(255 CHAR) VISIBLE , + "TIME_EXPRESSION_TYPE" NUMBER(10) VISIBLE , + "WF_DESCRIPTION" VARCHAR2(255 CHAR) VISIBLE , + "WF_NAME" VARCHAR2(255 CHAR) VISIBLE +) +TABLESPACE "ROOT" +LOGGING +NOCOMPRESS +PCTFREE 10 +INITRANS 1 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT +) +PARALLEL 1 +NOCACHE +DISABLE ROW MOVEMENT +; + +-- ---------------------------- +-- Table structure for PJ_WORKFLOW_INSTANCE_INFO +-- ---------------------------- +CREATE TABLE "PJ_WORKFLOW_INSTANCE_INFO" ( + "ID" NUMBER(19) VISIBLE NOT NULL , + "ACTUAL_TRIGGER_TIME" NUMBER(19) VISIBLE , + "APP_ID" NUMBER(19) VISIBLE , + "DAG" CLOB VISIBLE , + "EXPECTED_TRIGGER_TIME" NUMBER(19) VISIBLE , + "FINISHED_TIME" NUMBER(19) VISIBLE , + "GMT_CREATE" TIMESTAMP(6) VISIBLE , + "GMT_MODIFIED" TIMESTAMP(6) VISIBLE , + "PARENT_WF_INSTANCE_ID" NUMBER(19) VISIBLE , + "RESULT" CLOB VISIBLE , + "STATUS" NUMBER(10) VISIBLE , + "WF_CONTEXT" CLOB VISIBLE , + "WF_INIT_PARAMS" CLOB VISIBLE , + "WF_INSTANCE_ID" NUMBER(19) VISIBLE , + "WORKFLOW_ID" NUMBER(19) VISIBLE +) +TABLESPACE "ROOT" +LOGGING +NOCOMPRESS +PCTFREE 10 +INITRANS 1 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT +) +PARALLEL 1 +NOCACHE +DISABLE ROW MOVEMENT +; + +-- ---------------------------- +-- Table structure for PJ_WORKFLOW_NODE_INFO +-- ---------------------------- +CREATE TABLE "PJ_WORKFLOW_NODE_INFO" ( + "ID" NUMBER(19) VISIBLE NOT NULL , + "APP_ID" NUMBER(19) VISIBLE NOT NULL , + "ENABLE" NUMBER(1) VISIBLE NOT NULL , + "EXTRA" CLOB VISIBLE , + "GMT_CREATE" TIMESTAMP(6) VISIBLE NOT NULL , + "GMT_MODIFIED" TIMESTAMP(6) VISIBLE NOT NULL , + "JOB_ID" NUMBER(19) VISIBLE , + "NODE_NAME" VARCHAR2(255 CHAR) VISIBLE , + "NODE_PARAMS" CLOB VISIBLE , + "SKIP_WHEN_FAILED" NUMBER(1) VISIBLE NOT NULL , + "TYPE" NUMBER(10) VISIBLE , + "WORKFLOW_ID" NUMBER(19) VISIBLE +) +TABLESPACE "ROOT" +LOGGING +NOCOMPRESS +PCTFREE 10 +INITRANS 1 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT +) +PARALLEL 1 +NOCACHE +DISABLE ROW MOVEMENT +; + +-- ---------------------------- +-- Primary Key structure for table PJ_APP_INFO +-- ---------------------------- +ALTER TABLE "PJ_APP_INFO" ADD CONSTRAINT "SYS_C0012204" PRIMARY KEY ("ID"); + +-- ---------------------------- +-- Uniques structure for table PJ_APP_INFO +-- ---------------------------- +ALTER TABLE "PJ_APP_INFO" ADD CONSTRAINT "UIDX01_APP_INFO" UNIQUE ("APP_NAME") NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Checks structure for table PJ_APP_INFO +-- ---------------------------- +ALTER TABLE "PJ_APP_INFO" ADD CONSTRAINT "SYS_C0012203" CHECK ("ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Primary Key structure for table PJ_CONTAINER_INFO +-- ---------------------------- +ALTER TABLE "PJ_CONTAINER_INFO" ADD CONSTRAINT "SYS_C0012206" PRIMARY KEY ("ID"); + +-- ---------------------------- +-- Checks structure for table PJ_CONTAINER_INFO +-- ---------------------------- +ALTER TABLE "PJ_CONTAINER_INFO" ADD CONSTRAINT "SYS_C0012205" CHECK ("ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Indexes structure for table PJ_CONTAINER_INFO +-- ---------------------------- +CREATE INDEX "IDX01_CONTAINER_INFO" + ON "PJ_CONTAINER_INFO" ("APP_ID" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; + +-- ---------------------------- +-- Primary Key structure for table PJ_INSTANCE_INFO +-- ---------------------------- +ALTER TABLE "PJ_INSTANCE_INFO" ADD CONSTRAINT "SYS_C0012208" PRIMARY KEY ("ID"); + +-- ---------------------------- +-- Checks structure for table PJ_INSTANCE_INFO +-- ---------------------------- +ALTER TABLE "PJ_INSTANCE_INFO" ADD CONSTRAINT "SYS_C0012207" CHECK ("ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Indexes structure for table PJ_INSTANCE_INFO +-- ---------------------------- +CREATE INDEX "IDX01_INSTANCE_INFO" + ON "PJ_INSTANCE_INFO" ("JOB_ID" ASC, "STATUS" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; +CREATE INDEX "IDX02_INSTANCE_INFO" + ON "PJ_INSTANCE_INFO" ("APP_ID" ASC, "STATUS" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; +CREATE INDEX "IDX03_INSTANCE_INFO" + ON "PJ_INSTANCE_INFO" ("INSTANCE_ID" ASC, "STATUS" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; + +-- ---------------------------- +-- Primary Key structure for table PJ_JOB_INFO +-- ---------------------------- +ALTER TABLE "PJ_JOB_INFO" ADD CONSTRAINT "SYS_C0012213" PRIMARY KEY ("ID"); + +-- ---------------------------- +-- Checks structure for table PJ_JOB_INFO +-- ---------------------------- +ALTER TABLE "PJ_JOB_INFO" ADD CONSTRAINT "SYS_C0012209" CHECK ("ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; +ALTER TABLE "PJ_JOB_INFO" ADD CONSTRAINT "SYS_C0012210" CHECK ("MIN_CPU_CORES" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; +ALTER TABLE "PJ_JOB_INFO" ADD CONSTRAINT "SYS_C0012211" CHECK ("MIN_DISK_SPACE" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; +ALTER TABLE "PJ_JOB_INFO" ADD CONSTRAINT "SYS_C0012212" CHECK ("MIN_MEMORY_SPACE" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Indexes structure for table PJ_JOB_INFO +-- ---------------------------- +CREATE INDEX "IDX01_JOB_INFO" + ON "PJ_JOB_INFO" ("APP_ID" ASC, "NEXT_TRIGGER_TIME" ASC, "TIME_EXPRESSION_TYPE" ASC, "STATUS" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; + +-- ---------------------------- +-- Primary Key structure for table PJ_OMS_LOCK +-- ---------------------------- +ALTER TABLE "PJ_OMS_LOCK" ADD CONSTRAINT "SYS_C0012215" PRIMARY KEY ("ID"); + +-- ---------------------------- +-- Uniques structure for table PJ_OMS_LOCK +-- ---------------------------- +ALTER TABLE "PJ_OMS_LOCK" ADD CONSTRAINT "UIDX01_OMS_LOCK" UNIQUE ("LOCK_NAME") NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Checks structure for table PJ_OMS_LOCK +-- ---------------------------- +ALTER TABLE "PJ_OMS_LOCK" ADD CONSTRAINT "SYS_C0012214" CHECK ("ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Primary Key structure for table PJ_SERVER_INFO +-- ---------------------------- +ALTER TABLE "PJ_SERVER_INFO" ADD CONSTRAINT "SYS_C0012217" PRIMARY KEY ("ID"); + +-- ---------------------------- +-- Uniques structure for table PJ_SERVER_INFO +-- ---------------------------- +ALTER TABLE "PJ_SERVER_INFO" ADD CONSTRAINT "UIDX01_SERVER_INFO" UNIQUE ("IP") NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Checks structure for table PJ_SERVER_INFO +-- ---------------------------- +ALTER TABLE "PJ_SERVER_INFO" ADD CONSTRAINT "SYS_C0012216" CHECK ("ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Indexes structure for table PJ_SERVER_INFO +-- ---------------------------- +CREATE INDEX "IDX01_SERVER_INFO" + ON "PJ_SERVER_INFO" ("GMT_MODIFIED" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; + +-- ---------------------------- +-- Primary Key structure for table PJ_USER_INFO +-- ---------------------------- +ALTER TABLE "PJ_USER_INFO" ADD CONSTRAINT "SYS_C0012219" PRIMARY KEY ("ID"); + +-- ---------------------------- +-- Checks structure for table PJ_USER_INFO +-- ---------------------------- +ALTER TABLE "PJ_USER_INFO" ADD CONSTRAINT "SYS_C0012218" CHECK ("ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Indexes structure for table PJ_USER_INFO +-- ---------------------------- +CREATE INDEX "UIDX01_USER_INFO" + ON "PJ_USER_INFO" ("USERNAME" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; +CREATE INDEX "UIDX02_USER_INFO" + ON "PJ_USER_INFO" ("EMAIL" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; + +-- ---------------------------- +-- Primary Key structure for table PJ_WORKFLOW_INFO +-- ---------------------------- +ALTER TABLE "PJ_WORKFLOW_INFO" ADD CONSTRAINT "SYS_C0012221" PRIMARY KEY ("ID"); + +-- ---------------------------- +-- Checks structure for table PJ_WORKFLOW_INFO +-- ---------------------------- +ALTER TABLE "PJ_WORKFLOW_INFO" ADD CONSTRAINT "SYS_C0012220" CHECK ("ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Indexes structure for table PJ_WORKFLOW_INFO +-- ---------------------------- +CREATE INDEX "IDX01_WORKFLOW_INFO" + ON "PJ_WORKFLOW_INFO" ("APP_ID" ASC, "NEXT_TRIGGER_TIME" ASC, "TIME_EXPRESSION_TYPE" ASC, "STATUS" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; + +-- ---------------------------- +-- Primary Key structure for table PJ_WORKFLOW_INSTANCE_INFO +-- ---------------------------- +ALTER TABLE "PJ_WORKFLOW_INSTANCE_INFO" ADD CONSTRAINT "SYS_C0012223" PRIMARY KEY ("ID"); + +-- ---------------------------- +-- Uniques structure for table PJ_WORKFLOW_INSTANCE_INFO +-- ---------------------------- +ALTER TABLE "PJ_WORKFLOW_INSTANCE_INFO" ADD CONSTRAINT "UIDX01_WF_INSTANCE" UNIQUE ("WF_INSTANCE_ID") NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Checks structure for table PJ_WORKFLOW_INSTANCE_INFO +-- ---------------------------- +ALTER TABLE "PJ_WORKFLOW_INSTANCE_INFO" ADD CONSTRAINT "SYS_C0012222" CHECK ("ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Indexes structure for table PJ_WORKFLOW_INSTANCE_INFO +-- ---------------------------- +CREATE INDEX "IDX01_WF_INSTANCE" + ON "PJ_WORKFLOW_INSTANCE_INFO" ("WORKFLOW_ID" ASC, "EXPECTED_TRIGGER_TIME" ASC, "APP_ID" ASC, "STATUS" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; + +-- ---------------------------- +-- Primary Key structure for table PJ_WORKFLOW_NODE_INFO +-- ---------------------------- +ALTER TABLE "PJ_WORKFLOW_NODE_INFO" ADD CONSTRAINT "SYS_C0012230" PRIMARY KEY ("ID"); + +-- ---------------------------- +-- Checks structure for table PJ_WORKFLOW_NODE_INFO +-- ---------------------------- +ALTER TABLE "PJ_WORKFLOW_NODE_INFO" ADD CONSTRAINT "SYS_C0012224" CHECK ("ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; +ALTER TABLE "PJ_WORKFLOW_NODE_INFO" ADD CONSTRAINT "SYS_C0012225" CHECK ("APP_ID" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; +ALTER TABLE "PJ_WORKFLOW_NODE_INFO" ADD CONSTRAINT "SYS_C0012226" CHECK ("ENABLE" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; +ALTER TABLE "PJ_WORKFLOW_NODE_INFO" ADD CONSTRAINT "SYS_C0012227" CHECK ("GMT_CREATE" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; +ALTER TABLE "PJ_WORKFLOW_NODE_INFO" ADD CONSTRAINT "SYS_C0012228" CHECK ("GMT_MODIFIED" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; +ALTER TABLE "PJ_WORKFLOW_NODE_INFO" ADD CONSTRAINT "SYS_C0012229" CHECK ("SKIP_WHEN_FAILED" IS NOT NULL) NOT DEFERRABLE INITIALLY IMMEDIATE NORELY VALIDATE; + +-- ---------------------------- +-- Indexes structure for table PJ_WORKFLOW_NODE_INFO +-- ---------------------------- +CREATE INDEX "IDX01_WORKFLOW_NODE_INFO" + ON "PJ_WORKFLOW_NODE_INFO" ("GMT_CREATE" ASC, "WORKFLOW_ID" ASC) + LOGGING + TABLESPACE "ROOT" + VISIBLE +PCTFREE 10 +INITRANS 2 +STORAGE ( + INITIAL 65536 + NEXT 1048576 + MINEXTENTS 1 + MAXEXTENTS 2147483645 + BUFFER_POOL DEFAULT + FLASH_CACHE DEFAULT +) + USABLE; diff --git a/sql/postgres/postgres_ry_job.sql b/sql/postgres/postgres_ry_job.sql new file mode 100644 index 00000000..0e2265d3 --- /dev/null +++ b/sql/postgres/postgres_ry_job.sql @@ -0,0 +1,258 @@ +-- pj_app_info definition + +-- Drop table + +-- DROP TABLE pj_app_info; + +CREATE TABLE pj_app_info ( + id int8 NOT NULL, + app_name varchar(255) NULL, + current_server varchar(255) NULL, + gmt_create timestamp NULL, + gmt_modified timestamp NULL, + "password" varchar(255) NULL, + CONSTRAINT pj_app_info_pkey PRIMARY KEY (id), + CONSTRAINT uidx01_app_info UNIQUE (app_name) +); + +INSERT INTO pj_app_info VALUES(1, 'ruoyi-worker', '127.0.0.1:10010', '2023-06-13 16:32:59.263', '2023-07-04 17:25:49.798', '123456'); + + + +-- pj_container_info definition + +-- Drop table + +-- DROP TABLE pj_container_info; + +CREATE TABLE pj_container_info ( + id int8 NOT NULL, + app_id int8 NULL, + container_name varchar(255) NULL, + gmt_create timestamp NULL, + gmt_modified timestamp NULL, + last_deploy_time timestamp NULL, + source_info varchar(255) NULL, + source_type int4 NULL, + status int4 NULL, + "version" varchar(255) NULL, + CONSTRAINT pj_container_info_pkey PRIMARY KEY (id) +); +CREATE INDEX idx01_container_info ON pj_container_info USING btree (app_id); + + +-- pj_instance_info definition + +-- Drop table + +-- DROP TABLE pj_instance_info; + +CREATE TABLE pj_instance_info ( + id int8 NOT NULL, + actual_trigger_time int8 NULL, + app_id int8 NULL, + expected_trigger_time int8 NULL, + finished_time int8 NULL, + gmt_create timestamp NULL, + gmt_modified timestamp NULL, + instance_id int8 NULL, + instance_params oid NULL, + job_id int8 NULL, + job_params oid NULL, + last_report_time int8 NULL, + "result" oid NULL, + running_times int8 NULL, + status int4 NULL, + task_tracker_address varchar(255) NULL, + "type" int4 NULL, + wf_instance_id int8 NULL, + CONSTRAINT pj_instance_info_pkey PRIMARY KEY (id) +); +CREATE INDEX idx01_instance_info ON pj_instance_info USING btree (job_id, status); +CREATE INDEX idx02_instance_info ON pj_instance_info USING btree (app_id, status); +CREATE INDEX idx03_instance_info ON pj_instance_info USING btree (instance_id, status); + + +-- pj_job_info definition + +-- Drop table + +-- DROP TABLE pj_job_info; + +CREATE TABLE pj_job_info ( + id int8 NOT NULL, + alarm_config varchar(255) NULL, + app_id int8 NULL, + concurrency int4 NULL, + designated_workers varchar(255) NULL, + dispatch_strategy int4 NULL, + execute_type int4 NULL, + extra varchar(255) NULL, + gmt_create timestamp NULL, + gmt_modified timestamp NULL, + instance_retry_num int4 NULL, + instance_time_limit int8 NULL, + job_description varchar(255) NULL, + job_name varchar(255) NULL, + job_params oid NULL, + lifecycle varchar(255) NULL, + log_config varchar(255) NULL, + max_instance_num int4 NULL, + max_worker_count int4 NULL, + min_cpu_cores float8 NOT NULL, + min_disk_space float8 NOT NULL, + min_memory_space float8 NOT NULL, + next_trigger_time int8 NULL, + notify_user_ids varchar(255) NULL, + processor_info varchar(255) NULL, + processor_type int4 NULL, + status int4 NULL, + tag varchar(255) NULL, + task_retry_num int4 NULL, + time_expression varchar(255) NULL, + time_expression_type int4 NULL, + CONSTRAINT pj_job_info_pkey PRIMARY KEY (id) +); +CREATE INDEX idx01_job_info ON pj_job_info USING btree (app_id, status, time_expression_type, next_trigger_time); + + +INSERT INTO pj_job_info VALUES(1, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 2, 1, NULL, '2023-06-02 15:01:27.717', '2023-07-04 17:22:12.374', 1, 0, '', '单机处理器执行测试', NULL, '{}', '{\"type\":1}', 0, 0, 0.0, 0.0, 0.0, NULL, NULL, 'org.dromara.job.processors.StandaloneProcessorDemo', 1, 2, NULL, 1, '30000', 3); +INSERT INTO pj_job_info VALUES(2, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 2, NULL, '2023-06-02 15:04:45.342', '2023-07-04 17:22:12.816', 0, 0, NULL, '广播处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0.0, 0.0, 0.0, NULL, NULL, 'org.dromara.job.processors.BroadcastProcessorDemo', 1, 2, NULL, 1, '30000', 3); +INSERT INTO pj_job_info VALUES(3, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 4, NULL, '2023-06-02 15:13:23.519', '2023-06-02 16:03:22.421', 0, 0, NULL, 'Map处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0.0, 0.0, 0.0, NULL, NULL, 'org.dromara.job.processors.MapProcessorDemo', 1, 2, NULL, 1, '1000', 3); +INSERT INTO pj_job_info VALUES(4, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 3, NULL, '2023-06-02 15:45:25.896', '2023-06-02 16:03:23.125', 0, 0, NULL, 'MapReduce处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0.0, 0.0, 0.0, NULL, NULL, 'org.dromara.job.processors.MapReduceProcessorDemo', 1, 2, NULL, 1, '1000', 3); + + +-- pj_oms_lock definition + +-- Drop table + +-- DROP TABLE pj_oms_lock; + +CREATE TABLE pj_oms_lock ( + id int8 NOT NULL, + gmt_create timestamp NULL, + gmt_modified timestamp NULL, + lock_name varchar(255) NULL, + max_lock_time int8 NULL, + ownerip varchar(255) NULL, + CONSTRAINT pj_oms_lock_pkey PRIMARY KEY (id), + CONSTRAINT uidx01_oms_lock UNIQUE (lock_name) +); + + +-- pj_server_info definition + +-- Drop table + +-- DROP TABLE pj_server_info; + +CREATE TABLE pj_server_info ( + id int8 NOT NULL, + gmt_create timestamp NULL, + gmt_modified timestamp NULL, + ip varchar(255) NULL, + CONSTRAINT pj_server_info_pkey PRIMARY KEY (id), + CONSTRAINT uidx01_server_info UNIQUE (ip) +); +CREATE INDEX idx01_server_info ON pj_server_info USING btree (gmt_modified); + + +-- pj_user_info definition + +-- Drop table + +-- DROP TABLE pj_user_info; + +CREATE TABLE pj_user_info ( + id int8 NOT NULL, + email varchar(255) NULL, + extra varchar(255) NULL, + gmt_create timestamp NULL, + gmt_modified timestamp NULL, + "password" varchar(255) NULL, + phone varchar(255) NULL, + username varchar(255) NULL, + web_hook varchar(255) NULL, + CONSTRAINT pj_user_info_pkey PRIMARY KEY (id) +); +CREATE INDEX uidx01_user_info ON pj_user_info USING btree (username); +CREATE INDEX uidx02_user_info ON pj_user_info USING btree (email); + + +-- pj_workflow_info definition + +-- Drop table + +-- DROP TABLE pj_workflow_info; + +CREATE TABLE pj_workflow_info ( + id int8 NOT NULL, + app_id int8 NULL, + extra varchar(255) NULL, + gmt_create timestamp NULL, + gmt_modified timestamp NULL, + lifecycle varchar(255) NULL, + max_wf_instance_num int4 NULL, + next_trigger_time int8 NULL, + notify_user_ids varchar(255) NULL, + pedag oid NULL, + status int4 NULL, + time_expression varchar(255) NULL, + time_expression_type int4 NULL, + wf_description varchar(255) NULL, + wf_name varchar(255) NULL, + CONSTRAINT pj_workflow_info_pkey PRIMARY KEY (id) +); +CREATE INDEX idx01_workflow_info ON pj_workflow_info USING btree (app_id, status, time_expression_type, next_trigger_time); + + +-- pj_workflow_instance_info definition + +-- Drop table + +-- DROP TABLE pj_workflow_instance_info; + +CREATE TABLE pj_workflow_instance_info ( + id int8 NOT NULL, + actual_trigger_time int8 NULL, + app_id int8 NULL, + dag oid NULL, + expected_trigger_time int8 NULL, + finished_time int8 NULL, + gmt_create timestamp NULL, + gmt_modified timestamp NULL, + parent_wf_instance_id int8 NULL, + "result" oid NULL, + status int4 NULL, + wf_context oid NULL, + wf_init_params oid NULL, + wf_instance_id int8 NULL, + workflow_id int8 NULL, + CONSTRAINT pj_workflow_instance_info_pkey PRIMARY KEY (id), + CONSTRAINT uidx01_wf_instance UNIQUE (wf_instance_id) +); +CREATE INDEX idx01_wf_instance ON pj_workflow_instance_info USING btree (workflow_id, status, app_id, expected_trigger_time); + + +-- pj_workflow_node_info definition + +-- Drop table + +-- DROP TABLE pj_workflow_node_info; + +CREATE TABLE pj_workflow_node_info ( + id int8 NOT NULL, + app_id int8 NOT NULL, + "enable" bool NOT NULL, + extra oid NULL, + gmt_create timestamp NOT NULL, + gmt_modified timestamp NOT NULL, + job_id int8 NULL, + node_name varchar(255) NULL, + node_params oid NULL, + skip_when_failed bool NOT NULL, + "type" int4 NULL, + workflow_id int8 NULL, + CONSTRAINT pj_workflow_node_info_pkey PRIMARY KEY (id) +); +CREATE INDEX idx01_workflow_node_info ON pj_workflow_node_info USING btree (workflow_id, gmt_create); diff --git a/sql/powerjob_demo.sql b/sql/powerjob_demo.sql deleted file mode 100644 index eb816014..00000000 --- a/sql/powerjob_demo.sql +++ /dev/null @@ -1,5 +0,0 @@ -INSERT INTO `pj_app_info` (`id`, `app_name`, `current_server`, `gmt_create`, `gmt_modified`, `password`) VALUES (1, 'ruoyi-worker', '192.168.31.80:10010', '2023-06-13 16:32:59.263000', '2023-06-13 16:33:29.898000', '123456'); -INSERT INTO `pj_job_info` (`id`, `alarm_config`, `app_id`, `concurrency`, `designated_workers`, `dispatch_strategy`, `execute_type`, `extra`, `gmt_create`, `gmt_modified`, `instance_retry_num`, `instance_time_limit`, `job_description`, `job_name`, `job_params`, `lifecycle`, `log_config`, `max_instance_num`, `max_worker_count`, `min_cpu_cores`, `min_disk_space`, `min_memory_space`, `next_trigger_time`, `notify_user_ids`, `processor_info`, `processor_type`, `status`, `tag`, `task_retry_num`, `time_expression`, `time_expression_type`) VALUES (1, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 2, 1, NULL, '2023-06-02 15:01:27.717000', '2023-06-02 16:03:19.462000', 1, 0, '', '单机处理器执行测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.StandaloneProcessorDemo', 1, 1, NULL, 1, '30000', 3); -INSERT INTO `pj_job_info` (`id`, `alarm_config`, `app_id`, `concurrency`, `designated_workers`, `dispatch_strategy`, `execute_type`, `extra`, `gmt_create`, `gmt_modified`, `instance_retry_num`, `instance_time_limit`, `job_description`, `job_name`, `job_params`, `lifecycle`, `log_config`, `max_instance_num`, `max_worker_count`, `min_cpu_cores`, `min_disk_space`, `min_memory_space`, `next_trigger_time`, `notify_user_ids`, `processor_info`, `processor_type`, `status`, `tag`, `task_retry_num`, `time_expression`, `time_expression_type`) VALUES (2, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 2, NULL, '2023-06-02 15:04:45.342000', '2023-06-02 16:04:09.736000', 0, 0, NULL, '广播处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.BroadcastProcessorDemo', 1, 1, NULL, 1, '30000', 3); -INSERT INTO `pj_job_info` (`id`, `alarm_config`, `app_id`, `concurrency`, `designated_workers`, `dispatch_strategy`, `execute_type`, `extra`, `gmt_create`, `gmt_modified`, `instance_retry_num`, `instance_time_limit`, `job_description`, `job_name`, `job_params`, `lifecycle`, `log_config`, `max_instance_num`, `max_worker_count`, `min_cpu_cores`, `min_disk_space`, `min_memory_space`, `next_trigger_time`, `notify_user_ids`, `processor_info`, `processor_type`, `status`, `tag`, `task_retry_num`, `time_expression`, `time_expression_type`) VALUES (3, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 4, NULL, '2023-06-02 15:13:23.519000', '2023-06-02 16:03:22.421000', 0, 0, NULL, 'Map处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.MapProcessorDemo', 1, 2, NULL, 1, '1000', 3); -INSERT INTO `pj_job_info` (`id`, `alarm_config`, `app_id`, `concurrency`, `designated_workers`, `dispatch_strategy`, `execute_type`, `extra`, `gmt_create`, `gmt_modified`, `instance_retry_num`, `instance_time_limit`, `job_description`, `job_name`, `job_params`, `lifecycle`, `log_config`, `max_instance_num`, `max_worker_count`, `min_cpu_cores`, `min_disk_space`, `min_memory_space`, `next_trigger_time`, `notify_user_ids`, `processor_info`, `processor_type`, `status`, `tag`, `task_retry_num`, `time_expression`, `time_expression_type`) VALUES (4, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 3, NULL, '2023-06-02 15:45:25.896000', '2023-06-02 16:03:23.125000', 0, 0, NULL, 'MapReduce处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.MapReduceProcessorDemo', 1, 2, NULL, 1, '1000', 3); diff --git a/sql/ry-job.sql b/sql/ry-job.sql new file mode 100644 index 00000000..9381b881 --- /dev/null +++ b/sql/ry-job.sql @@ -0,0 +1,233 @@ +-- ---------------------------- +-- Table structure for pj_app_info +-- ---------------------------- +DROP TABLE IF EXISTS `pj_app_info`; +CREATE TABLE `pj_app_info` ( + `id` bigint(0) NOT NULL AUTO_INCREMENT, + `app_name` varchar(255) NULL DEFAULT NULL, + `current_server` varchar(255) NULL DEFAULT NULL, + `gmt_create` datetime(6) NULL DEFAULT NULL, + `gmt_modified` datetime(6) NULL DEFAULT NULL, + `password` varchar(255) NULL DEFAULT NULL, + PRIMARY KEY (`id`) USING BTREE, + UNIQUE INDEX `uidx01_app_info`(`app_name`) USING BTREE +) ENGINE = InnoDB AUTO_INCREMENT = 2 ROW_FORMAT = Dynamic; + +-- ---------------------------- +-- Records of pj_app_info +-- ---------------------------- +INSERT INTO `pj_app_info` VALUES (1, 'ruoyi-worker', '127.0.0.1:10010', '2023-06-13 16:32:59.263000', '2023-07-04 17:25:49.798000', '123456'); + +-- ---------------------------- +-- Table structure for pj_container_info +-- ---------------------------- +DROP TABLE IF EXISTS `pj_container_info`; +CREATE TABLE `pj_container_info` ( + `id` bigint(0) NOT NULL AUTO_INCREMENT, + `app_id` bigint(0) NULL DEFAULT NULL, + `container_name` varchar(255) NULL DEFAULT NULL, + `gmt_create` datetime(6) NULL DEFAULT NULL, + `gmt_modified` datetime(6) NULL DEFAULT NULL, + `last_deploy_time` datetime(6) NULL DEFAULT NULL, + `source_info` varchar(255) NULL DEFAULT NULL, + `source_type` int(0) NULL DEFAULT NULL, + `status` int(0) NULL DEFAULT NULL, + `version` varchar(255) NULL DEFAULT NULL, + PRIMARY KEY (`id`) USING BTREE, + INDEX `idx01_container_info`(`app_id`) USING BTREE +) ENGINE = InnoDB AUTO_INCREMENT = 1 ROW_FORMAT = Dynamic; + +-- ---------------------------- +-- Table structure for pj_instance_info +-- ---------------------------- +DROP TABLE IF EXISTS `pj_instance_info`; +CREATE TABLE `pj_instance_info` ( + `id` bigint(0) NOT NULL AUTO_INCREMENT, + `actual_trigger_time` bigint(0) NULL DEFAULT NULL, + `app_id` bigint(0) NULL DEFAULT NULL, + `expected_trigger_time` bigint(0) NULL DEFAULT NULL, + `finished_time` bigint(0) NULL DEFAULT NULL, + `gmt_create` datetime(6) NULL DEFAULT NULL, + `gmt_modified` datetime(6) NULL DEFAULT NULL, + `instance_id` bigint(0) NULL DEFAULT NULL, + `instance_params` longtext NULL, + `job_id` bigint(0) NULL DEFAULT NULL, + `job_params` longtext NULL, + `last_report_time` bigint(0) NULL DEFAULT NULL, + `result` longtext NULL, + `running_times` bigint(0) NULL DEFAULT NULL, + `status` int(0) NULL DEFAULT NULL, + `task_tracker_address` varchar(255) NULL DEFAULT NULL, + `type` int(0) NULL DEFAULT NULL, + `wf_instance_id` bigint(0) NULL DEFAULT NULL, + PRIMARY KEY (`id`) USING BTREE, + INDEX `idx01_instance_info`(`job_id`, `status`) USING BTREE, + INDEX `idx02_instance_info`(`app_id`, `status`) USING BTREE, + INDEX `idx03_instance_info`(`instance_id`, `status`) USING BTREE +) ENGINE = InnoDB AUTO_INCREMENT = 4 ROW_FORMAT = Dynamic; + +-- ---------------------------- +-- Table structure for pj_job_info +-- ---------------------------- +DROP TABLE IF EXISTS `pj_job_info`; +CREATE TABLE `pj_job_info` ( + `id` bigint(0) NOT NULL AUTO_INCREMENT, + `alarm_config` varchar(255) NULL DEFAULT NULL, + `app_id` bigint(0) NULL DEFAULT NULL, + `concurrency` int(0) NULL DEFAULT NULL, + `designated_workers` varchar(255) NULL DEFAULT NULL, + `dispatch_strategy` int(0) NULL DEFAULT NULL, + `execute_type` int(0) NULL DEFAULT NULL, + `extra` varchar(255) NULL DEFAULT NULL, + `gmt_create` datetime(6) NULL DEFAULT NULL, + `gmt_modified` datetime(6) NULL DEFAULT NULL, + `instance_retry_num` int(0) NULL DEFAULT NULL, + `instance_time_limit` bigint(0) NULL DEFAULT NULL, + `job_description` varchar(255) NULL DEFAULT NULL, + `job_name` varchar(255) NULL DEFAULT NULL, + `job_params` longtext NULL, + `lifecycle` varchar(255) NULL DEFAULT NULL, + `log_config` varchar(255) NULL DEFAULT NULL, + `max_instance_num` int(0) NULL DEFAULT NULL, + `max_worker_count` int(0) NULL DEFAULT NULL, + `min_cpu_cores` double NOT NULL, + `min_disk_space` double NOT NULL, + `min_memory_space` double NOT NULL, + `next_trigger_time` bigint(0) NULL DEFAULT NULL, + `notify_user_ids` varchar(255) NULL DEFAULT NULL, + `processor_info` varchar(255) NULL DEFAULT NULL, + `processor_type` int(0) NULL DEFAULT NULL, + `status` int(0) NULL DEFAULT NULL, + `tag` varchar(255) NULL DEFAULT NULL, + `task_retry_num` int(0) NULL DEFAULT NULL, + `time_expression` varchar(255) NULL DEFAULT NULL, + `time_expression_type` int(0) NULL DEFAULT NULL, + PRIMARY KEY (`id`) USING BTREE, + INDEX `idx01_job_info`(`app_id`, `status`, `time_expression_type`, `next_trigger_time`) USING BTREE +) ENGINE = InnoDB AUTO_INCREMENT = 5 ROW_FORMAT = Dynamic; + +-- ---------------------------- +-- Records of pj_job_info +-- ---------------------------- +INSERT INTO `pj_job_info` VALUES (1, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 2, 1, NULL, '2023-06-02 15:01:27.717000', '2023-07-04 17:22:12.374000', 1, 0, '', '单机处理器执行测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.StandaloneProcessorDemo', 1, 2, NULL, 1, '30000', 3); +INSERT INTO `pj_job_info` VALUES (2, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 2, NULL, '2023-06-02 15:04:45.342000', '2023-07-04 17:22:12.816000', 0, 0, NULL, '广播处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.BroadcastProcessorDemo', 1, 2, NULL, 1, '30000', 3); +INSERT INTO `pj_job_info` VALUES (3, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 4, NULL, '2023-06-02 15:13:23.519000', '2023-06-02 16:03:22.421000', 0, 0, NULL, 'Map处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.MapProcessorDemo', 1, 2, NULL, 1, '1000', 3); +INSERT INTO `pj_job_info` VALUES (4, '{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', 1, 5, '', 1, 3, NULL, '2023-06-02 15:45:25.896000', '2023-06-02 16:03:23.125000', 0, 0, NULL, 'MapReduce处理器测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'org.dromara.job.processors.MapReduceProcessorDemo', 1, 2, NULL, 1, '1000', 3); + +-- ---------------------------- +-- Table structure for pj_oms_lock +-- ---------------------------- +DROP TABLE IF EXISTS `pj_oms_lock`; +CREATE TABLE `pj_oms_lock` ( + `id` bigint(0) NOT NULL AUTO_INCREMENT, + `gmt_create` datetime(6) NULL DEFAULT NULL, + `gmt_modified` datetime(6) NULL DEFAULT NULL, + `lock_name` varchar(255) NULL DEFAULT NULL, + `max_lock_time` bigint(0) NULL DEFAULT NULL, + `ownerip` varchar(255) NULL DEFAULT NULL, + PRIMARY KEY (`id`) USING BTREE, + UNIQUE INDEX `uidx01_oms_lock`(`lock_name`) USING BTREE +) ENGINE = InnoDB AUTO_INCREMENT = 6 ROW_FORMAT = Dynamic; + +-- ---------------------------- +-- Table structure for pj_server_info +-- ---------------------------- +DROP TABLE IF EXISTS `pj_server_info`; +CREATE TABLE `pj_server_info` ( + `id` bigint(0) NOT NULL AUTO_INCREMENT, + `gmt_create` datetime(6) NULL DEFAULT NULL, + `gmt_modified` datetime(6) NULL DEFAULT NULL, + `ip` varchar(255) NULL DEFAULT NULL, + PRIMARY KEY (`id`) USING BTREE, + UNIQUE INDEX `uidx01_server_info`(`ip`) USING BTREE, + INDEX `idx01_server_info`(`gmt_modified`) USING BTREE +) ENGINE = InnoDB AUTO_INCREMENT = 2 ROW_FORMAT = Dynamic; + +-- ---------------------------- +-- Table structure for pj_user_info +-- ---------------------------- +DROP TABLE IF EXISTS `pj_user_info`; +CREATE TABLE `pj_user_info` ( + `id` bigint(0) NOT NULL AUTO_INCREMENT, + `email` varchar(255) NULL DEFAULT NULL, + `extra` varchar(255) NULL DEFAULT NULL, + `gmt_create` datetime(6) NULL DEFAULT NULL, + `gmt_modified` datetime(6) NULL DEFAULT NULL, + `password` varchar(255) NULL DEFAULT NULL, + `phone` varchar(255) NULL DEFAULT NULL, + `username` varchar(255) NULL DEFAULT NULL, + `web_hook` varchar(255) NULL DEFAULT NULL, + PRIMARY KEY (`id`) USING BTREE, + INDEX `uidx01_user_info`(`username`) USING BTREE, + INDEX `uidx02_user_info`(`email`) USING BTREE +) ENGINE = InnoDB AUTO_INCREMENT = 1 ROW_FORMAT = Dynamic; + +-- ---------------------------- +-- Table structure for pj_workflow_info +-- ---------------------------- +DROP TABLE IF EXISTS `pj_workflow_info`; +CREATE TABLE `pj_workflow_info` ( + `id` bigint(0) NOT NULL AUTO_INCREMENT, + `app_id` bigint(0) NULL DEFAULT NULL, + `extra` varchar(255) NULL DEFAULT NULL, + `gmt_create` datetime(6) NULL DEFAULT NULL, + `gmt_modified` datetime(6) NULL DEFAULT NULL, + `lifecycle` varchar(255) NULL DEFAULT NULL, + `max_wf_instance_num` int(0) NULL DEFAULT NULL, + `next_trigger_time` bigint(0) NULL DEFAULT NULL, + `notify_user_ids` varchar(255) NULL DEFAULT NULL, + `pedag` longtext NULL, + `status` int(0) NULL DEFAULT NULL, + `time_expression` varchar(255) NULL DEFAULT NULL, + `time_expression_type` int(0) NULL DEFAULT NULL, + `wf_description` varchar(255) NULL DEFAULT NULL, + `wf_name` varchar(255) NULL DEFAULT NULL, + PRIMARY KEY (`id`) USING BTREE, + INDEX `idx01_workflow_info`(`app_id`, `status`, `time_expression_type`, `next_trigger_time`) USING BTREE +) ENGINE = InnoDB AUTO_INCREMENT = 1 ROW_FORMAT = Dynamic; + +-- ---------------------------- +-- Table structure for pj_workflow_instance_info +-- ---------------------------- +DROP TABLE IF EXISTS `pj_workflow_instance_info`; +CREATE TABLE `pj_workflow_instance_info` ( + `id` bigint(0) NOT NULL AUTO_INCREMENT, + `actual_trigger_time` bigint(0) NULL DEFAULT NULL, + `app_id` bigint(0) NULL DEFAULT NULL, + `dag` longtext NULL, + `expected_trigger_time` bigint(0) NULL DEFAULT NULL, + `finished_time` bigint(0) NULL DEFAULT NULL, + `gmt_create` datetime(6) NULL DEFAULT NULL, + `gmt_modified` datetime(6) NULL DEFAULT NULL, + `parent_wf_instance_id` bigint(0) NULL DEFAULT NULL, + `result` longtext NULL, + `status` int(0) NULL DEFAULT NULL, + `wf_context` longtext NULL, + `wf_init_params` longtext NULL, + `wf_instance_id` bigint(0) NULL DEFAULT NULL, + `workflow_id` bigint(0) NULL DEFAULT NULL, + PRIMARY KEY (`id`) USING BTREE, + UNIQUE INDEX `uidx01_wf_instance`(`wf_instance_id`) USING BTREE, + INDEX `idx01_wf_instance`(`workflow_id`, `status`, `app_id`, `expected_trigger_time`) USING BTREE +) ENGINE = InnoDB AUTO_INCREMENT = 1 ROW_FORMAT = Dynamic; + +-- ---------------------------- +-- Table structure for pj_workflow_node_info +-- ---------------------------- +DROP TABLE IF EXISTS `pj_workflow_node_info`; +CREATE TABLE `pj_workflow_node_info` ( + `id` bigint(0) NOT NULL AUTO_INCREMENT, + `app_id` bigint(0) NOT NULL, + `enable` bit(1) NOT NULL, + `extra` longtext NULL, + `gmt_create` datetime(6) NULL, + `gmt_modified` datetime(6) NULL, + `job_id` bigint(0) NULL DEFAULT NULL, + `node_name` varchar(255) NULL DEFAULT NULL, + `node_params` longtext NULL, + `skip_when_failed` bit(1) NOT NULL, + `type` int(0) NULL DEFAULT NULL, + `workflow_id` bigint(0) NULL DEFAULT NULL, + PRIMARY KEY (`id`) USING BTREE, + INDEX `idx01_workflow_node_info`(`workflow_id`, `gmt_create`) USING BTREE +) ENGINE = InnoDB AUTO_INCREMENT = 1 ROW_FORMAT = Dynamic;