步步为营99-不同数据库数据实时同步

时间：2017-12-11 11:30:55 阅读：209 评论：0 收藏：0 [点我收藏+]

标签：中间 clu null dex rate play 解决 compute row

说明:

项目主数据中间表同步
项目主数据现在做了3张新的中间表，我们的任务就是做个windows服务从那3张中间表拉取部分字段数据插入我们老的中间表

技术分享图片

解决方案:

先从代码里连接中间表数据库，利用c# sqlserver类里的批量插入方法统一插入到本地的临时表，然后在存储过程里把临时表数据处理到目的表。

1: 先写一个存储过程:实现临时表[dbo].[Temp_MDM_Corporate]和中间表[dbo].[Z_MDM_Corporate]比对.

　　如果中间表中的数据和临时表一致,不进行操作;

　　如果不一致:中间表中没有数据,则插入,有则更新

　　1.1 创建数据表　　

CREATE TABLE [dbo].[Temp_MDM_Corporate](    
    [CorporateCode] [varchar](50) NOT NULL,
    [CorporateName] [nvarchar](50) NULL,
    [Status] [nvarchar](20) NULL,
    [UpdateTime] [datetime] NULL,
    [F1] [nvarchar](200) NULL,
    [F2] [nvarchar](200) NULL,
    [F3] [nvarchar](200) NULL,
    [F4] [nvarchar](200) NULL,
    [F5] [nvarchar](200) NULL,
 CONSTRAINT [PK_Temp_MDM_Corporate] PRIMARY KEY CLUSTERED     
(    
    [CorporateCode] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]    
) ON [PRIMARY]    
    
GO    


CREATE TABLE [dbo].[Z_MDM_Corporate](    
    [CorporateCode] [varchar](50) NOT NULL,
    [CorporateName] [nvarchar](50) NULL,
    [Status] [nvarchar](20) NULL,
    [UpdateTime] [datetime] NULL,
    [F1] [nvarchar](200) NULL,
    [F2] [nvarchar](200) NULL,
    [F3] [nvarchar](200) NULL,
    [F4] [nvarchar](200) NULL,
    [F5] [nvarchar](200) NULL,
 CONSTRAINT [PK_Z_MDM_Corporate] PRIMARY KEY CLUSTERED     
(    
    [CorporateCode] ASC
)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]    
) ON [PRIMARY]    
    
GO

View Code

1.2 创建存储过程

CREATE PROCEDURE sp_UpdateZ_MDM_Corporate
 
AS
BEGIN
       MERGE INTO Z_MDM_Corporate AS Z
       USING Temp_MDM_Corporate AS T
       ON Z.CorporateCode=T.CorporateCode
       WHEN MATCHED
       THEN UPDATE SET Z.CorporateName=T.CorporateName, Z.Status = T.Status,Z.UpdateTime=t.UpdateTime
       WHEN NOT MATCHED
       THEN INSERT  VALUES (T.CorporateCode,T.CorporateName,T.Status,T.UpdateTime,T.F1,T.F2,T.F3,T.F4,T.F5);
 
    END

View Code

　　1.3 说到这随便提一下,我们可以在数据库中创建一个job,每个一段时间跑一下存储过程.

　　1.3.1 技术分享图片