实战:sqlserver 数据实时同步到mysql

1.安装安装MysqLconnector

2.配置MysqLconnector

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

3.新建链接服务器

exec sp_addlinkedserver
 @server='jt',       --ODBC里面data source name
 @srvproduct='MysqL',    --自己随便
 @provider='MSDAsql',    --固定这个
 @datasrc=NULL,
 @location=NULL,
 @provstr='DRIVER={MysqL ODBC 5.3 ANSI Driver};SERVER=192.168.5.188;DATABASE=suzhou;UID=root;PORT=3306;',   
@catalog = NULL

exec sp_addlinkedsrvlogin
  @rmtsrvname='jt',
  @useself='false',
  @rmtuser='root',
  @rmtpassword='password';
 
 
  select * from openquery(jt,'SELECT * FROM sz ; ')
  GO
 
 

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

---4.sqlserver和MysqL新建库和表

 

create database suzhou;

create table sz(
id int not null  identity(1,1) primary key,
orderno char(20) not null,
ordertime datetime not null default getdate(),
remark varchar(200)
)
go

create table sz(
id int(11) not null,
ordertime datetime(6) not null,
remark varchar(200),
primary key (id)
) engine=innodb  default charset=utf8;

 

---5.建立回环
 --建立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',@optvalue=N'TRUE'
GO
EXEC master.dbo.sp_serveroption @server=N'loopback',@optvalue=N'false'
GO

----6.编写触发器和存储过程

----6.1 insert

--重写触发器
use suzhou
go
alter trigger tr_insert_sz on suzhou.dbo.sz
for insert
as
declare  @id   int,@orderno  char(20),@ordertime datetime,@remark  varchar(200)
select @id=id,@orderno=orderno,@ordertime=ordertime,@remark =remark from inserted;
begin
print @id
print @orderno
print @ordertime
print @remark
exec loopback.suzhou.dbo.sp_insert @id,@orderno,@ordertime,@remark
end
go

 

 

--存储过程
use suzhou
go
create PROCEDURE sp_insert(
@id   int,
@orderno  char(20),
@ordertime datetime,
@remark  varchar(200)
)
AS
BEGIN
SET NOCOUNT ON;
Insert openquery(jt,'select * from sz')(id,orderno,ordertime,remark)values(@id,@remark)
END
go

----6.2 update

--重写触发器
use suzhou
go
create trigger tr_update_sz on suzhou.dbo.sz
for update
as
declare  @orderno  char(20),@remark  varchar(200)
select @orderno=orderno,@remark =remark from inserted;
begin
exec loopback.suzhou.dbo.sp_update @orderno,@remark
end
go

 

 

--存储过程
use suzhou
go
create PROCEDURE sp_update(
@orderno  char(20),
@remark  varchar(200)
)
AS
BEGIN
SET NOCOUNT ON;
update openquery(jt,'select * from sz') set remark=@remark where orderno=@orderno
END
go

 

---update数据测试

use suzhou
go
update sz set remark='ocpyang' where orderno='a001'
go

----6.3 delete

--重写触发器
use suzhou
go
create trigger tr_delete_sz on suzhou.dbo.sz
for delete
as
declare  @orderno  char(20)
select @orderno=orderno from deleted;
begin
exec loopback.suzhou.dbo.sp_delete @orderno
end
go

 

 

--存储过程
use suzhou
go
create PROCEDURE sp_delete(
@orderno  char(20)
)
AS
BEGIN
SET NOCOUNT ON;
delete openquery(jt,'select * from sz')  where orderno=@orderno
END
go

 

---delete数据测试

use suzhou go delete from sz where orderno='a001' go