首页 技术 正文
技术 2022年11月23日
0 收藏 751 点赞 2,270 浏览 1976 个字

根据之前的一些想法,如果有A,B 两个数据库, 如果把A 用户通过界面产生的更新或者插入修改,操作的数据同步更新到B 库中,如果允许延时2分钟以内

想法一: 通过创建触发器 把变更的数据和对应的表名称统一存储到某个特定的表,然后通过程序获取转换成sql 更新B数据库中的表,本文主要说明使用该方法

想法二: 通过CDC 记录变更的内容, 园内搜索:  SQL Server 变更数据捕获(CDC)监控表数据  即可 。

以下是测试:

drop  database  T_Mytestcreate  database  T_Mytest -- 创建修改表
use T_Mytest
create table Mytest
(
id int null ,
name nvarchar (20) null ,
OwndStore int null )-- 创建记录修改了那个数据库,那张表的记录
create table testdatabaseLog
(
ID int identity not null ,
State int null ,-- 同步状态 0表示初始数据没有同步 ,1 表示已经同步需要插入的文件数据 ChangeTableName nvarchar (25) null , -- 更新了哪个数据库表
createdatetime datetime null ,
ActionType int null , -- 1插入 2更新 3 删除
ActionName nvarchar(20) null ,
Content nvarchar (max) null , -- 更新后的内容
FromStore int null , -- 该数据来自那个门店数据库 标识
ToStore int null , -- 同步到那个门店进行处理
)
go

  

二  创建重要的触发器语句 , 可以应用到所有需要同步的表中,只需要在创建的时候增加触发器即可,

不需要修改里面的内容,只需要修改触发器名称 和应该到哪张表即可

CREATE TRIGGER [dbo].[itrg_triggerTest]  ON [dbo].[Mytest]
after insert , update ,delete
AS
set nocount on
--查询该触发器触发的表
--SELECT @@PROCID, OBJECT_NAME( @@PROCID )
declare @tableName nvarchar(25) ;--宣告变量
DECLARE @D BIT = 0
DECLARE @I BIT = 0 declare @content nvarchar(max) ;
declare @actiontype int ;
declare @actionName nvarchar(15) ;
IF EXISTS(SELECT TOP 1 1 FROM DELETED)
begin
SET @D = 1
end IF EXISTS(SELECT TOP 1 1 FROM INSERTED)
begin
SET @I = 1
end IF @I = 1 AND @D = 0
begin
set @actiontype=1 ;
set @actionName='Insert'
--select N'插入'+'insert into '
select @content= (select * from inserted for xml path)+'' -- select * from inserted for xml path(@tableName),root('insert')
end
else IF @I = 1 AND @D = 1
begin
set @actiontype=2 ;
set @actionName='Update' ;
select @content= (select * from inserted for xml path)+'' ;end
else
begin set @actiontype=3 ;
set @actionName='Delete'
--select N'删除'+'insert into '
select @content= (select * from deleted for xml path)+'' ;
end if ( @content is not null )
begin SELECT @tableName =OBJECT_SCHEMA_NAME( parent_id ) + '.' + OBJECT_NAME( parent_id ) FROM sys.triggers WHERE object_id = @@PROCIDinsert into testdatabaseLog
(
ChangeTableName ,
createdatetime ,
ActionType ,
ActionName ,
content,FromStore)
values ( @tableName ,GETDATE() , @actiontype, @actionName ,@content, 1) ;
end GO

  

-- 测试数据
insert into Mytest values (1,'苹果',1)
insert into Mytest values (2,'雪梨',1)
insert into Mytest values (3,'香蕉',1)

  

得到结果 测试

捕获mssqlservice 修改表后的数据,统一存储到特定的表中,之后通过代码同步两个库的数据

相关推荐
python开发_常用的python模块及安装方法
adodb:我们领导推荐的数据库连接组件bsddb3:BerkeleyDB的连接组件Cheetah-1.0:我比较喜欢这个版本的cheeta…
日期:2022-11-24 点赞:878 阅读:8,999
Educational Codeforces Round 11 C. Hard Process 二分
C. Hard Process题目连接:http://www.codeforces.com/contest/660/problem/CDes…
日期:2022-11-24 点赞:807 阅读:5,511
下载Ubuntn 17.04 内核源代码
zengkefu@server1:/usr/src$ uname -aLinux server1 4.10.0-19-generic #21…
日期:2022-11-24 点赞:569 阅读:6,357
可用Active Desktop Calendar V7.86 注册码序列号
可用Active Desktop Calendar V7.86 注册码序列号Name: www.greendown.cn Code: &nb…
日期:2022-11-24 点赞:733 阅读:6,140
Android调用系统相机、自定义相机、处理大图片
Android调用系统相机和自定义相机实例本博文主要是介绍了android上使用相机进行拍照并显示的两种方式,并且由于涉及到要把拍到的照片显…
日期:2022-11-24 点赞:512 阅读:7,770
Struts的使用
一、Struts2的获取  Struts的官方网站为:http://struts.apache.org/  下载完Struts2的jar包,…
日期:2022-11-24 点赞:671 阅读:4,848