VberAdminPlusV3/SERVER/VberAdminPlusV3/.script/sql/powerjob.sql

-- ----------------------------
-- 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 `idx01_app_info` (`app_name`) USING BTREE
) ENGINE = InnoDB
  AUTO_INCREMENT = 1000
  ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- 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 = 1000
  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 = 1000
  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 = 1000
  ROW_FORMAT = DYNAMIC;

-- ----------------------------
-- 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 = 1000
  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 = 1000
  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 = 1000
  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 = 1000
  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 = 1000
  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 = 1000
  ROW_FORMAT = DYNAMIC;


-- ----------------------------
-- Records of pj_app_info
-- ----------------------------
INSERT INTO `pj_app_info` (id, app_name, current_server, gmt_create, gmt_modified, password)
VALUES (1, 'vber-worker', '127.0.0.1:10010', SYSDATE(), NULL, '123456');

-- ----------------------------
-- Records of pj_job_info
-- ----------------------------
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-07-04 17:22:12.374000', 1, 0, '', '单机处理器执行测试', NULL, '{}', '{\"type\":1}', 0, 0, 0, 0, 0, NULL, NULL, 'com.vber.job.processors.StandaloneProcessorDemo', 1, 2, NULL, 1, '30000', 3),
       (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, 'com.vber.job.processors.BroadcastProcessorDemo', 1, 2, NULL, 1, '30000', 3),
       (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, 'com.vber.job.processors.MapProcessorDemo', 1, 2, NULL, 1, '1000', 3),
       (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, 'com.vber.job.processors.MapReduceProcessorDemo', 1, 2, NULL, 1, '1000', 3);