Seata所需的表global_table、branch_table 、lock_table、undo_log
一、seata-tc服务器
分别是分支事务表和全局事务表
create schema seata collate utf8_unicode_ci;
create table branch_table
(
branch_id bigint not null
primary key,
xid varchar(128) not null,
transaction_id bigint null,
resource_group_id varchar(32) null,
resource_id varchar(256) null,
branch_type varchar(8) null,
status tinyint null,
client_id varchar(64) null,
application_data varchar(2000) null,
gmt_create datetime(6) null,
gmt_modified datetime(6) null
)
charset=utf8;
create index idx_xid
on branch_table (xid);
create table global_table
(
xid varchar(128) not null
primary key,
transaction_id bigint null,
status tinyint not null,
application_id varchar(32) null,
transaction_service_group varchar(32) null,
transaction_name varchar(128) null,
timeout int null,
begin_time bigint null,
application_data varchar(2000) null,
gmt_create datetime null,
gmt_modified datetime null
)
charset=utf8;
create index idx_gmt_modified_status
on global_table (gmt_modified, status);
create index idx_transaction_id
on global_table (transaction_id);
二、各分支数据库
lock_table:记录着被全局事务锁xid锁定的数据pk,各分支事务提交的时候先校验是否有被全局锁住的数据,如果冲突则分支事务无法进行提交,防止了脏写(都是被seata管理的事务)。 对于没被seata的管理的事务,怎样防止脏写呢,就要用到保存前后镜像的undo log,seata事务要回滚的时候判断当前镜像有没有被其他事务修改过,没有则可进行回滚。
create table health_ums.lock_table
(
row_key varchar(128) not null
primary key,
xid varchar(96) null,
transaction_id bigint null,
branch_id bigint not null,
resource_id varchar(256) null,
table_name varchar(32) null,
pk varchar(36) null,
gmt_create datetime null,
gmt_modified datetime null
)
charset=utf8;
create index idx_branch_id
on health_ums.lock_table (branch_id);
create table health_ums.undo_log
(
branch_id bigint not null comment 'branch transaction id',
xid varchar(100) not null comment 'global transaction id',
context varchar(128) not null comment 'undo_log context,such as serialization',
rollback_info longblob not null comment 'rollback info',
log_status int not null comment '0:normal status,1:defense status',
log_created datetime(6) not null comment 'create datetime',
log_modified datetime(6) not null comment 'modify datetime',
constraint ux_undo_log
unique (xid, branch_id)
)
comment 'AT transaction mode undo table' charset=utf8;
|