一个事务复制的bug--更新丢失

一个事务复制的bug--更新丢失 描述 === 环境：事务复制的订阅是通过快照进行的初始化 条件： Logreader 没有运行。 操作：我们向 publicaiton 添加了一个新的 Article . 此时在log reader停止期间到完成添加article之前， publication 的 article 出现了更新

一个事务复制的bug--更新丢失

描述

===

环境：事务复制的订阅是通过快照进行的初始化

条件：Logreader没有运行。

操作：我们向publicaiton添加了一个新的Article.

此时在log reader停止期间到完成添加article之前，publication的article出现了更新/删除/插入，那么这些变更都不会传递到订阅。 假设 Logreader在11:00停止，我们在12:00添加了一个新的artilce(假设瞬间完成），13：00重新启动Logreader 。那么11:00~12:00之间的更新将全部丢失。

原因

===

当publicationdatabase的article发生更新时， 会产生相应的日志，Log reader会读取这些日志信息，将他们写入到Distribution 数据库的msrepl_transactions和msrepl_commands中。具体的技术细节我会在以后的文章里介绍。

Msrepl_transactions中的每一条记录都有一个唯一标识xact_seqno，xact_seqno对应日志中的LSN。 所以可以通过xact_seqno推断出他们在publicationdatabase中的生成顺序，编号大的生成时间就晚，编号小的生成时间就早。

Distributionagent包含两个进程，reader和writer。 Reader负责从Distribution 数据库中读取数据，Writer负责将reader读取的数据写入到订阅数据库.

reader是通过sp_MSget_repl_commands来读取Distribution数据库中（读取Msrepl_transactions表和Msrepl_Commands表）的数据

下面是sp_MSget_repl_commands的参数定义

CREATE PROCEDURE sys.sp_MSget_repl_commands

(

@agent_id int,

@last_xact_seqno varbinary(16),

@get_count tinyint = 0, -- 0 = no count, 1 = cmd and tran (legacy), 2 = cmd only

@compatibility_level int = 7000000,

@subdb_version int = 0,

@read_query_size int = -1

)

这个存储过程有6个参数，在Transactionalreplication 中，只会使用前4个（并且第三个参数和第四个参数的值是固定不变的.分别为0和10000000）。下面是一个例子：