最近有个需求是要跨库进行数据同步,两个数据库分布在两台物理计算机上,自动定期同步可以通过SQL Server代理作业来实现,但是前提是需要编写一个存储过程来实现同步逻辑处理。这里的存储过程用的不是opendatasource,而是用的链接服务器来实现的。存储过程创建在IP1:192.168.0.3服务器上,需要将视图v_custom的客户信息同步到IP2:192.168.0.10服务器上的t_custom表中。逻辑是如果不存在则插入,存在则更新字段。

 1 create PROCEDURE [dbo].[p_pm_项目平台客户批量同步到报销平台](
 2     @destserver nvarchar(50),
 3     @sourceserver nvarchar(50)
 4 )
 5 AS
 6 BEGIN
 7
 8     SET NOCOUNT ON;
 9     --不存在则添加链接服务器,外部查询必须指明IP地址,例如 select * from [IP].[database].[dbo].[table]
10     if not exists (select * from sys.servers where server_id!=0  and data_source=@destserver)
11     begin
12         exec sp_addlinkedserver    @server=@destserver
13     end
14     if not exists (select * from sys.servers where server_id!=0  and data_source=@sourceserver)
15     begin
16         exec sp_addlinkedserver    @server=@sourceserver
17     end
18         begin try
19         set xact_abort on
20         begin transaction
21             --http://www.cnblogs.com/chnking/archive/2007/04/04/699891.html
22                 INSERT INTO [192.168.0.10].[dbCRM].[dbo].[t_custom] (客户ID,
23
24                                 客户名称,
25                                 客户简称,
26                                 输入码,
27                                 查询码,
28                                 地址,
29                                 录入登录名,
30                                 录入时间,
31                                 修改登录名,
32                                 修改时间,
33                                 审批状态ID,
34                                 审批状态名称,
35                                 是否审批结束,
36                                 审批操作时间,
37                                 项目管理客商编码,
38                                 序号)
39                 SELECT A.客户ID,A.客户名称,
40                                 A.客户简称,
41                                 dbo.fn_pm_GetPy(A.客户名称),
42                                 A.客户编号+','+A.客户名称+','+dbo.fn_pm_GetPy(A.客户名称)+','+A.客户简称+','+dbo.fn_pm_GetPy(A.客户简称),
43                                 A.地址,
44                                 'admin',
45                                 getdate(),
46                                 null,
47                                 null,
48                                 'D65F87A8-79C8-4D1C-812D-AE4591E056A8',
49                                 '已审批',
50                                 1,
51                                 A.审批操作时间,
52                                 A.项目管理客商编码,
53                                 0
54                 FROM   [dbPM].[dbo].[v_custom] A
55                 WHERE  A.客户ID NOT IN ( SELECT 客户ID FROM   [192.168.0.10].[dbCRM].[dbo].[t_custom]);
56
57
58
59                 ----------------------------------存在更新-----------------------------------
60                 update   A  set
61                             A.客户名称=B.客户名称,
62                             A.客户简称=B.客户简称,
63                             A.输入码=dbo.fn_pm_GetPy(B.客户名称),
64                             A.查询码=B.客户编号+','+B.客户名称+','+dbo.fn_pm_GetPy(B.客户名称)+','+B.客户简称+','+dbo.fn_pm_GetPy(B.客户简称),
65                             A.地址=B.地址,
66                             A.修改登录名='admin',
67                             A.修改时间=getdate(),
68                             A.项目管理客商编码 =B.项目管理客商编码
69                     from  [192.168.0.10].[dbCRM].[dbo].[t_custom] A,[dbPM].[dbo].[v_custom]  B
70                     where A.客户ID=B.客户ID;
71
72
73
74             commit transaction
75         end try
76         begin catch
77             select ERROR_NUMBER() as errornumber,ERROR_MESSAGE() as errormsg,ERROR_LINE() as errorline
78             rollback transaction
79         end catch
80 END

  如果没有正确配置,经常会出现 消息 7391,级别 16,状态 2,过程 xxxxx,第 XX 行 。无法执行该操作,因为链接服务器 "xxxxx" 的 OLE DB 访问接口 "SQLNCLI" 无法启动分布式事务。

  可以参照如下的配置:

具体可以参看:http://www.cnblogs.com/chnking/archive/2007/04/04/699891.html

