SqlServer實時數據同步到MySql

下載網站:www.SyncNavigator.CN 
 客服QQ1793040
----------------------------------------------------------

關於HKROnline SyncNavigator 註冊機價格的問題

 

 

HKROnline SyncNavigator 8.4.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.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,qty) values (@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’)