码迷,mamicode.com
首页 > 数据库 > 详细

ODBC数据管理器 SqlServer实时数据同步到MySql

时间:2018-05-12 12:41:05      阅读:242      评论:0      收藏:0      [点我收藏+]

标签:pad   cursor   add   链接   nts   rom   ack   server   https   

---安装安装mysqlconnector
/*
配置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.29.33;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
EXE Cmaster.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,qtyvalues (@id,@qty);
                SET NOCOUNT OFF
END

---update
CREATE TRIGGERT R_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  into  penquery(MySqll_Aggregation,‘select * from bi.tb‘) select*from[FSLogin].[dbo].[tb]with(nolock)


---从mysql同步表结构及数据到sqlserver上
select into  [SqlServerDBName].dbo.MYTest  from   openquery(localmysql,‘select * from mysqldbname.weibosession‘)

ODBC数据管理器 SqlServer实时数据同步到MySql

标签:pad   cursor   add   链接   nts   rom   ack   server   https   

原文地址:https://www.cnblogs.com/dullbaby/p/9028256.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!