快盘下载:好资源、好软件、快快下载吧!

快盘排行|快盘最新

当前位置:首页软件教程电脑软件教程 → SqlServer实时数据同步到mysql

SqlServer实时数据同步到mysql

时间:2022-04-28 18:50:20人气:作者:快盘下载我要评论

因为业务需要要要实现 sqlserver和 mysql 异构数据库 数据同步;起先一点思路都没有,于是到网上一顿好找;

最后找到了2种解决方案:

1、利用第三方工具实现;

2、利用ODBC实现;

第一种测试结果不理想,弊端是:1、不稳定 2、出了问题不易定位3、不够智能

最后采用了第二种ODBC来实现,运行了快1年没有出过问题;今天共享出来以帮助其他朋友;

---安装安装mysqlconnector
http://www.mysql.com/products/connector/

配置mysqlconnector

ODBC数据管理器->系统DSN->添加->mysql ODBC 5.3 ANSI driver->填入data source name如jt,mysql的ip、用户名、密码即可

--新建链接服务器

exec sp_addlinkedserver
@server='MySqll_Aggregation' , --ODBC里面data source name
@srvproduct='MySql' , --自己随便
@provider='MSDASQL' , --固定这个
@datasrc=NULL,
@location=NULL,
@provstr='DRIVER={MySQL ODBC 5.3 ANSI Driver};SERVER=172.17.22.3;DATABASE=bi;UID=zhaowenzhong;PORT=3306;',

@catalog = NULL


---创建连接mysql数据库的账号及密码

exec sp_addlinkedsrvlogin
@rmtsrvname='MySqll_Aggregation' ,----ODBC里面data source name
@useself='false' ,

@rmtuser='zhaowenzhong' ,---mysql账号
@rmtpassword='mysqldba@2015' ;--mysql账号其密码


---测试是否可以访问mysql数据库中的表

select * from openquery(MySqll_Aggregation,'SELECT * FROM tb; ')


-----建立允许远程访问连接操作

USE [master]
GO

EXEC master .dbo. sp_serveroption @server =N'MySqll_Aggregation' , @optname= N'rpc out', @optvalue=N'TRUE'
GO
EXEC master .dbo. sp_serveroption @server =N'MySqll_Aggregation' , @optname= N'remote proc transaction promotion', @optvalue =N'false'
GO


--建立LOOPBACK 服务器链接

EXEC sp_addlinkedserver @server = N'loopback' , @srvproduct = N' ' , @provider = N'SQLNCLI',
@datasrc = @@SERVERNAME
go


--设置服务器链接选项,阻止SQL Server 由于远过程调用而将本地事务提升为分布事务(重点)

USE [master]
GO
EXEC master .dbo. sp_serveroption @server =N'loopback', @optname= N'rpc out', @optvalue=N'TRUE'
GO
EXEC master .dbo. sp_serveroption @server =N'loopback', @optname= N'remote proc transaction promotion' , @optvalue=N'false'
GO


---编写触发器和存储过程
--insert

CREATE TRIGGER TR_INSERT_TB ON DB_TY2015 .DBO. TB
FOR INSERT
AS
DECLARE @ID INT,
                                 @QTY INT
                                 SELECT @ID =ID, @QTY=QTY FROM INSERTED;
                                 BEGIN
                                                 EXEC loopback .db_ty2015. dbo.sp_insert @id, @qty;
                                 END
CREATE PROCEDURE SP_INSERT
@ID INT ,
@QTY INT
AS
BEGIN
                 SET NOCOUNT ON
                                 INSERT OPENQUERY (db_ty2015, 'select * from tb')(id ,qty) values(@id ,@qty);
                 SET NOCOUNT OFF
END


---update

CREATE TRIGGER TR_UPDATE_TB ON DB_TY2015 .DBO. TB
FOR UPDATE
AS
DECLARE @ID INT, @QTY INT
SELECT @ID =ID, @QTY=QTY FROM INSERTED;
BEGIN
                 EXEC loopback .db_ty2015. dbo.sp_update @id, @qty;
END
 
CREATE PROCEDURE SP_UPDATE
@ID INT ,
@QTY INT
AS
BEGIN
                 SET NOCOUNT ON
                                 UPDATE OPENQUERY (db_ty2015, 'select * from tb') set qty =@qty where id =@id
                 SET NOCOUNT OFF
END


--delete

CREATE TRIGGER TR_DELETE_TB ON DB_TY2015 .DBO. TB
FOR DELETE
AS
 
                 DECLARE @ID INT
                 SELECT @ID =ID FROM DELETED ;
BEGIN
                 EXEC loopback .db_ty2015. dbo.sp_DELETE @id;
END
 
CREATE PROCEDURE SP_DELETE
@ID INT
AS
BEGIN
                 SET NOCOUNT ON
                                 DELETE OPENQUERY (db_ty2015, 'select * from tb') where id =@id
                 SET NOCOUNT OFF
END


-------初始化数据     表已存在的情况

insert openquery (MySqll_Aggregation, 'select * from bi.tb')  select * from [FSLogin] .[dbo]. [tb] with(nolock )


---从mysql同步表结构及数据到sqlserver上(与本案例无关)

select * into [SqlServerDBName].dbo .tb from openquery (localmysql, 'select * from mysqldbname.weibosession')


相关文章

  • 一步步带你设计MySQL索引数据结构

    一步步带你设计MySQL索引数据结构,想想我们生活中的例子,比如新华字典,我们有一个目录,目录根据拼音排序,内容包含了汉字位于字典中具体的的页码。聪明的你肯定也想到了,我们也可以借鉴这种思想,建立一个MySQL的目录,叫做“索引”。...
  • 影刀连接Mysql数据库

    影刀连接Mysql数据库,影刀配置连接mysql数据库基础版...

网友评论

快盘下载暂未开通留言功能。

关于我们| 广告联络| 联系我们| 网站帮助| 免责声明| 软件发布

Copyright 2019-2029 【快快下载吧】 版权所有 快快下载吧 | 豫ICP备10006759号公安备案:41010502004165

声明: 快快下载吧上的所有软件和资料来源于互联网,仅供学习和研究使用,请测试后自行销毁,如有侵犯你版权的,请来信指出,本站将立即改正。