使用SSIS創建同步數據庫數據任務

2024-07-21 02:51:02

字體：大中小

來源：轉載

供稿：網友

使用SSIS創建同步數據庫數據任務

國外相關的文章:http://blog.dxuf.com/sql-tutorial/use-ssis-to-create-the-synchronization-database-data-task.html

SSIS（SQL Server Integration Services）是用于生成企業級數據集成和數據轉換解決方案的平臺。使用 Integration Services 可解決復雜的業務問題，具體表現為：復制或下載文件，發送電子郵件以響應事件，更新數據倉庫，清除和挖掘數據以及管理 SQL Server 對象和數據。這些包可以獨立使用，也可以與其他包一起使用以滿足復雜的業務需求。Integration Services 可以提取和轉換來自多種源（如 xml 數據文件、平面文件和關系數據源）的數據，然后將這些數據加載到一個或多個目標。（摘自MSDN，更多詳細信息可參考：http://technet.microsoft.com/zh-cn/library/ms141026(v=sql.105).aspx）

下面我使用SSIS來演示一個實際例子。比如我有一個數據庫，出于備份數據或者其它的目的，會定期的對這個數據庫的數據遷移到其它的數據庫去。遷移的時候，有些新增的字段會被插入備份數據庫，而有些被修改過的字段也會在備份數據庫被修改。現在我們就用SSIS來完成這項任務。

首先在我源數據庫db_source和目標數據庫db_destination中運行以下SQL創建好需要的表，就以這一個表test_1來進行示范。

CREATE TABLE [dbo].[test_1](    [Id] [int] IDENTITY(1,1) NOT NULL PRimary key,    [Name] [varchar](50) NULL,    [Age] [int] NULL)

建好表好在源數據表中可以隨便加幾條記錄，目標數據庫暫時留空。

現在我們打開VS，創建一個Intergration Services Project。（注意：如果SQL Server 裝的是Express版的話是沒有這個項目工程模板的）

創建好工程后，在Control Flow這個Tab下拖入一個Data Flow Task，如下圖：

雙擊這個Data Flow Task，我們就會進入Data Flow這個Tab標簽中。

然后我們在左邊工具欄里找到OLE DB Source，繼續拖兩個OLE DB Source出來。分別給它們命名為Source DB和Destination DB。

將數據源拖出來后，雙擊它，可以對它進行一些設置，主要就是鏈接數據庫及選擇你要進行遷移的表或者視圖等設置，這里我就不詳細說明了。注意一點的是就像上圖所示，如果一個圖形上出現一個紅X的話說明設置有錯誤。

再來就是拖兩個Sort及一個Merge Join出來，將之前的數據源箭頭分別指向兩個Sort，最后兩個Sort出來的數據同時輸入Merge Join中。

分別雙擊兩個Sort，鉤選表中的ID，對ID這個字段進行一次排序。因為Merge Join這個流程要求輸入的數據是已排序好的。這個排序也可以直接在數據源中對它們的輸出字段設置SortKeyPosition這個屬性來排序。（詳見：http://msdn.microsoft.com/zh-cn/library/ms137653.aspx）

這里我們第一次從Sort拉箭頭到Merge Join的時候，會讓我們選擇這個輸入的數據是作為左輸入還是右輸入，我們按照圖示的那樣，左邊的作為左輸入，右邊的作為右輸入。然后我們雙擊Merge Join，按照如下圖所示設置：

這里打鉤的是這個流程之后輸出的數據，Join Type需要選擇為Left outer join，因為左邊是我們的原始數據表，右邊是我們備份的表，右表可以看成是一個左表的一個子集，如果左表有的數據，右表沒有的，那些就是需要新插入備份數據庫的數據。

現在我們需要一個分支，即新的數據需要插入備份數據庫中，而已有的數據需要更新為新的值。我們從工具欄中拖入一個Conditional Split來進行這樣的分支處理。我們將Merge Sort中的輸出指向Conditional Split，然后雙擊Conditional Split，如下圖所示設置（注意條件一個是ISNULL，一個是非ISNULL）。