chore: Main version upgraded to 4.3.9

others/powerjob-mysql.sql

@@ -1,3 +1,22 @@
+/*
+ 官方 SQL 仅基于特定版本（MySQL8）导出，不一定兼容其他数据库，也不一定兼容其他版本。此 SQL 仅供参考。
+ 如果您的数据库无法使用此 SQL，建议使用 SpringDataJPA 自带的建表能力，先在开发环境直连测试库自动建表，然后自行导出相关的 SQL 即可
+
+ Navicat Premium Data Transfer
+
+ Source Server         : Local@3306
+ Source Server Type    : MySQL
+ Source Server Version : 80300 (8.3.0)
+ Source Host           : localhost:3306
+ Source Schema         : powerjob4
+
+ Target Server Type    : MySQL
+ Target Server Version : 80300 (8.3.0)
+ File Encoding         : 65001
+
+ Date: 02/03/2024 18:51:36
+*/
+
 SET NAMES utf8mb4;
 SET FOREIGN_KEY_CHECKS = 0;
 
@@ -5,260 +24,224 @@ SET FOREIGN_KEY_CHECKS = 0;
 -- Table structure for app_info
 -- ----------------------------
 DROP TABLE IF EXISTS `app_info`;
-CREATE TABLE `app_info`
+CREATE TABLE `app_info` (
-(
+                            `id` bigint NOT NULL AUTO_INCREMENT,
-    `id`             bigint       NOT NULL AUTO_INCREMENT COMMENT '应用ID',
+                            `app_name` varchar(255) DEFAULT NULL,
-    `app_name`       varchar(128) not NULL COMMENT '应用名称',
+                            `current_server` varchar(255) DEFAULT NULL,
-    `current_server` varchar(255) default null COMMENT 'Server地址,用于负责调度应用的ActorSystem地址',
+                            `gmt_create` datetime(6) DEFAULT NULL,
-    `gmt_create`     datetime     not null COMMENT '创建时间',
+                            `gmt_modified` datetime(6) DEFAULT NULL,
-    `gmt_modified`   datetime     not null COMMENT '更新时间',
+                            `password` varchar(255) DEFAULT NULL,
-    `password`       varchar(255) not null COMMENT '应用密码',
+                            PRIMARY KEY (`id`),
-    PRIMARY KEY (`id`),
+                            UNIQUE KEY `uidx01_app_info` (`app_name`)
-    UNIQUE KEY `uidx01_app_info` (`app_name`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-) ENGINE = InnoDB
-  AUTO_INCREMENT = 1
-  DEFAULT CHARSET = utf8mb4
-  COLLATE = utf8mb4_general_ci COMMENT ='应用表';
 
 -- ----------------------------
 -- Table structure for container_info
 -- ----------------------------
-
 DROP TABLE IF EXISTS `container_info`;
-CREATE TABLE `container_info`
+CREATE TABLE `container_info` (
-(
+                                  `id` bigint NOT NULL AUTO_INCREMENT,
-    `id`               bigint       NOT NULL AUTO_INCREMENT COMMENT '容器ID',
+                                  `app_id` bigint DEFAULT NULL,
-    `app_id`           bigint       not null COMMENT '应用ID',
+                                  `container_name` varchar(255) DEFAULT NULL,
-    `container_name`   varchar(128) not null COMMENT '容器名称',
+                                  `gmt_create` datetime(6) DEFAULT NULL,
-    `gmt_create`       datetime     not null COMMENT '创建时间',
+                                  `gmt_modified` datetime(6) DEFAULT NULL,
-    `gmt_modified`     datetime     not null COMMENT '更新时间',
+                                  `last_deploy_time` datetime(6) DEFAULT NULL,
-    `last_deploy_time` datetime     DEFAULT NULL COMMENT '上次部署时间',
+                                  `source_info` varchar(255) DEFAULT NULL,
-    `source_info`      varchar(255) DEFAULT NULL COMMENT '资源信息,内容取决于source_type\n1、FatJar -> String\n2、Git -> JSON，{"repo”:””仓库,”branch”:”分支”,”username”:”账号,”password”:”密码”}',
+                                  `source_type` int DEFAULT NULL,
-    `source_type`      int          not null COMMENT '资源类型,1:FatJar/2:Git',
+                                  `status` int DEFAULT NULL,
-    `status`           int          not null COMMENT '状态,1:正常ENABLE/2:已禁用DISABLE/99:已删除DELETED',
+                                  `version` varchar(255) DEFAULT NULL,
-    `version`          varchar(255) default null COMMENT '版本',
+                                  PRIMARY KEY (`id`),
-    PRIMARY KEY (`id`),
+                                  KEY `idx01_container_info` (`app_id`)
-    KEY `idx01_container_info` (`app_id`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-) ENGINE = InnoDB
-  DEFAULT CHARSET = utf8mb4
-  COLLATE = utf8mb4_general_ci COMMENT ='容器表';
 
 -- ----------------------------
 -- Table structure for instance_info
 -- ----------------------------
 DROP TABLE IF EXISTS `instance_info`;
-CREATE TABLE `instance_info`
+CREATE TABLE `instance_info` (
-(
+                                 `id` bigint NOT NULL AUTO_INCREMENT,
-    `id`                    bigint   NOT NULL AUTO_INCREMENT COMMENT '任务实例ID',
+                                 `actual_trigger_time` bigint DEFAULT NULL,
-    `app_id`                bigint   not null COMMENT '应用ID',
+                                 `app_id` bigint DEFAULT NULL,
-    `instance_id`           bigint   not null COMMENT '任务实例ID',
+                                 `expected_trigger_time` bigint DEFAULT NULL,
-    `type`                  int      not NULL COMMENT '任务实例类型,1:普通NORMAL/2:工作流WORKFLOW',
+                                 `finished_time` bigint DEFAULT NULL,
-    `job_id`                bigint   not NULL COMMENT '任务ID',
+                                 `gmt_create` datetime(6) DEFAULT NULL,
-    `instance_params`       longtext COMMENT '任务动态参数',
+                                 `gmt_modified` datetime(6) DEFAULT NULL,
-    `job_params`            longtext COMMENT '任务静态参数',
+                                 `instance_id` bigint DEFAULT NULL,
-    `actual_trigger_time`   bigint       default NULL COMMENT '实际触发时间',
+                                 `instance_params` longtext,
-    `expected_trigger_time` bigint       DEFAULT NULL COMMENT '计划触发时间',
+                                 `job_id` bigint DEFAULT NULL,
-    `finished_time`         bigint       DEFAULT NULL COMMENT '执行结束时间',
+                                 `job_params` longtext,
-    `last_report_time`      bigint       DEFAULT NULL COMMENT '最后上报时间',
+                                 `last_report_time` bigint DEFAULT NULL,
-    `result`                longtext COMMENT '执行结果',
+                                 `result` longtext,
-    `running_times`         bigint       DEFAULT NULL COMMENT '总执行次数,用于重试判断',
+                                 `running_times` bigint DEFAULT NULL,
-    `status`                int      not NULL COMMENT '任务状态,1:等待派发WAITING_DISPATCH/2:等待Worker接收WAITING_WORKER_RECEIVE/3:运行中RUNNING/4:失败FAILED/5:成功SUCCEED/9:取消CANCELED/10:手动停止STOPPED',
+                                 `status` int DEFAULT NULL,
-    `task_tracker_address`  varchar(255) DEFAULT NULL COMMENT 'TaskTracker地址',
+                                 `task_tracker_address` varchar(255) DEFAULT NULL,
-    `wf_instance_id`        bigint       DEFAULT NULL COMMENT '工作流实例ID',
+                                 `type` int DEFAULT NULL,
-    `additional_data`       longtext comment '附加信息 (JSON)',
+                                 `wf_instance_id` bigint DEFAULT NULL,
-    `gmt_create`            datetime not NULL COMMENT '创建时间',
+                                 PRIMARY KEY (`id`),
-    `gmt_modified`          datetime not NULL COMMENT '更新时间',
+                                 KEY `idx01_instance_info` (`job_id`,`status`),
-    PRIMARY KEY (`id`),
+                                 KEY `idx02_instance_info` (`app_id`,`status`),
-    KEY `idx01_instance_info` (`job_id`, `status`),
+                                 KEY `idx03_instance_info` (`instance_id`,`status`)
-    KEY `idx02_instance_info` (`app_id`, `status`),
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-    KEY `idx03_instance_info` (`instance_id`, `status`)
-) ENGINE = InnoDB
-  AUTO_INCREMENT = 1
-  DEFAULT CHARSET = utf8mb4
-  COLLATE = utf8mb4_general_ci COMMENT ='任务实例表';
 
 -- ----------------------------
 -- Table structure for job_info
 -- ----------------------------
 DROP TABLE IF EXISTS `job_info`;
-CREATE TABLE `job_info`
+CREATE TABLE `job_info` (
-(
+                            `id` bigint NOT NULL AUTO_INCREMENT,
-    `id`                   bigint   NOT NULL AUTO_INCREMENT,
+                            `advanced_runtime_config` varchar(255) DEFAULT NULL,
-    `app_id`               bigint            DEFAULT NULL COMMENT '应用ID',
+                            `alarm_config` varchar(255) DEFAULT NULL,
-    `job_name`             varchar(128)      DEFAULT NULL COMMENT '任务名称',
+                            `app_id` bigint DEFAULT NULL,
-    `job_description`      varchar(255)      DEFAULT NULL COMMENT '任务描述',
+                            `concurrency` int DEFAULT NULL,
-    `job_params`           text COMMENT '任务默认参数',
+                            `designated_workers` varchar(255) DEFAULT NULL,
-    `concurrency`          int               DEFAULT NULL COMMENT '并发度,同时执行某个任务的最大线程数量',
+                            `dispatch_strategy` int DEFAULT NULL,
-    `designated_workers`   varchar(255)      DEFAULT NULL COMMENT '运行节点,空:不限(多值逗号分割)',
+                            `dispatch_strategy_config` varchar(255) DEFAULT NULL,
-    `dispatch_strategy`    int               DEFAULT NULL COMMENT '投递策略,1:健康优先/2:随机',
+                            `execute_type` int DEFAULT NULL,
-    `execute_type`         int      not NULL COMMENT '执行类型,1:单机STANDALONE/2:广播BROADCAST/3:MAP_REDUCE/4:MAP',
+                            `extra` varchar(255) DEFAULT NULL,
-    `instance_retry_num`   int      not null DEFAULT 0 COMMENT 'Instance重试次数',
+                            `gmt_create` datetime(6) DEFAULT NULL,
-    `instance_time_limit`  bigint   not null DEFAULT 0 COMMENT '任务整体超时时间',
+                            `gmt_modified` datetime(6) DEFAULT NULL,
-    `lifecycle`            varchar(255)      DEFAULT NULL COMMENT '生命周期',
+                            `instance_retry_num` int DEFAULT NULL,
-    `max_instance_num`     int      not null DEFAULT 1 COMMENT '最大同时运行任务数,默认 1',
+                            `instance_time_limit` bigint DEFAULT NULL,
-    `max_worker_count`     int      not null DEFAULT 0 COMMENT '最大运行节点数量',
+                            `job_description` varchar(255) DEFAULT NULL,
-    `min_cpu_cores`        double   NOT NULL default 0 COMMENT '最低CPU核心数量,0:不限',
+                            `job_name` varchar(255) DEFAULT NULL,
-    `min_disk_space`       double   NOT NULL default 0 COMMENT '最低磁盘空间(GB),0:不限',
+                            `job_params` longtext,
-    `min_memory_space`     double   NOT NULL default 0 COMMENT '最低内存空间(GB),0:不限',
+                            `lifecycle` varchar(255) DEFAULT NULL,
-    `next_trigger_time`    bigint            DEFAULT NULL COMMENT '下一次调度时间',
+                            `log_config` varchar(255) DEFAULT NULL,
-    `notify_user_ids`      varchar(255)      DEFAULT NULL COMMENT '报警用户(多值逗号分割)',
+                            `max_instance_num` int DEFAULT NULL,
-    `processor_info`       varchar(255)      DEFAULT NULL COMMENT '执行器信息',
+                            `max_worker_count` int DEFAULT NULL,
-    `processor_type`       int      not NULL COMMENT '执行器类型,1:内建处理器BUILT_IN/2:SHELL/3:PYTHON/4:外部处理器（动态加载）EXTERNAL',
+                            `min_cpu_cores` double NOT NULL,
-    `status`               int      not NULL COMMENT '状态,1:正常ENABLE/2:已禁用DISABLE/99:已删除DELETED',
+                            `min_disk_space` double NOT NULL,
-    `task_retry_num`       int      not NULL default 0 COMMENT 'Task重试次数',
+                            `min_memory_space` double NOT NULL,
-    `time_expression`      varchar(255)      default NULL COMMENT '时间表达式,内容取决于time_expression_type,1:CRON/2:NULL/3:LONG/4:LONG',
+                            `next_trigger_time` bigint DEFAULT NULL,
-    `time_expression_type` int      not NULL COMMENT '时间表达式类型,1:CRON/2:API/3:FIX_RATE/4:FIX_DELAY,5:WORKFLOW\n）',
+                            `notify_user_ids` varchar(255) DEFAULT NULL,
-    `tag`                  varchar(255)      DEFAULT NULL COMMENT 'TAG',
+                            `processor_info` varchar(255) DEFAULT NULL,
-    `log_config`           varchar(255)      DEFAULT NULL COMMENT '日志配置',
+                            `processor_type` int DEFAULT NULL,
-    `extra`                varchar(255)      DEFAULT NULL COMMENT '扩展字段',
+                            `status` int DEFAULT NULL,
-    `gmt_create`           datetime not NULL COMMENT '创建时间',
+                            `tag` varchar(255) DEFAULT NULL,
-    `gmt_modified`         datetime not NULL COMMENT '更新时间',
+                            `task_retry_num` int DEFAULT NULL,
-    PRIMARY KEY (`id`),
+                            `time_expression` varchar(255) DEFAULT NULL,
-    KEY `idx01_job_info` (`app_id`, `status`, `time_expression_type`, `next_trigger_time`)
+                            `time_expression_type` int DEFAULT NULL,
-) ENGINE = InnoDB
+                            PRIMARY KEY (`id`),
-  AUTO_INCREMENT = 1
+                            KEY `idx01_job_info` (`app_id`,`status`,`time_expression_type`,`next_trigger_time`)
-  DEFAULT CHARSET = utf8mb4
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-  COLLATE = utf8mb4_general_ci COMMENT ='任务表';
 
 -- ----------------------------
 -- Table structure for oms_lock
 -- ----------------------------
 DROP TABLE IF EXISTS `oms_lock`;
-CREATE TABLE `oms_lock`
+CREATE TABLE `oms_lock` (
-(
+                            `id` bigint NOT NULL AUTO_INCREMENT,
-    `id`            bigint   NOT NULL AUTO_INCREMENT COMMENT '序号ID',
+                            `gmt_create` datetime(6) DEFAULT NULL,
-    `lock_name`     varchar(128) DEFAULT NULL COMMENT '名称',
+                            `gmt_modified` datetime(6) DEFAULT NULL,
-    `max_lock_time` bigint       DEFAULT NULL COMMENT '最长持锁时间',
+                            `lock_name` varchar(255) DEFAULT NULL,
-    `ownerip`       varchar(255) DEFAULT NULL COMMENT '拥有者IP',
+                            `max_lock_time` bigint DEFAULT NULL,
-    `gmt_create`    datetime not NULL COMMENT '创建时间',
+                            `ownerip` varchar(255) DEFAULT NULL,
-    `gmt_modified`  datetime not NULL COMMENT '更新时间',
+                            PRIMARY KEY (`id`),
-    PRIMARY KEY (`id`),
+                            UNIQUE KEY `uidx01_oms_lock` (`lock_name`)
-    UNIQUE KEY `uidx01_oms_lock` (`lock_name`)
+) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-) ENGINE = InnoDB
-  AUTO_INCREMENT = 1
-  DEFAULT CHARSET = utf8mb4
-  COLLATE = utf8mb4_general_ci COMMENT ='数据库锁';
 
 -- ----------------------------
 -- Table structure for server_info
 -- ----------------------------
 DROP TABLE IF EXISTS `server_info`;
-CREATE TABLE `server_info`
+CREATE TABLE `server_info` (
-(
+                               `id` bigint NOT NULL AUTO_INCREMENT,
-    `id`           bigint NOT NULL AUTO_INCREMENT COMMENT '服务器ID',
+                               `gmt_create` datetime(6) DEFAULT NULL,
-    `gmt_create`   datetime     DEFAULT NULL COMMENT '创建时间',
+                               `gmt_modified` datetime(6) DEFAULT NULL,
-    `gmt_modified` datetime     DEFAULT NULL COMMENT '更新时间',
+                               `ip` varchar(255) DEFAULT NULL,
-    `ip`           varchar(128) DEFAULT NULL COMMENT '服务器IP地址',
+                               PRIMARY KEY (`id`),
-    PRIMARY KEY (`id`),
+                               UNIQUE KEY `uidx01_server_info` (`ip`),
-    UNIQUE KEY `uidx01_server_info` (`ip`),
+                               KEY `idx01_server_info` (`gmt_modified`)
-    KEY `idx01_server_info` (`gmt_modified`)
+) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-) ENGINE = InnoDB
-  AUTO_INCREMENT = 1
-  DEFAULT CHARSET = utf8mb4
-  COLLATE = utf8mb4_general_ci COMMENT ='服务器表';
 
 -- ----------------------------
 -- Table structure for user_info
 -- ----------------------------
 DROP TABLE IF EXISTS `user_info`;
-CREATE TABLE `user_info`
+CREATE TABLE `user_info` (
-(
+                             `id` bigint NOT NULL AUTO_INCREMENT,
-    `id`           bigint       NOT NULL AUTO_INCREMENT COMMENT '用户ID',
+                             `email` varchar(255) DEFAULT NULL,
-    `username`     varchar(128) not NULL COMMENT '用户名',
+                             `extra` varchar(255) DEFAULT NULL,
-    `password`     varchar(255) default NULL COMMENT '密码',
+                             `gmt_create` datetime(6) DEFAULT NULL,
-    `phone`        varchar(255) DEFAULT NULL COMMENT '手机号',
+                             `gmt_modified` datetime(6) DEFAULT NULL,
-    `email`        varchar(128) not NULL COMMENT '邮箱',
+                             `password` varchar(255) DEFAULT NULL,
-    `extra`        varchar(255) DEFAULT NULL COMMENT '扩展字段',
+                             `phone` varchar(255) DEFAULT NULL,
-    `web_hook`     varchar(255) DEFAULT NULL COMMENT 'webhook地址',
+                             `username` varchar(255) DEFAULT NULL,
-    `gmt_create`   datetime     not NULL COMMENT '创建时间',
+                             `web_hook` varchar(255) DEFAULT NULL,
-    `gmt_modified` datetime     not NULL COMMENT '更新时间',
+                             PRIMARY KEY (`id`),
-    PRIMARY KEY (`id`),
+                             KEY `uidx01_user_info` (`username`),
-    unique index uidx01_user_info (username),
+                             KEY `uidx02_user_info` (`email`)
-    unique index uidx02_user_info (email)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-) ENGINE = InnoDB
-  DEFAULT CHARSET = utf8mb4
-  COLLATE = utf8mb4_general_ci COMMENT ='用户表';
 
 -- ----------------------------
 -- Table structure for workflow_info
 -- ----------------------------
 DROP TABLE IF EXISTS `workflow_info`;
-CREATE TABLE `workflow_info`
+CREATE TABLE `workflow_info` (
-(
+                                 `id` bigint NOT NULL AUTO_INCREMENT,
-    `id`                   bigint       NOT NULL AUTO_INCREMENT COMMENT '工作流ID',
+                                 `app_id` bigint DEFAULT NULL,
-    `app_id`               bigint       not NULL COMMENT '应用ID',
+                                 `extra` varchar(255) DEFAULT NULL,
-    `wf_name`              varchar(128) not NULL COMMENT '工作流名称',
+                                 `gmt_create` datetime(6) DEFAULT NULL,
-    `wf_description`       varchar(255)          default NULL COMMENT '工作流描述',
+                                 `gmt_modified` datetime(6) DEFAULT NULL,
-    `extra`                varchar(255)          DEFAULT NULL COMMENT '扩展字段',
+                                 `lifecycle` varchar(255) DEFAULT NULL,
-    `lifecycle`            varchar(255)          DEFAULT NULL COMMENT '生命周期',
+                                 `max_wf_instance_num` int DEFAULT NULL,
-    `max_wf_instance_num`  int          not null DEFAULT 1 COMMENT '最大运行工作流数量,默认 1',
+                                 `next_trigger_time` bigint DEFAULT NULL,
-    `next_trigger_time`    bigint                DEFAULT NULL COMMENT '下次调度时间',
+                                 `notify_user_ids` varchar(255) DEFAULT NULL,
-    `notify_user_ids`      varchar(255)          DEFAULT NULL COMMENT '报警用户(多值逗号分割)',
+                                 `pedag` longtext,
-    `pedag`                text COMMENT 'DAG信息(JSON)',
+                                 `status` int DEFAULT NULL,
-    `status`               int          not NULL COMMENT '状态,1:正常ENABLE/2:已禁用DISABLE/99:已删除DELETED',
+                                 `time_expression` varchar(255) DEFAULT NULL,
-    `time_expression`      varchar(255)          DEFAULT NULL COMMENT '时间表达式,内容取决于time_expression_type,1:CRON/2:NULL/3:LONG/4:LONG',
+                                 `time_expression_type` int DEFAULT NULL,
-    `time_expression_type` int          not NULL COMMENT '时间表达式类型,1:CRON/2:API/3:FIX_RATE/4:FIX_DELAY,5:WORKFLOW\n）',
+                                 `wf_description` varchar(255) DEFAULT NULL,
-    `gmt_create`           datetime              DEFAULT NULL COMMENT '创建时间',
+                                 `wf_name` varchar(255) DEFAULT NULL,
-    `gmt_modified`         datetime              DEFAULT NULL COMMENT '更新时间',
+                                 PRIMARY KEY (`id`),
-    PRIMARY KEY (`id`),
+                                 KEY `idx01_workflow_info` (`app_id`,`status`,`time_expression_type`,`next_trigger_time`)
-    KEY `idx01_workflow_info` (`app_id`, `status`, `time_expression_type`, next_trigger_time)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-) ENGINE = InnoDB
-  AUTO_INCREMENT = 1
-  DEFAULT CHARSET = utf8mb4
-  COLLATE = utf8mb4_general_ci COMMENT ='工作流表';
 
 -- ----------------------------
 -- Table structure for workflow_instance_info
 -- ----------------------------
 DROP TABLE IF EXISTS `workflow_instance_info`;
-CREATE TABLE `workflow_instance_info`
+CREATE TABLE `workflow_instance_info` (
-(
+                                          `id` bigint NOT NULL AUTO_INCREMENT,
-    `id`                    bigint NOT NULL AUTO_INCREMENT COMMENT '工作流实例ID',
+                                          `actual_trigger_time` bigint DEFAULT NULL,
-    `wf_instance_id`        bigint   DEFAULT NULL COMMENT '工作流实例ID',
+                                          `app_id` bigint DEFAULT NULL,
-    `workflow_id`           bigint   DEFAULT NULL COMMENT '工作流ID',
+                                          `dag` longtext,
-    `actual_trigger_time`   bigint   DEFAULT NULL COMMENT '实际触发时间',
+                                          `expected_trigger_time` bigint DEFAULT NULL,
-    `app_id`                bigint   DEFAULT NULL COMMENT '应用ID',
+                                          `finished_time` bigint DEFAULT NULL,
-    `dag`                   text COMMENT 'DAG信息(JSON)',
+                                          `gmt_create` datetime(6) DEFAULT NULL,
-    `expected_trigger_time` bigint   DEFAULT NULL COMMENT '计划触发时间',
+                                          `gmt_modified` datetime(6) DEFAULT NULL,
-    `finished_time`         bigint   DEFAULT NULL COMMENT '执行结束时间',
+                                          `parent_wf_instance_id` bigint DEFAULT NULL,
-    `result`                text COMMENT '执行结果',
+                                          `result` longtext,
-    `status`                int      DEFAULT NULL COMMENT '工作流实例状态,1:等待调度WAITING/2:运行中RUNNING/3:失败FAILED/4:成功SUCCEED/10:手动停止STOPPED',
+                                          `status` int DEFAULT NULL,
-    `wf_context`            text COMMENT '工作流上下文',
+                                          `wf_context` longtext,
-    `wf_init_params`        text COMMENT '工作流启动参数',
+                                          `wf_init_params` longtext,
-    `gmt_create`            datetime DEFAULT NULL COMMENT '创建时间',
+                                          `wf_instance_id` bigint DEFAULT NULL,
-    `gmt_modified`          datetime DEFAULT NULL COMMENT '更新时间',
+                                          `workflow_id` bigint DEFAULT NULL,
-    PRIMARY KEY (`id`),
+                                          PRIMARY KEY (`id`),
-    unique index uidx01_wf_instance (`wf_instance_id`),
+                                          UNIQUE KEY `uidx01_wf_instance` (`wf_instance_id`),
-    index idx01_wf_instance (`workflow_id`, `status`),
+                                          KEY `idx01_wf_instance` (`workflow_id`,`status`,`app_id`,`expected_trigger_time`)
-    index idx02_wf_instance (`app_id`, `status`, `expected_trigger_time`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-) ENGINE = InnoDB
-  AUTO_INCREMENT = 1
-  DEFAULT CHARSET = utf8mb4
-  COLLATE = utf8mb4_general_ci COMMENT ='工作流实例表';
 
 -- ----------------------------
 -- Table structure for workflow_node_info
 -- ----------------------------
 DROP TABLE IF EXISTS `workflow_node_info`;
-CREATE TABLE `workflow_node_info`
+CREATE TABLE `workflow_node_info` (
-(
+                                      `id` bigint NOT NULL AUTO_INCREMENT,
-    `id`               bigint   NOT NULL AUTO_INCREMENT COMMENT '节点ID',
+                                      `app_id` bigint NOT NULL,
-    `app_id`           bigint   NOT NULL COMMENT '应用ID',
+                                      `enable` bit(1) NOT NULL,
-    `enable`           bit(1)   NOT NULL COMMENT '是否启动,0:否/1:是',
+                                      `extra` longtext,
-    `extra`            text COMMENT '扩展字段',
+                                      `gmt_create` datetime(6) NOT NULL,
-    `gmt_create`       datetime NOT NULL COMMENT '创建时间',
+                                      `gmt_modified` datetime(6) NOT NULL,
-    `gmt_modified`     datetime NOT NULL COMMENT '更新时间',
+                                      `job_id` bigint DEFAULT NULL,
-    `job_id`           bigint       default NULL COMMENT '任务ID',
+                                      `node_name` varchar(255) DEFAULT NULL,
-    `node_name`        varchar(255) DEFAULT NULL COMMENT '节点名称',
+                                      `node_params` longtext,
-    `node_params`      text COMMENT '节点参数',
+                                      `skip_when_failed` bit(1) NOT NULL,
-    `skip_when_failed` bit(1)   NOT NULL COMMENT '是否允许失败跳过,0:否/1:是',
+                                      `type` int DEFAULT NULL,
-    `type`             int          DEFAULT NULL COMMENT '节点类型,1:任务JOB',
+                                      `workflow_id` bigint DEFAULT NULL,
-    `workflow_id`      bigint       DEFAULT NULL COMMENT '工作流ID',
+                                      PRIMARY KEY (`id`),
-    PRIMARY KEY (`id`),
+                                      KEY `idx01_workflow_node_info` (`workflow_id`,`gmt_create`)
-    KEY `idx01_workflow_node_info` (`workflow_id`,`gmt_create`)
+) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
-) ENGINE = InnoDB
-  AUTO_INCREMENT = 1
-  DEFAULT CHARSET = utf8mb4
-  COLLATE = utf8mb4_general_ci COMMENT ='工作流节点表';
 
 SET FOREIGN_KEY_CHECKS = 1;
+

others/sql/upgrade/v4.3.7-v4.3.8.sql

@@ -0,0 +1,6 @@
+-- Upgrade SQL FROM 4.3.7 to 4.3.8
+-- ----------------------------
+-- Table change for job_info
+-- ----------------------------
+alter table job_info add dispatch_strategy_config varchar(255) comment 'dispatch_strategy_config' default null;
+alter table job_info add advanced_runtime_config varchar(255) comment 'advanced_runtime_config' default null;

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>tech.powerjob</groupId>
     <artifactId>powerjob</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
     <packaging>pom</packaging>
     <name>powerjob</name>
     <url>http://www.powerjob.tech</url>

powerjob-client/pom.xml

@@ -5,18 +5,18 @@
     <parent>
         <artifactId>powerjob</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-client</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
     <packaging>jar</packaging>
 
     <properties>
         <junit.version>5.9.1</junit.version>
         <fastjson.version>1.2.83</fastjson.version>
-        <powerjob.common.version>4.3.8</powerjob.common.version>
+        <powerjob.common.version>4.3.9</powerjob.common.version>
 
         <mvn.shade.plugin.version>3.2.4</mvn.shade.plugin.version>
     </properties>

powerjob-common/pom.xml

@@ -5,12 +5,12 @@
     <parent>
         <artifactId>powerjob</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-common</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
     <packaging>jar</packaging>
 
     <properties>

powerjob-official-processors/pom.xml

@@ -5,12 +5,12 @@
     <parent>
         <artifactId>powerjob</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-official-processors</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
     <packaging>jar</packaging>
 
     <properties>
@@ -20,7 +20,7 @@
         <!-- 不会被打包的部分，scope 只能是 test 或 provide -->
         <junit.version>5.9.1</junit.version>
         <logback.version>1.2.13</logback.version>
-        <powerjob.worker.version>4.3.8</powerjob.worker.version>
+        <powerjob.worker.version>4.3.9</powerjob.worker.version>
         <h2.db.version>2.2.224</h2.db.version>
         <mysql.version>8.0.28</mysql.version>
         <spring.version>5.3.31</spring.version>

powerjob-remote/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>powerjob</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
     <packaging>pom</packaging>

powerjob-remote/powerjob-remote-benchmark/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>powerjob-remote</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
@@ -21,8 +21,8 @@
 
         <logback.version>1.2.13</logback.version>
         <springboot.version>2.7.18</springboot.version>
-        <powerjob-remote-impl-http.version>4.3.8</powerjob-remote-impl-http.version>
+        <powerjob-remote-impl-http.version>4.3.9</powerjob-remote-impl-http.version>
-        <powerjob-remote-impl-akka.version>4.3.8</powerjob-remote-impl-akka.version>
+        <powerjob-remote-impl-akka.version>4.3.9</powerjob-remote-impl-akka.version>
 
         <gatling.version>3.9.0</gatling.version>
         <gatling-maven-plugin.version>4.2.9</gatling-maven-plugin.version>

powerjob-remote/powerjob-remote-framework/pom.xml

@@ -5,11 +5,11 @@
     <parent>
         <artifactId>powerjob-remote</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <version>4.3.8</version>
+    <version>4.3.9</version>
     <artifactId>powerjob-remote-framework</artifactId>
 
     <properties>
@@ -17,7 +17,7 @@
         <maven.compiler.target>8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 
-        <powerjob-common.version>4.3.8</powerjob-common.version>
+        <powerjob-common.version>4.3.9</powerjob-common.version>
         <reflections.version>0.10.2</reflections.version>
 
 

powerjob-remote/powerjob-remote-impl-akka/pom.xml

@@ -5,19 +5,19 @@
     <parent>
         <artifactId>powerjob-remote</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>powerjob-remote-impl-akka</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>
         <maven.compiler.target>8</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 
-        <powerjob-remote-framework.version>4.3.8</powerjob-remote-framework.version>
+        <powerjob-remote-framework.version>4.3.9</powerjob-remote-framework.version>
 
         <akka.version>2.6.13</akka.version>
     </properties>

powerjob-remote/powerjob-remote-impl-http/pom.xml

@@ -5,12 +5,12 @@
     <parent>
         <artifactId>powerjob-remote</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>powerjob-remote-impl-http</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
 
     <properties>
         <maven.compiler.source>8</maven.compiler.source>
@@ -18,7 +18,7 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
 
         <vertx.version>4.3.7</vertx.version>
-        <powerjob-remote-framework.version>4.3.8</powerjob-remote-framework.version>
+        <powerjob-remote-framework.version>4.3.9</powerjob-remote-framework.version>
     </properties>
 
     <dependencies>

powerjob-server/pom.xml

@@ -5,12 +5,12 @@
     <parent>
         <artifactId>powerjob</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-server</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
     <packaging>pom</packaging>
 
     <modules>
@@ -50,9 +50,9 @@
         <groovy.version>3.0.10</groovy.version>
         <cron-utils.version>9.2.1</cron-utils.version>
 
-        <powerjob-common.version>4.3.8</powerjob-common.version>
+        <powerjob-common.version>4.3.9</powerjob-common.version>
-        <powerjob-remote-impl-http.version>4.3.8</powerjob-remote-impl-http.version>
+        <powerjob-remote-impl-http.version>4.3.9</powerjob-remote-impl-http.version>
-        <powerjob-remote-impl-akka.version>4.3.8</powerjob-remote-impl-akka.version>
+        <powerjob-remote-impl-akka.version>4.3.9</powerjob-remote-impl-akka.version>
         <springdoc-openapi-ui.version>1.6.14</springdoc-openapi-ui.version>
         <aliyun-sdk-oss.version>3.17.1</aliyun-sdk-oss.version>
         <aws-java-sdk-s3.version>1.12.665</aws-java-sdk-s3.version>

powerjob-server/powerjob-server-common/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>powerjob-server</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

powerjob-server/powerjob-server-core/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>powerjob-server</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

powerjob-server/powerjob-server-extension/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>powerjob-server</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

powerjob-server/powerjob-server-migrate/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>powerjob-server</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

powerjob-server/powerjob-server-monitor/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>powerjob-server</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

powerjob-server/powerjob-server-persistence/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>powerjob-server</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

powerjob-server/powerjob-server-persistence/src/main/java/tech/powerjob/server/persistence/storage/impl/MinioOssService.java

@@ -196,6 +196,8 @@ public class MinioOssService extends AbstractDFsService {
      */
     @SneakyThrows(Exception.class)
     public void createBucket(String bucketName) {
+
+        // 建议自行创建 bucket，设置好相关的策略
         if (bucketExists(bucketName)) {
            return;
         }

powerjob-server/powerjob-server-remote/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>powerjob-server</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

powerjob-server/powerjob-server-starter/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>powerjob-server</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

powerjob-server/powerjob-server-starter/src/main/resources/application-daily.properties

@@ -12,7 +12,7 @@ spring.datasource.core.minimum-idle=5
 ####### Storage properties(Delete if not needed)  #######
 #oms.storage.dfs.mongodb.uri=mongodb+srv://zqq:No1Bug2Please3!@cluster0.wie54.gcp.mongodb.net/powerjob_daily?retryWrites=true&w=majority
 oms.storage.dfs.mysql_series.driver=com.mysql.cj.jdbc.Driver
-oms.storage.dfs.mysql_series.url=jdbc:mysql://localhost:3306/powerjob-daily?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
+oms.storage.dfs.mysql_series.url=jdbc:mysql://powerjob-mysql:3306/powerjob-daily?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai
 oms.storage.dfs.mysql_series.username=root
 oms.storage.dfs.mysql_series.password=No1Bug2Please3!
 oms.storage.dfs.mysql_series.auto_create_table=true

powerjob-server/powerjob-server-starter/src/main/resources/application-product.properties

@@ -10,7 +10,7 @@ spring.datasource.core.maximum-pool-size=20
 spring.datasource.core.minimum-idle=5
 
 ####### Storage properties(Delete if not needed)  #######
-oms.storage.dfs.mongodb.uri=mongodb://localhost:27017/powerjob-product
+#oms.storage.dfs.mongodb.uri=mongodb://localhost:27017/powerjob-product
 
 ####### Email properties(Non-core configuration properties) #######
 ####### Delete the following code to disable the mail #######

powerjob-worker-agent/pom.xml

@@ -5,24 +5,24 @@
     <parent>
         <artifactId>powerjob</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-worker-agent</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
     <packaging>jar</packaging>
 
 
     <properties>
-        <powerjob.worker.version>4.3.8</powerjob.worker.version>
+        <powerjob.worker.version>4.3.9</powerjob.worker.version>
         <logback.version>1.2.13</logback.version>
         <picocli.version>4.3.2</picocli.version>
         <spring.version>5.3.31</spring.version>
 
         <spring.boot.version>2.3.4.RELEASE</spring.boot.version>
 
-        <powerjob.official.processors.version>4.3.8</powerjob.official.processors.version>
+        <powerjob.official.processors.version>4.3.9</powerjob.official.processors.version>
 
         <!-- dependency for dynamic sql processor -->
         <mysql.version>8.0.28</mysql.version>

powerjob-worker-samples/pom.xml

@@ -5,18 +5,18 @@
     <parent>
         <artifactId>powerjob</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
     <artifactId>powerjob-worker-samples</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
 
     <properties>
         <springboot.version>2.7.18</springboot.version>
-        <powerjob.worker.starter.version>4.3.8</powerjob.worker.starter.version>
+        <powerjob.worker.starter.version>4.3.9</powerjob.worker.starter.version>
         <fastjson.version>1.2.83</fastjson.version>
-        <powerjob.official.processors.version>4.3.8</powerjob.official.processors.version>
+        <powerjob.official.processors.version>4.3.9</powerjob.official.processors.version>
 
         <!-- 部署时跳过该module -->
         <maven.deploy.skip>true</maven.deploy.skip>

powerjob-worker-spring-boot-starter/pom.xml

@@ -5,16 +5,16 @@
     <parent>
         <artifactId>powerjob</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-worker-spring-boot-starter</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
     <packaging>jar</packaging>
 
     <properties>
-        <powerjob.worker.version>4.3.8</powerjob.worker.version>
+        <powerjob.worker.version>4.3.9</powerjob.worker.version>
         <springboot.version>2.7.18</springboot.version>
     </properties>
 

powerjob-worker/pom.xml

@@ -5,12 +5,12 @@
     <parent>
         <artifactId>powerjob</artifactId>
         <groupId>tech.powerjob</groupId>
-        <version>4.3.8</version>
+        <version>4.3.9</version>
     </parent>
 
     <modelVersion>4.0.0</modelVersion>
     <artifactId>powerjob-worker</artifactId>
-    <version>4.3.8</version>
+    <version>4.3.9</version>
     <packaging>jar</packaging>
 
     <properties>
@@ -21,10 +21,10 @@
 
         <logback.version>1.2.13</logback.version>
 
-        <powerjob-common.version>4.3.8</powerjob-common.version>
+        <powerjob-common.version>4.3.9</powerjob-common.version>
-        <powerjob-remote-framework.version>4.3.8</powerjob-remote-framework.version>
+        <powerjob-remote-framework.version>4.3.9</powerjob-remote-framework.version>
-        <powerjob-remote-impl-akka.version>4.3.8</powerjob-remote-impl-akka.version>
+        <powerjob-remote-impl-akka.version>4.3.9</powerjob-remote-impl-akka.version>
-        <powerjob-remote-impl-http.version>4.3.8</powerjob-remote-impl-http.version>
+        <powerjob-remote-impl-http.version>4.3.9</powerjob-remote-impl-http.version>
     </properties>
 
     <dependencies>