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事务要回滚的时候判断当前镜像有没有被其他事务修改过,没有则可进行回滚。

Logo

华为开发者空间,是为全球开发者打造的专属开发空间,汇聚了华为优质开发资源及工具,致力于让每一位开发者拥有一台云主机,基于华为根生态开发、创新。

更多推荐