CREATE DATABASE IF NOT EXISTS `dtm` /*!40100 DEFAULT CHARACTER SET utf8mb4 */;

use dtm;

drop table IF EXISTS trans_global;
CREATE TABLE if not EXISTS `trans_global` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `gid` varchar(128) NOT NULL COMMENT '事务全局id',
  `trans_type` varchar(45) not null COMMENT '事务类型: saga | xa',
  `data` TEXT COMMENT '事务携带的数据',
  `status` varchar(45) NOT NULL COMMENT '全局事务的状态 prepared | submitted | finished | rollbacked',
  `query_prepared` varchar(128) NOT NULL COMMENT 'prepared状态事务的查询api',
  `create_time` datetime DEFAULT NULL,
  `update_time` datetime DEFAULT NULL,
  `commit_time` datetime DEFAULT NULL,
  `finish_time` datetime DEFAULT NULL,
  `rollback_time` datetime DEFAULT NULL,
  `next_cron_interval` int(11) default null comment '下次定时处理的间隔',
  `next_cron_time` datetime default null comment '下次定时处理的时间',
  `owner` varchar(128) not null default '' comment '正在处理全局事务的锁定者',
  PRIMARY KEY (`id`),
  UNIQUE KEY `gid` (`gid`),
  key `owner`(`owner`),
  KEY `create_time` (`create_time`),
  KEY `update_time` (`update_time`),
  key `next_cron_time` (`next_cron_time`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

drop table IF EXISTS trans_branch;
CREATE TABLE IF NOT EXISTS `trans_branch` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `gid` varchar(128) NOT NULL COMMENT '事务全局id',
  `url` varchar(128) NOT NULL COMMENT '动作关联的url',
  `data` TEXT COMMENT '请求所携带的数据',
  `branch_id` VARCHAR(128) NOT NULL COMMENT '事务分支名称',
  `branch_type` varchar(45) NOT NULL COMMENT '事务分支类型 saga_action | saga_compensate | xa',
  `status` varchar(45) NOT NULL COMMENT '步骤的状态 submitted | finished | rollbacked',
  `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` (`gid`,`branch_id`, `branch_type`),
  KEY `create_time` (`create_time`),
  KEY `update_time` (`update_time`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

drop table IF EXISTS trans_log;
CREATE TABLE IF NOT EXISTS `trans_log` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `gid` varchar(128) NOT NULL COMMENT '事务全局id',
  `branch_id` varchar(128) DEFAULT NULL COMMENT '事务分支',
  `action` varchar(45) DEFAULT NULL COMMENT '行为',
  `old_status` varchar(45) NOT NULL DEFAULT '' COMMENT '旧状态',
  `new_status` varchar(45) NOT NULL COMMENT '新状态',
  `detail` TEXT NOT NULL COMMENT '行为记录的数据',
  `create_time` datetime DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  KEY `gid` (`gid`),
  KEY `create_time` (`create_time`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;