SQL Server 跨库同步数据相关推荐

  1. sql server跨服务器修改数据,SQL Server跨数据库服务器查询和跨表更新的详细操作...

    SQL Server数据库跨数据库服务器查询和跨表更新的相关知识是本文我们主要要介绍的内容,接下来我们就通过一个实例来介绍这一过程.实例是这样的:想实现的功能很简单, 在我的本地一个表用来保存省的信息 ...

  2. SQL Server跨库查询

    跨服务器数据库查询 --连接远程/局域网数据(openrowset/openquery/opendatasource)  --1.openrowset (比较推荐这种做法) --查询示例  selec ...

  3. SQL Server 跨库查询

    1. 开启Ad Hoc Distributed Queries组件,在sql查询编辑器中执行如下语句: exec sp_configure 'show advanced options',1 reco ...

  4. SQL Server 跨域访问

    # SQL Server 跨服务器访问数据参考链接:[sp_addlinkedserver](https://msdn.microsoft.com/zh-cn/library/ms190479.asp ...

  5. C#同步SQL Server数据库中的数据--数据库同步工具[同步已有的有变化的数据]

    C#同步SQL Server数据库中的数据--数据库同步工具[同步已有的有变化的数据] 1. C#同步SQL Server数据库Schema 2. C#同步SQL Server数据库中的数据--数据库 ...

  6. sql server 触发器实时同步数据库表数据

    sql server 触发器实时同步数据库表数据 创建两个相同结构的数据库表 CREATE TABLE [dbo].[Table_1]([id] [varchar](50) NOT NULL,[nam ...

  7. SQL Server 跨版本数据迁移实践

    背景 在现代企业中,数据库是非常重要的一部分,它们存储着企业的核心数据.然而,数据库的版本和技术不断更新,企业需要及时升级和迁移数据库以保持其业务系统的可靠性和稳定性. 尽管对于某些业务系统来说,稳定 ...

  8. 干货 | RDS For SQL Server单库上云

    数据库作为核心数据的重要存储,很多时候都会面临数据迁移的需求,例如:业务从本地迁移上云.数据中心故障需要切换至灾备中心.混合云或多云部署下的数据同步.流量突增导致数据库性能瓶颈需要拆分-- 本文将会一 ...

  9. 转载-SQL Server各种导入导出数据方式的比较

    注:本文转载自 http://blog.csdn.net/nokiaguy/article/details/4684822 当我们建立一个数据库时,并且想将分散在各处的不同类型的数据库分类汇总在这个新 ...

最新文章

  1. 程序员从初级到中级10个秘诀 【转载】
  2. The difference between synchronous and asynchronous code in JavaScript
  3. Windows Server 2012体验之卸载辅助域控制器
  4. string、stringbuilder、stringbuffer区别
  5. 多元样条函数及其应用_B样条算法(B-spline)
  6. RHEL7.0手动安装
  7. (C/C++) Link List - C 語言版本
  8. android loginDemo +WebService用户登录验证
  9. 分组求和并排序python_python 实现分组求和与分组累加求和代码
  10. 如何快速调出软键盘_天生我材必有用 | 如何快速的计算和调用防火阀、调节阀、铝合金风口等材料价格...
  11. 学习SQL Server这一篇就够了
  12. 自顶向下语法分析的作业
  13. 开源路由器-OpenWRT/梅林
  14. Prometheus 系列开篇:为什么要学 Prometheus ?
  15. win10的局域网如何设为专用网络
  16. IPv4下,划分子网,构造超网(CIDR)
  17. Android系统功耗优化之CPU - CPU功耗和频率的关系
  18. R3LIVE:A Robust, Real-time, RGB-colored, LiDAR-Inertial-Visual tightly-coupled state Estimation 运行记录
  19. c语言奇怪的分式11,蓝桥杯-奇怪的分式-java
  20. [转载] 蝴蝶上如何做种候选及发布

热门文章

  1. ITK:二进制和两个图像
  2. DCMTK:I2DBmpSource类的测试程序
  3. VTK:Video之OggTheora
  4. VTK:可视化之LabeledMesh
  5. QML从右到左的用户界面
  6. Qt Creator缩进文字或代码
  7. C++实现tree234树(附完整源码)
  8. C++ sizeof()
  9. QT的QBluetoothDeviceDiscoveryAgent类的使用
  10. c++类与类的聚合(Aggregation)关系