diff --git a/workflow-engine-core/src/main/resources/sql/upgrade_to_1.3.3.sql b/workflow-engine-core/src/main/resources/sql/upgrade_to_1.3.3.sql index 1d529a302..d65168734 100644 --- a/workflow-engine-core/src/main/resources/sql/upgrade_to_1.3.3.sql +++ b/workflow-engine-core/src/main/resources/sql/upgrade_to_1.3.3.sql @@ -1,19 +1,22 @@ DROP TABLE IF EXISTS `EXT_AX_MQ_LOG`; CREATE TABLE IF NOT EXISTS EXT_AX_MQ_LOG ( - `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', - `unique_id` varchar(50) NOT NULL DEFAULT '' COMMENT '唯一ID', - `message_id` varchar(100) NOT NULL DEFAULT '' COMMENT 'MQ 的 Message ID', - `mq_tag` varchar(50) NOT NULL DEFAULT '' COMMENT 'MQ 的 TAG', - `mq_key` varchar(50) NOT NULL DEFAULT '' COMMENT 'MQ 的 KEY', - `message_body` text COMMENT 'MQ 的 Message Body', - `trace_id` varchar(50) NOT NULL DEFAULT '' COMMENT 'traceId', - `create_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', - `update_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', - `is_delete` bigint NOT NULL DEFAULT '0' COMMENT '是否删除', + `id` bigint NOT NULL AUTO_INCREMENT COMMENT '主键', + `unique_id` varchar(50) NOT NULL DEFAULT '' COMMENT '唯一ID', + `message_id` varchar(100) NOT NULL DEFAULT '' COMMENT 'MQ 的 Message ID', + `mq_tag` varchar(50) NOT NULL DEFAULT '' COMMENT 'MQ 的 TAG', + `mq_key` varchar(50) NOT NULL DEFAULT '' COMMENT 'MQ 的 KEY', + `message_body` text COMMENT 'MQ 的 Message Body', + `trace_id` varchar(50) NOT NULL DEFAULT '' COMMENT 'traceId', + `create_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', + `update_at` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '更新时间', + `is_delete` bigint NOT NULL DEFAULT '0' COMMENT '是否删除', + `insert_thread_name` varchar(100) NOT NULL DEFAULT '' COMMENT '插入线程名', + `update_thread_name` varchar(100) NOT NULL DEFAULT '' COMMENT '更新线程名', + `delete_thread_name` varchar(100) NOT NULL DEFAULT '' COMMENT '删除线程名', PRIMARY KEY (`id`) ) ENGINE = InnoDB COMMENT 'MQ发送记录表'; -create unique index idx_unique_trace on EXT_AX_MQ_LOG (unique_id, trace_id); +create unique index idx_unique on EXT_AX_MQ_LOG (unique_id);