mirror of https://github.com/dtm-labs/dtm.git
csharpjavadistributed-transactionsdtmgogolangmicroservicenodejsphpdatabasesagaseatatcctransactiontransactionsxapythondistributed
You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
57 lines
3.0 KiB
57 lines
3.0 KiB
CREATE DATABASE IF NOT EXISTS dtm
|
|
/*!40100 DEFAULT CHARACTER SET utf8mb4 */
|
|
;
|
|
drop table IF EXISTS dtm.trans_global;
|
|
CREATE TABLE if not EXISTS dtm.trans_global (
|
|
`id` bigint(22) NOT NULL AUTO_INCREMENT,
|
|
`gid` varchar(128) NOT NULL COMMENT 'global transaction id',
|
|
`trans_type` varchar(45) not null COMMENT 'transaction type: saga | xa | tcc | msg',
|
|
`status` varchar(12) NOT NULL COMMENT 'transaction status: prepared | submitted | aborting | finished | rollbacked',
|
|
`query_prepared` varchar(1024) NOT NULL COMMENT 'url to check for msg|workflow',
|
|
`protocol` varchar(45) not null comment 'protocol: http | grpc | json-rpc',
|
|
`create_time` datetime DEFAULT NULL,
|
|
`update_time` datetime DEFAULT NULL,
|
|
`finish_time` datetime DEFAULT NULL,
|
|
`rollback_time` datetime DEFAULT NULL,
|
|
`options` varchar(1024) DEFAULT '' COMMENT 'options for transaction like: TimeoutToFail, RequestTimeout',
|
|
`custom_data` varchar(1024) DEFAULT '' COMMENT 'custom data for transaction',
|
|
`next_cron_interval` int(11) default null comment 'next cron interval. for use of cron job',
|
|
`next_cron_time` datetime default null comment 'next time to process this trans. for use of cron job',
|
|
`owner` varchar(128) not null default '' comment 'who is locking this trans',
|
|
`ext_data` TEXT comment 'extra data for this trans. currently used in workflow pattern',
|
|
`result` varchar(1024) DEFAULT '' COMMENT 'result for transaction',
|
|
`rollback_reason` varchar(1024) DEFAULT '' COMMENT 'rollback reason for transaction',
|
|
PRIMARY KEY (`id`),
|
|
UNIQUE KEY `gid` (`gid`),
|
|
key `owner`(`owner`),
|
|
key `status_next_cron_time` (`status`, `next_cron_time`) comment 'cron job will use this index to query trans'
|
|
) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4;
|
|
drop table IF EXISTS dtm.trans_branch_op;
|
|
CREATE TABLE IF NOT EXISTS dtm.trans_branch_op (
|
|
`id` bigint(22) NOT NULL AUTO_INCREMENT,
|
|
`gid` varchar(128) NOT NULL COMMENT 'global transaction id',
|
|
`url` varchar(1024) NOT NULL COMMENT 'the url of this op',
|
|
`data` TEXT COMMENT 'request body, depreceated',
|
|
`bin_data` BLOB COMMENT 'request body',
|
|
`branch_id` VARCHAR(128) NOT NULL COMMENT 'transaction branch ID',
|
|
`op` varchar(45) NOT NULL COMMENT 'transaction operation type like: action | compensate | try | confirm | cancel',
|
|
`status` varchar(45) NOT NULL COMMENT 'transaction op status: prepared | succeed | failed',
|
|
`finish_time` datetime DEFAULT NULL,
|
|
`rollback_time` datetime DEFAULT NULL,
|
|
`create_time` datetime DEFAULT NULL,
|
|
`update_time` datetime DEFAULT NULL,
|
|
PRIMARY KEY (`id`),
|
|
UNIQUE KEY `gid_uniq` (`gid`, `branch_id`, `op`)
|
|
) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4;
|
|
drop table IF EXISTS dtm.kv;
|
|
CREATE TABLE IF NOT EXISTS dtm.kv (
|
|
`id` bigint(22) NOT NULL AUTO_INCREMENT,
|
|
`cat` varchar(45) NOT NULL COMMENT 'the category of this data',
|
|
`k` varchar(128) NOT NULL,
|
|
`v` TEXT,
|
|
`version` bigint(22) default 1 COMMENT 'version of the value',
|
|
create_time datetime default NULL,
|
|
update_time datetime DEFAULT NULL,
|
|
PRIMARY KEY (`id`),
|
|
UNIQUE key `uniq_k`(`cat`, `k`)
|
|
) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4;
|
|
|