Seata AT模式所需的表global_table、branch_table 、lock_table和undo_log
Seata所需的表global_table、branch_table 、lock_table、undo_log一、seata-tc服务器分别是分支事务表和全局事务表seata如何防止脏写
·
Seata AT模式所需要的表global_table、branch_table 、lock_table、undo_log
一、seata数据库三张表
分别是分支事务表,全局事务表和全局锁表。
lock_table:记录着被全局事务锁xid锁定的数据pk,各分支事务提交的时候先校验是否有被全局锁住的数据,如果冲突则分支事务无法进行提交,防止了脏写(都是被seata管理的事务)。
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);
create table 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 lock_table (branch_id);
二、各分支数据库undo_lock表
create table 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;
seata如何防止脏写
事务一和事务二都被seata管理
本地事务一修改数据A并本地提交,但全局事务还没提交,本地事务二获取到了本地锁,也修改了数据A,当事务二要提交的时候,需要获取全局锁,获取不到则回滚,避免了脏写。
只有事务一被seata管理,事务二不被seata管理
对于没被seata的管理的事务二,怎样防止脏写呢,就要用到保存前后镜像的undo_log,seata事务要回滚的时候判断当前镜像有没有被其他事务修改过,没有则可进行回滚。
更多推荐
已为社区贡献1条内容
所有评论(0)