diff --git a/dtmcli/barrier.mysql.sql b/dtmcli/barrier.mysql.sql index a676f34..60b828f 100644 --- a/dtmcli/barrier.mysql.sql +++ b/dtmcli/barrier.mysql.sql @@ -1,10 +1,11 @@ -create database if not exists dtm_barrier /*!40100 DEFAULT CHARACTER SET utf8mb4 */; - +create database if not exists dtm_barrier +/*!40100 DEFAULT CHARACTER SET utf8mb4 */ +; drop table if exists dtm_barrier.barrier; create table if not exists dtm_barrier.barrier( - id int(11) PRIMARY KEY AUTO_INCREMENT, - trans_type varchar(45) default '' , - gid varchar(128) default'', + id bigint(22) PRIMARY KEY AUTO_INCREMENT, + trans_type varchar(45) default '', + gid varchar(128) default '', branch_id varchar(128) default '', branch_type varchar(45) default '', barrier_id varchar(45) default '', @@ -14,4 +15,4 @@ create table if not exists dtm_barrier.barrier( key(create_time), key(update_time), UNIQUE key(gid, branch_id, branch_type, barrier_id) -); +); \ No newline at end of file diff --git a/dtmcli/barrier.postgres.sql b/dtmcli/barrier.postgres.sql index dc3d069..62b8f5a 100644 --- a/dtmcli/barrier.postgres.sql +++ b/dtmcli/barrier.postgres.sql @@ -1,13 +1,10 @@ create schema if not exists dtm_barrier; - drop table if exists dtm_barrier.barrier; - CREATE SEQUENCE if not EXISTS dtm_barrier.barrier_seq; - create table if not exists dtm_barrier.barrier( - id int NOT NULL DEFAULT NEXTVAL ('dtm_barrier.barrier_seq'), - trans_type varchar(45) default '' , - gid varchar(128) default'', + id bigint NOT NULL DEFAULT NEXTVAL ('dtm_barrier.barrier_seq'), + trans_type varchar(45) default '', + gid varchar(128) default '', branch_id varchar(128) default '', branch_type varchar(45) default '', barrier_id varchar(45) default '', @@ -16,5 +13,4 @@ create table if not exists dtm_barrier.barrier( update_time timestamp(0) DEFAULT NULL, PRIMARY KEY(id), CONSTRAINT uniq_barrier unique(gid, branch_id, branch_type, barrier_id) -); - +); \ No newline at end of file diff --git a/dtmsvr/dtmsvr.mysql.sql b/dtmsvr/dtmsvr.mysql.sql index 0c7c550..20ce7b9 100644 --- a/dtmsvr/dtmsvr.mysql.sql +++ b/dtmsvr/dtmsvr.mysql.sql @@ -3,7 +3,7 @@ CREATE DATABASE IF NOT EXISTS dtm ; drop table IF EXISTS dtm.trans_global; CREATE TABLE if not EXISTS dtm.trans_global ( - `id` int(11) NOT NULL AUTO_INCREMENT, + `id` bigint(22) NOT NULL AUTO_INCREMENT, `gid` varchar(128) NOT NULL COMMENT '事务全局id', `trans_type` varchar(45) not null COMMENT '事务类型: saga | xa | tcc | msg', -- `data` TEXT COMMENT '事务携带的数据', -- 影响性能,不必要存储 @@ -15,6 +15,8 @@ CREATE TABLE if not EXISTS dtm.trans_global ( `commit_time` datetime DEFAULT NULL, `finish_time` datetime DEFAULT NULL, `rollback_time` datetime DEFAULT NULL, + `options` varchar(256) DEFAULT '', + `custom_data` varchar(256) DEFAULT '', `next_cron_interval` int(11) default null comment '下次定时处理的间隔', `next_cron_time` datetime default null comment '下次定时处理的时间', `owner` varchar(128) not null default '' comment '正在处理全局事务的锁定者', @@ -27,7 +29,7 @@ CREATE TABLE if not EXISTS dtm.trans_global ( ) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4; drop table IF EXISTS dtm.trans_branch; CREATE TABLE IF NOT EXISTS dtm.trans_branch ( - `id` int(11) NOT NULL AUTO_INCREMENT, + `id` bigint(22) NOT NULL AUTO_INCREMENT, `gid` varchar(128) NOT NULL COMMENT '事务全局id', `url` varchar(128) NOT NULL COMMENT '动作关联的url', `data` TEXT COMMENT '请求所携带的数据', @@ -45,7 +47,7 @@ CREATE TABLE IF NOT EXISTS dtm.trans_branch ( ) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4; drop table IF EXISTS dtm.trans_log; CREATE TABLE IF NOT EXISTS dtm.trans_log ( - `id` int(11) NOT NULL AUTO_INCREMENT, + `id` bigint(22) NOT NULL AUTO_INCREMENT, `gid` varchar(128) NOT NULL COMMENT '事务全局id', `branch_id` varchar(128) DEFAULT NULL COMMENT '事务分支', `action` varchar(45) DEFAULT NULL COMMENT '行为', diff --git a/dtmsvr/dtmsvr.postgres.sql b/dtmsvr/dtmsvr.postgres.sql index 6bc598a..ed8b273 100644 --- a/dtmsvr/dtmsvr.postgres.sql +++ b/dtmsvr/dtmsvr.postgres.sql @@ -5,7 +5,7 @@ drop table IF EXISTS dtm.trans_global; -- SQLINES LICENSE FOR EVALUATION USE ONLY CREATE SEQUENCE if not EXISTS dtm.trans_global_seq; CREATE TABLE if not EXISTS dtm.trans_global ( - id int NOT NULL DEFAULT NEXTVAL ('dtm.trans_global_seq'), + id bigint NOT NULL DEFAULT NEXTVAL ('dtm.trans_global_seq'), gid varchar(128) NOT NULL, trans_type varchar(45) not null, status varchar(45) NOT NULL, @@ -16,6 +16,8 @@ CREATE TABLE if not EXISTS dtm.trans_global ( commit_time timestamp(0) DEFAULT NULL, finish_time timestamp(0) DEFAULT NULL, rollback_time timestamp(0) DEFAULT NULL, + options varchar(256) DEFAULT '', + custom_data varchar(256) DEFAULT '', next_cron_interval int default null, next_cron_time timestamp(0) default null, owner varchar(128) not null default '', @@ -30,7 +32,7 @@ drop table IF EXISTS dtm.trans_branch; -- SQLINES LICENSE FOR EVALUATION USE ONLY CREATE SEQUENCE if not EXISTS dtm.trans_branch_seq; CREATE TABLE IF NOT EXISTS dtm.trans_branch ( - id int NOT NULL DEFAULT NEXTVAL ('dtm.trans_branch_seq'), + id bigint NOT NULL DEFAULT NEXTVAL ('dtm.trans_branch_seq'), gid varchar(128) NOT NULL, url varchar(128) NOT NULL, data TEXT, @@ -50,7 +52,7 @@ drop table IF EXISTS dtm.trans_log; -- SQLINES LICENSE FOR EVALUATION USE ONLY CREATE SEQUENCE if not EXISTS dtm.trans_log_seq; CREATE TABLE IF NOT EXISTS dtm.trans_log ( - id int NOT NULL DEFAULT NEXTVAL ('dtm.trans_log_seq'), + id bigint NOT NULL DEFAULT NEXTVAL ('dtm.trans_log_seq'), gid varchar(128) NOT NULL, branch_id varchar(128) DEFAULT NULL, action varchar(45) DEFAULT NULL,