From 53bad85b006eebdc3625e0efc6e8ba84075706fe 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:46:49 +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 --- script/sql/oracle/powerjob.sql | 694 ++++++++++++++++++++++++++++++ script/sql/postgres/powerjob.sql | 258 +++++++++++ script/sql/powerjob.sql | 233 ++++++++++ script/sql/powerjob_demo.sql | 5 - script/sql/sqlserver/powerjob.sql | 517 ++++++++++++++++++++++ 5 files changed, 1702 insertions(+), 5 deletions(-) create mode 100644 script/sql/oracle/powerjob.sql create mode 100644 script/sql/postgres/powerjob.sql create mode 100644 script/sql/powerjob.sql delete mode 100644 script/sql/powerjob_demo.sql create mode 100644 script/sql/sqlserver/powerjob.sql diff --git a/script/sql/oracle/powerjob.sql b/script/sql/oracle/powerjob.sql new file mode 100644 index 000000000..83ebd410f --- /dev/null +++ b/script/sql/oracle/powerjob.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/script/sql/postgres/powerjob.sql b/script/sql/postgres/powerjob.sql new file mode 100644 index 000000000..0e2265d3f --- /dev/null +++ b/script/sql/postgres/powerjob.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/script/sql/powerjob.sql b/script/sql/powerjob.sql new file mode 100644 index 000000000..9381b881c --- /dev/null +++ b/script/sql/powerjob.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; diff --git a/script/sql/powerjob_demo.sql b/script/sql/powerjob_demo.sql deleted file mode 100644 index eb8160149..000000000 --- a/script/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/script/sql/sqlserver/powerjob.sql b/script/sql/sqlserver/powerjob.sql new file mode 100644 index 000000000..9233866ad --- /dev/null +++ b/script/sql/sqlserver/powerjob.sql @@ -0,0 +1,517 @@ +-- ---------------------------- +-- Table structure for pj_app_info +-- ---------------------------- + +CREATE TABLE [pj_app_info] ( + [id] bigint IDENTITY(1,1) NOT NULL, + [app_name] varchar(255) NULL, + [current_server] varchar(255) NULL, + [gmt_create] datetime2(7) NULL, + [gmt_modified] datetime2(7) NULL, + [password] varchar(255) NULL +) +GO + +ALTER TABLE [pj_app_info] SET (LOCK_ESCALATION = TABLE) +GO + + +-- ---------------------------- +-- Records of [pj_app_info] +-- ---------------------------- +SET IDENTITY_INSERT [pj_app_info] ON +GO + +INSERT INTO [pj_app_info] ([id], [app_name], [current_server], [gmt_create], [gmt_modified], [password]) VALUES (N'1', N'ruoyi-worker', N'192.168.31.100:10010', N'2023-06-13 16:32:59.2630000', N'2023-07-04 17:25:49.7980000', N'123456') +GO + +SET IDENTITY_INSERT [pj_app_info] OFF +GO + + +-- ---------------------------- +-- Table structure for pj_container_info +-- ---------------------------- + +CREATE TABLE [pj_container_info] ( + [id] bigint IDENTITY(1,1) NOT NULL, + [app_id] bigint NULL, + [container_name] varchar(255) NULL, + [gmt_create] datetime2(7) NULL, + [gmt_modified] datetime2(7) NULL, + [last_deploy_time] datetime2(7) NULL, + [source_info] varchar(255) NULL, + [source_type] int NULL, + [status] int NULL, + [version] varchar(255) NULL +) +GO + +ALTER TABLE [pj_container_info] SET (LOCK_ESCALATION = TABLE) +GO + + +-- ---------------------------- +-- Table structure for pj_instance_info +-- ---------------------------- + +CREATE TABLE [pj_instance_info] ( + [id] bigint IDENTITY(1,1) NOT NULL, + [actual_trigger_time] bigint NULL, + [app_id] bigint NULL, + [expected_trigger_time] bigint NULL, + [finished_time] bigint NULL, + [gmt_create] datetime2(7) NULL, + [gmt_modified] datetime2(7) NULL, + [instance_id] bigint NULL, + [instance_params] varchar(max) NULL, + [job_id] bigint NULL, + [job_params] varchar(max) NULL, + [last_report_time] bigint NULL, + [result] varchar(max) NULL, + [running_times] bigint NULL, + [status] int NULL, + [task_tracker_address] varchar(255) NULL, + [type] int NULL, + [wf_instance_id] bigint NULL +) +GO + +ALTER TABLE [pj_instance_info] SET (LOCK_ESCALATION = TABLE) +GO + + +-- ---------------------------- +-- Table structure for pj_job_info +-- ---------------------------- + +CREATE TABLE [pj_job_info] ( + [id] bigint IDENTITY(1,1) NOT NULL, + [alarm_config] varchar(255) NULL, + [app_id] bigint NULL, + [concurrency] int NULL, + [designated_workers] varchar(255) NULL, + [dispatch_strategy] int NULL, + [execute_type] int NULL, + [extra] varchar(255) NULL, + [gmt_create] datetime2(7) NULL, + [gmt_modified] datetime2(7) NULL, + [instance_retry_num] int NULL, + [instance_time_limit] bigint NULL, + [job_description] varchar(255) NULL, + [job_name] varchar(255) NULL, + [job_params] varchar(max) NULL, + [lifecycle] varchar(255) NULL, + [log_config] varchar(255) NULL, + [max_instance_num] int NULL, + [max_worker_count] int NULL, + [min_cpu_cores] float(53) NOT NULL, + [min_disk_space] float(53) NOT NULL, + [min_memory_space] float(53) NOT NULL, + [next_trigger_time] bigint NULL, + [notify_user_ids] varchar(255) NULL, + [processor_info] varchar(255) NULL, + [processor_type] int NULL, + [status] int NULL, + [tag] varchar(255) NULL, + [task_retry_num] int NULL, + [time_expression] varchar(255) NULL, + [time_expression_type] int NULL +) +GO + +ALTER TABLE [pj_job_info] SET (LOCK_ESCALATION = TABLE) +GO + + +-- ---------------------------- +-- Records of [pj_job_info] +-- ---------------------------- +SET IDENTITY_INSERT [pj_job_info] ON +GO + +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 (N'1', N'{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', N'1', N'5', N'', N'2', N'1', NULL, N'2023-06-02 15:01:27.7170000', N'2023-07-04 17:22:12.3740000', N'1', N'0', N'', N'?????????', NULL, N'{}', N'{\"type\":1}', N'0', N'0', N'0.000000000000000', N'0.000000000000000', N'0.000000000000000', NULL, NULL, N'org.dromara.job.processors.StandaloneProcessorDemo', N'1', N'2', NULL, N'1', N'30000', N'3') +GO + +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 (N'2', N'{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', N'1', N'5', N'', N'1', N'2', NULL, N'2023-06-02 15:04:45.3420000', N'2023-07-04 17:22:12.8160000', N'0', N'0', NULL, N'???????', NULL, N'{}', N'{\"type\":1}', N'0', N'0', N'0.000000000000000', N'0.000000000000000', N'0.000000000000000', NULL, NULL, N'org.dromara.job.processors.BroadcastProcessorDemo', N'1', N'2', NULL, N'1', N'30000', N'3') +GO + +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 (N'3', N'{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', N'1', N'5', N'', N'1', N'4', NULL, N'2023-06-02 15:13:23.5190000', N'2023-06-02 16:03:22.4210000', N'0', N'0', NULL, N'Map?????', NULL, N'{}', N'{\"type\":1}', N'0', N'0', N'0.000000000000000', N'0.000000000000000', N'0.000000000000000', NULL, NULL, N'org.dromara.job.processors.MapProcessorDemo', N'1', N'2', NULL, N'1', N'1000', N'3') +GO + +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 (N'4', N'{\"alertThreshold\":0,\"silenceWindowLen\":0,\"statisticWindowLen\":0}', N'1', N'5', N'', N'1', N'3', NULL, N'2023-06-02 15:45:25.8960000', N'2023-06-02 16:03:23.1250000', N'0', N'0', NULL, N'MapReduce?????', NULL, N'{}', N'{\"type\":1}', N'0', N'0', N'0.000000000000000', N'0.000000000000000', N'0.000000000000000', NULL, NULL, N'org.dromara.job.processors.MapReduceProcessorDemo', N'1', N'2', NULL, N'1', N'1000', N'3') +GO + +SET IDENTITY_INSERT [pj_job_info] OFF +GO + + +-- ---------------------------- +-- Table structure for pj_oms_lock +-- ---------------------------- + +CREATE TABLE [pj_oms_lock] ( + [id] bigint IDENTITY(1,1) NOT NULL, + [gmt_create] datetime2(7) NULL, + [gmt_modified] datetime2(7) NULL, + [lock_name] varchar(255) NULL, + [max_lock_time] bigint NULL, + [ownerip] varchar(255) NULL +) +GO + +ALTER TABLE [pj_oms_lock] SET (LOCK_ESCALATION = TABLE) +GO + + +-- ---------------------------- +-- Table structure for pj_server_info +-- ---------------------------- + +CREATE TABLE [pj_server_info] ( + [id] bigint IDENTITY(1,1) NOT NULL, + [gmt_create] datetime2(7) NULL, + [gmt_modified] datetime2(7) NULL, + [ip] varchar(255) NULL +) +GO + +ALTER TABLE [pj_server_info] SET (LOCK_ESCALATION = TABLE) +GO + + +-- ---------------------------- +-- Table structure for pj_user_info +-- ---------------------------- + +CREATE TABLE [pj_user_info] ( + [id] bigint IDENTITY(1,1) NOT NULL, + [email] varchar(255) NULL, + [extra] varchar(255) NULL, + [gmt_create] datetime2(7) NULL, + [gmt_modified] datetime2(7) NULL, + [password] varchar(255) NULL, + [phone] varchar(255) NULL, + [username] varchar(255) NULL, + [web_hook] varchar(255) NULL +) +GO + +ALTER TABLE [pj_user_info] SET (LOCK_ESCALATION = TABLE) +GO + + +-- ---------------------------- +-- Table structure for pj_workflow_info +-- ---------------------------- + +CREATE TABLE [pj_workflow_info] ( + [id] bigint IDENTITY(1,1) NOT NULL, + [app_id] bigint NULL, + [extra] varchar(255) NULL, + [gmt_create] datetime2(7) NULL, + [gmt_modified] datetime2(7) NULL, + [lifecycle] varchar(255) NULL, + [max_wf_instance_num] int NULL, + [next_trigger_time] bigint NULL, + [notify_user_ids] varchar(255) NULL, + [pedag] varchar(max) NULL, + [status] int NULL, + [time_expression] varchar(255) NULL, + [time_expression_type] int NULL, + [wf_description] varchar(255) NULL, + [wf_name] varchar(255) NULL +) +GO + +ALTER TABLE [pj_workflow_info] SET (LOCK_ESCALATION = TABLE) +GO + + +-- ---------------------------- +-- Table structure for pj_workflow_instance_info +-- ---------------------------- + +CREATE TABLE [pj_workflow_instance_info] ( + [id] bigint IDENTITY(1,1) NOT NULL, + [actual_trigger_time] bigint NULL, + [app_id] bigint NULL, + [dag] varchar(max) NULL, + [expected_trigger_time] bigint NULL, + [finished_time] bigint NULL, + [gmt_create] datetime2(7) NULL, + [gmt_modified] datetime2(7) NULL, + [parent_wf_instance_id] bigint NULL, + [result] varchar(max) NULL, + [status] int NULL, + [wf_context] varchar(max) NULL, + [wf_init_params] varchar(max) NULL, + [wf_instance_id] bigint NULL, + [workflow_id] bigint NULL +) +GO + +ALTER TABLE [pj_workflow_instance_info] SET (LOCK_ESCALATION = TABLE) +GO + + +-- ---------------------------- +-- Table structure for pj_workflow_node_info +-- ---------------------------- + +CREATE TABLE [pj_workflow_node_info] ( + [id] bigint IDENTITY(1,1) NOT NULL, + [app_id] bigint NOT NULL, + [enable] bit NOT NULL, + [extra] varchar(max) NULL, + [gmt_create] datetime2(7) NOT NULL, + [gmt_modified] datetime2(7) NOT NULL, + [job_id] bigint NULL, + [node_name] varchar(255) NULL, + [node_params] varchar(max) NULL, + [skip_when_failed] bit NOT NULL, + [type] int NULL, + [workflow_id] bigint NULL +) +GO + +ALTER TABLE [pj_workflow_node_info] SET (LOCK_ESCALATION = TABLE) +GO + + +-- ---------------------------- +-- Uniques structure for table pj_app_info +-- ---------------------------- +ALTER TABLE [pj_app_info] ADD CONSTRAINT [uidx01_app_info] UNIQUE NONCLUSTERED ([app_name] ASC) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Primary Key structure for table pj_app_info +-- ---------------------------- +ALTER TABLE [pj_app_info] ADD CONSTRAINT [PK__pj_app_i__3213E83FDD7E2005] PRIMARY KEY CLUSTERED ([id]) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Indexes structure for table pj_container_info +-- ---------------------------- +CREATE NONCLUSTERED INDEX [idx01_container_info] +ON [pj_container_info] ( + [app_id] ASC +) +GO + + +-- ---------------------------- +-- Primary Key structure for table pj_container_info +-- ---------------------------- +ALTER TABLE [pj_container_info] ADD CONSTRAINT [PK__pj_conta__3213E83FE1AAA8BE] PRIMARY KEY CLUSTERED ([id]) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Indexes structure for table pj_instance_info +-- ---------------------------- +CREATE NONCLUSTERED INDEX [idx01_instance_info] +ON [pj_instance_info] ( + [job_id] ASC, + [status] ASC +) +GO + +CREATE NONCLUSTERED INDEX [idx02_instance_info] +ON [pj_instance_info] ( + [app_id] ASC, + [status] ASC +) +GO + +CREATE NONCLUSTERED INDEX [idx03_instance_info] +ON [pj_instance_info] ( + [instance_id] ASC, + [status] ASC +) +GO + + +-- ---------------------------- +-- Primary Key structure for table pj_instance_info +-- ---------------------------- +ALTER TABLE [pj_instance_info] ADD CONSTRAINT [PK__pj_insta__3213E83F6F188642] PRIMARY KEY CLUSTERED ([id]) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Indexes structure for table pj_job_info +-- ---------------------------- +CREATE NONCLUSTERED INDEX [idx01_job_info] +ON [pj_job_info] ( + [app_id] ASC, + [status] ASC, + [time_expression_type] ASC, + [next_trigger_time] ASC +) +GO + + +-- ---------------------------- +-- Primary Key structure for table pj_job_info +-- ---------------------------- +ALTER TABLE [pj_job_info] ADD CONSTRAINT [PK__pj_job_i__3213E83FBFBCD483] PRIMARY KEY CLUSTERED ([id]) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Uniques structure for table pj_oms_lock +-- ---------------------------- +ALTER TABLE [pj_oms_lock] ADD CONSTRAINT [uidx01_oms_lock] UNIQUE NONCLUSTERED ([lock_name] ASC) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Primary Key structure for table pj_oms_lock +-- ---------------------------- +ALTER TABLE [pj_oms_lock] ADD CONSTRAINT [PK__pj_oms_l__3213E83F31F31A08] PRIMARY KEY CLUSTERED ([id]) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Indexes structure for table pj_server_info +-- ---------------------------- +CREATE NONCLUSTERED INDEX [idx01_server_info] +ON [pj_server_info] ( + [gmt_modified] ASC +) +GO + + +-- ---------------------------- +-- Uniques structure for table pj_server_info +-- ---------------------------- +ALTER TABLE [pj_server_info] ADD CONSTRAINT [uidx01_server_info] UNIQUE NONCLUSTERED ([ip] ASC) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Primary Key structure for table pj_server_info +-- ---------------------------- +ALTER TABLE [pj_server_info] ADD CONSTRAINT [PK__pj_serve__3213E83F75246E89] PRIMARY KEY CLUSTERED ([id]) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Indexes structure for table pj_user_info +-- ---------------------------- +CREATE NONCLUSTERED INDEX [uidx01_user_info] +ON [pj_user_info] ( + [username] ASC +) +GO + +CREATE NONCLUSTERED INDEX [uidx02_user_info] +ON [pj_user_info] ( + [email] ASC +) +GO + + +-- ---------------------------- +-- Primary Key structure for table pj_user_info +-- ---------------------------- +ALTER TABLE [pj_user_info] ADD CONSTRAINT [PK__pj_user___3213E83FB78DE8FD] PRIMARY KEY CLUSTERED ([id]) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Indexes structure for table pj_workflow_info +-- ---------------------------- +CREATE NONCLUSTERED INDEX [idx01_workflow_info] +ON [pj_workflow_info] ( + [app_id] ASC, + [status] ASC, + [time_expression_type] ASC, + [next_trigger_time] ASC +) +GO + + +-- ---------------------------- +-- Primary Key structure for table pj_workflow_info +-- ---------------------------- +ALTER TABLE [pj_workflow_info] ADD CONSTRAINT [PK__pj_workf__3213E83F790DC98A] PRIMARY KEY CLUSTERED ([id]) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Indexes structure for table pj_workflow_instance_info +-- ---------------------------- +CREATE NONCLUSTERED INDEX [idx01_wf_instance] +ON [pj_workflow_instance_info] ( + [workflow_id] ASC, + [status] ASC, + [app_id] ASC, + [expected_trigger_time] ASC +) +GO + + +-- ---------------------------- +-- Uniques structure for table pj_workflow_instance_info +-- ---------------------------- +ALTER TABLE [pj_workflow_instance_info] ADD CONSTRAINT [uidx01_wf_instance] UNIQUE NONCLUSTERED ([wf_instance_id] ASC) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Primary Key structure for table pj_workflow_instance_info +-- ---------------------------- +ALTER TABLE [pj_workflow_instance_info] ADD CONSTRAINT [PK__pj_workf__3213E83F5AF8A72D] PRIMARY KEY CLUSTERED ([id]) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO + + +-- ---------------------------- +-- Indexes structure for table pj_workflow_node_info +-- ---------------------------- +CREATE NONCLUSTERED INDEX [idx01_workflow_node_info] +ON [pj_workflow_node_info] ( + [workflow_id] ASC, + [gmt_create] ASC +) +GO + + +-- ---------------------------- +-- Primary Key structure for table pj_workflow_node_info +-- ---------------------------- +ALTER TABLE [pj_workflow_node_info] ADD CONSTRAINT [PK__pj_workf__3213E83FD000EE6D] PRIMARY KEY CLUSTERED ([id]) +WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) +ON [PRIMARY] +GO +