位置: 编程技术 - 正文

Transactional replication(事务复制)详解之如何跳过一个事务

编辑:rootadmin

推荐整理分享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的参数定义

这个存储过程有6个参数,在Transactional replication 中,只会使用前4个(并且第三个参数和第四个参数的值是固定不变的.分别为0和)。下面是一个例子:

execsp_MSget_repl_commands ,0xFAEA,0,

@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: SQLW2K8R

Distributor: SQLW2K8R

Transactional replication(事务复制)详解之如何跳过一个事务

Subscriber: SQLW2K8R

图中高亮的publication中包含3个aritcles,ta,tb,tc

其中ta包含,,万数据,然后我们进行了一下操作

在:进行了更新语句,

update ta set c=-

后续陆续对表ta,tb,tc执行一些插入操作

insert tb values(0,0)

insert tc values(0,0)

之后我们启动replication monitor ,发现有很大的延迟,distribution agent一直在传递a)操作产生的数据

在subscription database中执行下面的语句,得到当前最新记录的事务编号

在我的环境中,事务编号为0xE9A

返回到distribution database,执行下面的语句,得到紧跟在大事务后面的事务编号. 请将参数替换成您实际环境中的数据。(请注意,如果执行下列语句遇到性能问题,请将参数直接替换成值)

在我的环境中,事务编号为0xC

在subscription database中执行下面的语句,跳过大的事务。请将参数替换成您实际环境中的数据

执行完成后开启distribution agent job即可。

接下来您就会发现,事务已经成功跳过,ta在订阅端不会被更新,后续的更新会逐步传递到订阅,延迟消失。

SQL语句中含有乘号报错的处理办法 在ADO中,我们需要在SQL语句中使用乘法运算,可是添加'*'以后执行程序总是会出错,这是因为‘*'与sql中的‘*'关键字重合了,所以编译会出错。解决办

SQL SERVER先判断视图是否存在然后再创建视图的语句 如果我们的语句为:IFNOTEXISTS(SELECT1FROMsys.viewsWHEREname='Report_IndividualTicket')BEGINcreateviewReport_IndividualTicketasSELECTTicket.TicketNumber,Ticket.TicketID,GisProcess.StageName,Co

sql中循环处理当前行数据和上一行数据相加减 以下事例,使用游标循环表#temptable中数据,然后让当前行和上一行中的argument1相加存放到当前行的argument2中,比较简单。--droptable#temptablecreatetable#temptab

标签: Transactional replication(事务复制)详解之如何跳过一个事务

本文链接地址:https://www.jiuchutong.com/biancheng/320315.html 转载请保留说明!

上一篇:SQL SERVER中关于exists 和 in的简单分析

下一篇:SQL语句中含有乘号报错的处理办法(sql乘函数)

  • 预付账款可以开发票吗
  • 交通费中的高速费怎么算
  • 进项3个点销项13个点,增值税
  • 可转债中签后怎么操作卖出
  • 备用金可以不要发票吗
  • 销售票据和发票的区别是什么?
  • 计提坏账准备为什么要加借方
  • 增值税销项税如何进行处理,有哪些种情况
  • 企业厂房整改应该计入什么科目?
  • 国税怎么查缴税明细
  • 关于住宿费增值税专发票抵扣问题
  • 公司租车费用会计分录
  • 购买方纳税人识别号是什么意思
  • 增值税电子普通发票怎么下载
  • 资产负债率70%说明长期偿债能力
  • 分期付款购买商品
  • 企业报税表
  • 个体户财务章必须刻吗
  • 五月份和六月份都有什么节日
  • 小规模纳税人印花税怎样计算
  • 生产企业的免抵退纳税申报,在财务做销售收入账务后
  • 管理费用金额多做了,如何减少
  • 交通费,通讯费均按照上级行标准领取
  • 应收票据借贷方核算什么内容
  • 研发费加计扣除申报表怎么填
  • 多交增值税可以退吗
  • 电脑网页播放视频只有声音没有画面
  • win7为什么还有人用
  • 注销公司如何注销
  • PHP:oci_get_implicit_resultset()的用法_Oracle函数
  • 资金占用利息会计处理
  • 长期借款的账务处理怎么做分录
  • 没有购入发票可以开出发票
  • 凯丽温泉可以做spa
  • 加里西亚省
  • 存货跌价准备的分录
  • 职工教育经费可以以后年度结转吗
  • ms 高级应用
  • 股权转让完税证明要多少时间
  • 工具tj
  • 远程调试时,gdbserver运行在调试机
  • python字符串多行
  • 劳务费如何支付
  • 修改公司章程注意事项
  • 公司的财务报表能看出什么
  • 人工费按照考虑管理费和利润吗
  • 工程施工预付款20%的规定
  • 建筑业成本需要摊销吗
  • 固定资产原值和净值在报表哪里看
  • 高铁票可以抵扣的进项
  • 房地产项目公司组织架构
  • 有支出没有发票应怎么整改
  • 长期待摊费用未摊销完一次性处理怎么走
  • 委托收款背书和质押背书都属于转让背书
  • 其他应收款为负数正常吗
  • 个人独资企业税收政策2023规定
  • 展位费按多少税率
  • 缴纳工会筹备金应该记什么科目
  • sql server数据库查询语句
  • linux转移文件代码
  • win10周年更新版是什么意思
  • freebsd怎么样
  • 查找linux
  • win7电脑磁盘突然不见了怎么办
  • perl处理特殊符号
  • bootstrap导航都有哪些
  • js中正则表达式语法
  • excel的基本数据类型
  • 清理服务器c盘
  • javascriptj
  • shell 非
  • unauthorizedAccessException
  • js左值
  • [置顶] Deniz Saypinar
  • Python出现keyerror
  • python 数据类型
  • 工会经费范围税率是多少
  • 年应税销售额超过小规模纳税人标准的企业
  • 企业所得税零申报
  • 国家个人所得税征收标准
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设