Transactional replication（事務復制）詳解之若何跳過一個事務。本站提示廣大學習愛好者：（Transactional replication（事務復制）詳解之若何跳過一個事務）文章只能為提供參考，不一定能成為您想要的結果。以下是Transactional replication（事務復制）詳解之若何跳過一個事務正文
在transactional replication, 常常會碰到數據同步延遲的情形。有時刻這些延遲是因為在publication中履行了一個更新，例如update ta set col=? Where ?，這個更新包括偉大的數據量。在subscription端，這個更新會分化成多條敕令（默許情形下每一個數據行一個敕令），運用到subscription上。 不得已的情形下，我們須要跳過這個年夜的事務，讓replication持續運轉下去。
如今引見一下transactional replication的一些道理和詳細的辦法
當publication database的article產生更新時， 會發生響應的日記，Log reader會讀取這些日記信息，將他們寫入到Distribution 數據庫的msrepl_transactions和msrepl_commands中。
Msrepl_transactions中的每筆記錄都有一個獨一標識xact_seqno，xact_seqno對應日記中的LSN。 所以可以經由過程xact_seqno揣摸出他們在publication database中的生成次序，編號年夜的生成時光就晚，編號小的生成時光就早。
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個參數，在Transactional replication 中，只會應用前4個（而且第三個參數和第四個參數的值是固定不變的.分離為0和10000000）。上面是一個例子：
execsp_MSget_repl_commands 46,0x0010630F000002A900EA00000000,0,10000000
@agent_id表現Distributionagentid，每一個定閱都邑有一個零丁的Distributionagent來處置數據。 帶入@agent_id後，便可以找到定閱對應的publication 和一切的article。
@last_xact_seqno 表現上一次傳遞到定閱的LSN。
年夜致邏輯是：Reader讀取subscription database的MSreplication_subscriptions表的transaction_timestamp列，取得更新的上一次LSN編號，然後讀取分發數據庫中LSN年夜於這個編號的數據。 Writer將讀取到的數據寫入定閱，並更新MSreplication_subscriptions表的transaction_timestamp列。然後Reader會持續用新的LSN來讀取後續的數據，再傳遞給Writer，如斯來去。
假如我們手工更新transaction_timestamp列,將這個值設置為以後正在履行的年夜事務的LSN，那末distribution agent就會不讀取這個年夜事務，而是將其跳過了。
上面以一個實例演示一下
情況以下
Publisher: SQL108W2K8R21
Distributor: SQL108W2K8R22
Subscriber: SQL108W2K8R23
圖中高亮的publication中包括3個aritcles，ta,tb,tc
個中ta包括18,218,200萬數據，然後我們停止了一下操作
在11：00停止了更新語句，
update ta set c=-11
後續陸續對表ta,tb,tc履行一些拔出操作
insert tb values(0,0)
insert tc values(0,0)
以後我們啟動replication monitor ，發明有很年夜的延遲，distribution agent一向在傳遞a）操作發生的數據
在subscription database中履行上面的語句,獲得以後最新記載的事務編號
declare @publisher sysname declare @publicationDB sysname declare @publication sysname set @publisher='SQL108W2K8R22' set @publicationDB='pubdb' set @publication='pubdbtest2' select transaction_timestamp From MSreplication_subscriptions where publisher=@publisher and publisher_db=@publicationDB and publication=@publication
在我的情況中，事務編號為0x0000014900004E9A0004000000000000
前往到distribution database，履行上面的語句，獲得緊跟在年夜事務前面的事務編號. 請將參數調換成您現實情況中的數據。（請留意，假如履行以下語句碰到機能成績，請將參數直代替換成值）
declare @publisher sysname
declare @publicationDB sysname
declare @publication sysname
declare @transaction_timestamp [varbinary](16)
set @publisher='SQL108W2K8R21'
set @publicationDB='publicationdb2'
set @publication='pubtest'
set @transaction_timestamp= 0x0000014900004E9A0004000000000000
select top 1 xact_seqno from MSrepl_commands with (nolock) where xact_seqno>@transaction_timestamp and
article_id in (
select article_id From MSarticles a inner join MSpublications p on a.publication_id=p.publication_id and a.publisher_id=p.publisher_id and a.publisher_db=p.publisher_db
inner join sys.servers s on s.server_id=p.publisher_id
where p.publication=@publication and p.publisher_db=@publicationDB and s.name=@publisher
)
and publisher_database_id =(
select id From MSpublisher_databases pd inner join MSpublications p on pd.publisher_id=p.publisher_id
inner join sys.servers s on pd.publisher_id=s.server_id and pd.publisher_db=p.publisher_db
where s.name=@publisher and p.publication=@publication and pd.publisher_db=@publicationDB
)
Order by xact_seqno
在我的情況中，事務編號為0x0000018C000001000171
在subscription database中履行上面的語句，跳過年夜的事務。請將參數調換成您現實情況中的數據
declare @publisher sysname declare @publicationDB sysname declare @publication sysname declare @transaction_timestamp [varbinary](16) set @publisher='SQL108W2K8R22' set @publicationDB='pubdb' set @publication='pubdbtest2' set @transaction_timestamp= 0x0000018C000001000171 update MSreplication_subscriptions set transaction_timestamp=@transaction_timestamp where publisher=@publisher and publisher_db=@publicationDB and publication=@publication
履行完成後開啟distribution agent job便可。
接上去您就會發明，事務曾經勝利跳過，ta在定閱端不會被更新，後續的更新會慢慢傳遞到定閱，延遲消逝。
