Browse Source

update 优化 提供powerjob完整sql脚本 降低用户使用难度

疯狂的狮子Li 1 năm trước cách đây
mục cha
commit
53bad85b00

+ 694 - 0
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;

+ 258 - 0
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);

+ 233 - 0
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;

+ 0 - 5
script/sql/powerjob_demo.sql

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

+ 517 - 0
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
+