国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 數據庫 > SQL Server > 正文

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

2024-08-31 00:57:08
字體:
來源:轉載
供稿:網友
這些包可以獨立使用,也可以與其他包一起使用以滿足復雜的業務需求。Integration Services 可以提取和轉換來自多種源(如 XML 數據文件、平面文件和關系數據源)的數據,然后將這些數據加載到一個或多個目標。(摘自MSDN,更多詳細信息可參考:(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版的話是沒有這個項目工程模板的)

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

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

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

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

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

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

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

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

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

分別雙擊兩個Sort,鉤選表中的ID,對ID這個字段進行一次排序。因為Merge Join這個流程要求輸入的數據是已排序好的。這個排序也可以直接在數據源中對它們的輸出字段設置SortKeyPosition這個屬性來排序。(詳見:)

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

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

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

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

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

這時它們的輸入值就被分成兩種條件輸出,最后我們再拖入一個OLE DB Destination來插入數據和一個OLE DB Command來更新數據庫,最終流程如下圖:

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

雙擊設置OLE DB Destionation,選擇好數據導入的目標數據庫中的表,這里需要注意的就是要鉤選Keep identity這個選項,因為我創建表的時候對ID字段使用了自增屬性。

雙擊設置OLE DB Command,首先在Connection Managers這個Tab中選擇好鏈接對象,然后在Component Properties這個選項卡中,設置你的SqlCommand屬性。如下圖:

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

這里的參數值都是用?號來代替,之后在Column Mappings這個Tab中設置代替值實際代替的列,如下圖:

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

至此,任務就創建完畢了,沒有編寫任何代碼,直接拖拉完成了。現在可以直接在VS中按F5運行看下效果,我們的目標數據表將插入源數據表中的值。然后我們修改一下原數據表,再來運行一下上面這個任務,就可以在目標數據庫中看到更改了。

那么如何去定時完成任務哩?這里可以用SQL Server Agent去調用上面我們寫好的包, 或者在Windows計劃任務中使用DTExec.exe去執行上面的任務。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 洞头县| 安康市| 广元市| 桐梓县| 阳山县| 从化市| 开原市| 江西省| 仁寿县| 榆树市| 乡城县| 宁海县| 洪洞县| 邛崃市| 舒城县| 西昌市| 满洲里市| 黎川县| 延川县| 历史| 吐鲁番市| 阿拉尔市| 泰安市| 海安县| 隆安县| 涡阳县| 阿图什市| 南木林县| 元氏县| 砚山县| 宕昌县| 桦甸市| 桓台县| 凤冈县| 洛隆县| 德保县| 赤城县| 正镶白旗| 柞水县| 财经| 东方市|