| -- -------------------------------- The script used when storeMode is 'db' -------------------------------- | |
| -- the table to store GlobalSession data | |
| DROP TABLE IF EXISTS `global_table`; | |
| CREATE TABLE IF NOT EXISTS `global_table` | |
| ( | |
|     `xid`                       VARCHAR(128) NOT NULL, | |
|     `transaction_id`            BIGINT, | |
|     `status`                    TINYINT      NOT NULL, | |
|     `application_id`            VARCHAR(32), | |
|     `transaction_service_group` VARCHAR(32), | |
|     `transaction_name`          VARCHAR(128), | |
|     `timeout`                   INT, | |
|     `begin_time`                BIGINT, | |
|     `application_data`          VARCHAR(2000), | |
|     `gmt_create`                DATETIME, | |
|     `gmt_modified`              DATETIME, | |
|     PRIMARY KEY (`xid`), | |
|     KEY `idx_status_gmt_modified` (`status` , `gmt_modified`), | |
|     KEY `idx_transaction_id` (`transaction_id`) | |
| ) ENGINE = InnoDB | |
|   DEFAULT CHARSET = utf8mb4; | |
|  | |
| -- the table to store BranchSession data | |
| DROP TABLE IF EXISTS `branch_table`; | |
| CREATE TABLE IF NOT EXISTS `branch_table` | |
| ( | |
|     `branch_id`         BIGINT       NOT NULL, | |
|     `xid`               VARCHAR(128) NOT NULL, | |
|     `transaction_id`    BIGINT, | |
|     `resource_group_id` VARCHAR(32), | |
|     `resource_id`       VARCHAR(256), | |
|     `branch_type`       VARCHAR(8), | |
|     `status`            TINYINT, | |
|     `client_id`         VARCHAR(64), | |
|     `application_data`  VARCHAR(2000), | |
|     `gmt_create`        DATETIME(6), | |
|     `gmt_modified`      DATETIME(6), | |
|     PRIMARY KEY (`branch_id`), | |
|     KEY `idx_xid` (`xid`) | |
| ) ENGINE = InnoDB | |
|   DEFAULT CHARSET = utf8mb4; | |
|  | |
| -- the table to store lock data | |
| DROP TABLE IF EXISTS `lock_table`; | |
| CREATE TABLE IF NOT EXISTS `lock_table` | |
| ( | |
|     `row_key`        VARCHAR(128) NOT NULL, | |
|     `xid`            VARCHAR(128), | |
|     `transaction_id` BIGINT, | |
|     `branch_id`      BIGINT       NOT NULL, | |
|     `resource_id`    VARCHAR(256), | |
|     `table_name`     VARCHAR(32), | |
|     `pk`             VARCHAR(36), | |
|     `status`         TINYINT      NOT NULL DEFAULT '0' COMMENT '0:locked ,1:rollbacking', | |
|     `gmt_create`     DATETIME, | |
|     `gmt_modified`   DATETIME, | |
|     PRIMARY KEY (`row_key`), | |
|     KEY `idx_status` (`status`), | |
|     KEY `idx_branch_id` (`branch_id`), | |
|     KEY `idx_xid` (`xid`) | |
| ) ENGINE = InnoDB | |
|   DEFAULT CHARSET = utf8mb4; | |
|  | |
| DROP TABLE IF EXISTS `distributed_lock`; | |
| CREATE TABLE IF NOT EXISTS `distributed_lock` | |
| ( | |
|     `lock_key`       CHAR(20) NOT NULL, | |
|     `lock_value`     VARCHAR(20) NOT NULL, | |
|     `expire`         BIGINT, | |
|     primary key (`lock_key`) | |
| ) ENGINE = InnoDB | |
|   DEFAULT CHARSET = utf8mb4; | |
|  | |
| INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('AsyncCommitting', ' ', 0); | |
| INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryCommitting', ' ', 0); | |
| INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('RetryRollbacking', ' ', 0); | |
| INSERT INTO `distributed_lock` (lock_key, lock_value, expire) VALUES ('TxTimeoutCheck', ' ', 0); |