我了解的数据库事务复制

简介: 事务复制 事务复制的基本机制,在联机文档上也有介绍。 基本原理   如图,主要依靠2个代理,1.日志读取代理(log reader agent),2.分发代理(distribution agent)。

事务复制

事务复制的基本机制,在联机文档上也有介绍。

基本原理


 

如图,主要依靠2个代理,1.日志读取代理(log reader agent),2.分发代理(distribution agent)

其中log reader agent,负责从发布数据库上读取日志并且写入到分发数据库(distribution)中。然后distribution agent负责从distribution读取数据并且写入到订阅中。

Log Reader Agent


profiler,使用tsql模板即可。在已经有复制环境的状态下,对发布项目执行:

BEGIN TRAN

go

INSERT INTO dbo.rename_sc DEFAULT VALUES

GO 10

COMMIT

最主要的部分:

如图,Log Reader Agent使用会话55去发布库的日志上读取事务,如果发现有需要分发的,那么会调用sp_MSadd_replcmds,这个存储过程会把抓到的指令存放到dbo.MSrepl_commandsMSrepl_transactions2个表中。然后就会使用过程sp_repldone标记事务已经被复制。

 

SELECT spid,program_name FROM sys.sysprocesses WHERE spid IN( 57,55)

 

sql server中查询sys.sysprocesses 2spid 会发现program_name='Repl-LogReader-0-p1-9

也就是log reader agentsql server 上有2个会话一个负责读,一个负责写。这样Log Reader Agent的一次读取完成。

Distribution Agent


Log Reader Agent写入完之后就是有Distribution Agent 把事务应用到订阅库。

获取事务

在存储过程sys.sp_MSget_repl_commands对表dbo.MSrepl_commands读取,之后就是在订阅服务器上面运行sp_MSins命令。

仔细观察其实不难发现msrepl_command表中存的是明码,通过和sp_browsereplcmds对比就能发现,那么也就是说其实在插入MSrepl_commands的时候就已经知道了。

但是这里有个问题Agent是怎么知道要调用这个存储过程的。

 

 

 在这里会注意到有2个不同的会话在处理,一个负责读,一个负责写入,其中65负责从分发库中读取,51负责应用到订阅库

SELECT spid,program_name FROM sys.sysprocesses WHERE spid IN( 65 ,51)

修改订阅

最后会修改订阅服务器中的MSreplication_subscriptions中的一些字段,其中最终要的是timestamp,这个字段表示现在订阅已经应用到了那个事务。奇特的事情又出现,会发现有2update语句。不知道是不是为了版本兼容。

UPDATE  MSreplication_subscriptions

SET     transaction_timestamp = CAST(@P1 AS BINARY(15))

        + CAST(SUBSTRING(transaction_timestamp, 16, 1) AS BINARY(1)) ,

        "time" = @P2

WHERE   UPPER(publisher) = UPPER(@P3)

        AND publisher_db = @P4

        AND publication = @P5

        AND subscription_type = 1

        AND( SUBSTRING(transaction_timestamp, 16, 1) = 0

              OR DATALENGTH(transaction_timestamp) < 16

            )

 

UPDATE  MSreplication_subscriptions

SET     transaction_timestamp = CAST(@P1 AS BINARY(15))

        + CAST(CASE DATALENGTH(transaction_timestamp)

                 WHEN 16

                 THEN ISNULL(SUBSTRING(transaction_timestamp, 16, 1), 0)

                 ELSE 0

               END AS BINARY(1)) ,

        "time" = @P2

WHERE   UPPER(publisher) = UPPER(@P3)

        AND publisher_db = @P4

        AND publication = @P5

        AND subscription_type = 1

Distribution Agent完成一次分发。

 

目录
相关文章
|
6月前
|
SQL 关系型数据库 MySQL
(七)MySQL事务篇:ACID原则、事务隔离级别及事务机制原理剖析
众所周知,MySQL数据库的核心功能就是存储数据,通常是整个业务系统中最重要的一层,可谓是整个系统的“大本营”,因此只要MySQL存在些许隐患问题,对于整个系统而言都是致命的。
160 2
|
8月前
|
SQL 关系型数据库 MySQL
⑨【MySQL事务】事务开启、提交、回滚,事务特性ACID,脏读、幻读、不可重复读。
⑨【MySQL事务】事务开启、提交、回滚,事务特性ACID,脏读、幻读、不可重复读。
75 0
|
8月前
|
SQL 数据库 数据库管理
事务管理,事务的概念(原子性、一致性、隔离性和持久性(ACID特性))、事务的控制(BEGIN、COMMIT和ROLLBACK)
事务管理,事务的概念(原子性、一致性、隔离性和持久性(ACID特性))、事务的控制(BEGIN、COMMIT和ROLLBACK)
|
8月前
|
数据库
异步复制与同步复制结合
异步复制与同步复制结合
108 4
|
8月前
|
Java 数据库
JPA - EntityTransaction与事务
JPA - EntityTransaction与事务
77 0
|
安全 关系型数据库 MySQL
MySQL事务隔离级别:读未提交、读已提交、可重复读和串行
MySQL事务隔离级别:读未提交、读已提交、可重复读和串行
472 0
|
CDN
多主复制下处理写冲突(1)-同步与异步冲突检测及避免冲突
多主复制的最大问题:可能发生写冲突,这是必须要解决的。
153 0
|
消息中间件 JavaScript 小程序
MySQL 底层之 MVCC、回滚段、一致性读、锁定读
MySQL 底层之 MVCC、回滚段、一致性读、锁定读
|
SQL 关系型数据库 MySQL
如何使用事务
如何使用事务
如何使用事务

热门文章

最新文章

下一篇
开通oss服务