問題描述 :

當(dāng)你把數(shù)據(jù)從其他數(shù)據(jù)庫 , 或者是文本文件之類的其他數(shù)據(jù)源導(dǎo)入到目的數(shù)據(jù)庫時 , 有時希望在導(dǎo)入的處理中 , 能夠?qū)崿F(xiàn) " 數(shù)據(jù)存在時更新 , 不存在時導(dǎo)入 "

在之前 , 一般是通過導(dǎo)入臨時表 , 然后再判斷處理導(dǎo)入正式表的 , 在 SQL Server 2005 中 , SSIS 可以在導(dǎo)入處理時直接完成這種處理 .

1. 準備測試環(huán)境

-- 1. 在數(shù)據(jù)庫中創(chuàng)建下面的對象

USE tempdb

GO

CREATE TABLE dbo.tb (

id int PRIMARY KEY ,

name nvarchar ( 128 ))

GO

-- 2. 準備兩個文本文件 , 放在 d:\test 目錄下 , 文件的內(nèi)容如下

t1 . txt

id name

1 張三

2 李四

t2 . txt

id name

1 張三君

3 李林

4 阿聯(lián)酋

2. 創(chuàng)建新的 Integration Services 項目（創(chuàng)建 SSIS 包）

? 在“開始”菜單中，依次指向“所有程序”、“ Microsoft SQL Server <chmetcnv w:st="on" tcsc="0" numbertype="1" negative="False" hasspace="False" sourcevalue="2005" unitname="”"><font face="Times New Roman">2005</font><span lang="EN-US" style="FONT-FAMILY: 宋體; mso-ascii-font-family: 'Times New Roman'; mso-hansi-font-family: 'Times New Roman'"><span lang="EN-US">”</span></span></chmetcnv> ，再單擊 SQL Server Business Intelligence Development Studio 。

? 在“文件”菜單中，指向“新建”，再單擊“項目”，以創(chuàng)建一個新的 Integration Services 項目。

? 在“新建項目”對話框的“模板”窗格中，選擇“ Integration Services 項目”。

? 在“名稱”框中，將默認名稱更改為 SSIS Tutorial 。或者，清除“創(chuàng)建解決方案的目錄”復(fù)選框。

? 接受默認位置，或單擊“瀏覽”，以瀏覽并找到要使用的文件夾。

? 在“項目位置”對話框中，單擊文件夾，再單擊“打開”。

? 單擊“確定”。

? 默認情況下，將創(chuàng)建一個名為 “ 新建包 .dtsx “ 的空包，并將該包添加到項目中。

? 在解決方案資源管理器工具欄中，右鍵單擊 Package.dtsx ，再單擊“重命名”，將默認包重命名為 Lesson 1.dtsx 。

? 當(dāng)系統(tǒng)提示重命名包對象時，單擊“是”。

3. 為 SSIS 包添加數(shù)據(jù)源（導(dǎo)入數(shù)據(jù)的源和目標數(shù)據(jù)源）

? 首先添加導(dǎo)入數(shù)據(jù)的源

? 右鍵單擊“連接管理器”區(qū)域中的任意位置，再單擊“新建平面文件連接”。

? 在“平面文件連接管理器編輯器”對話框的“連接管理器名稱”字段中，鍵入 Source 。

? 單擊“瀏覽”。

? 在“打開”對話框中，瀏覽并找到“ d:\test\t1.txt ”文件。

? “常規(guī)”選項中，勾選“在第 1 個數(shù)據(jù)行中顯示列名稱”。

? “高級”選項中，選擇“ id ”列，將數(shù)據(jù)類型設(shè)置為“ four-byte single integer[DT_I4] ”。

? “高級”選項中，選擇“ name ”列，將數(shù)據(jù)類型設(shè)置為“ Unicode string[DT_WSTR] ”。

? 然后，你可以在“預(yù)覽”中查看數(shù)據(jù)是否正確。

? 然后添加接收數(shù)據(jù)的目的數(shù)據(jù)源

? 右鍵單擊連接管理器區(qū)域中的任意位置，再單擊“新建 OLE DB 連接 ” 。

? 在 “ 配置 OLE DB 連接管理器 ” 對話框中，單擊 “ 新建 ” 。

? 在 “ 服務(wù)器名稱 ” 中，輸入 localhost 。

? 將 localhost 指定為服務(wù)器名稱時，連接管理器將連接到本地計算機上 Microsoft SQL Server 2005 的默認實例。若要使用 SQL Server 2005 的遠程實例，請將 localhost 替換為要連接到的服務(wù)器的名稱。

? 在 “ 登錄到服務(wù)器 ” 組中，確認選擇了 “ 使用 Windows 身份驗證 ” 。

? 在 “ 連接到數(shù)據(jù)庫 ” 組的 “ 選擇或輸入數(shù)據(jù)庫名稱 ” 框中，鍵入或選擇 tempdb 。

? 單擊 “ 測試連接 ” ，驗證指定的連接設(shè)置是否有效。

? 單擊 “ 確定 ” 。

? 單擊 “ 確定 ” 。

? 在 “ 配置 OLE DB 連接管理器 ” 對話框的 “ 數(shù)據(jù)連接 ” 窗格中，確認選擇了 localhost.tempdb 。

? 單擊 “ 確定 ” 。

4. 為 SSIS 包添加數(shù)據(jù)流任務(wù)

? 單擊“控制流”選項卡。

? 在“工具箱”中，展開“控制流項”，并將一個數(shù)據(jù)流任務(wù)拖到“控制流”選項卡的設(shè)計圖面上。

? 在“控制流”設(shè)計圖面中，右鍵單擊新添加的數(shù)據(jù)流任務(wù)，再單擊“重命名”，將名稱更改為 Import Data 。

5. 在數(shù)據(jù)流任務(wù)中設(shè)置數(shù)據(jù)流源

? 打開“數(shù)據(jù)流”設(shè)計器，方法是雙擊 Import Data 數(shù)據(jù)流任務(wù)或單擊 “ 數(shù)據(jù)流 ” 選項卡。

? 在 “ 工具箱 ” 中，展開 “ 數(shù)據(jù)流源 ” ，然后將 “ 平面文件源 ” 拖動到 “ 數(shù)據(jù)流 ” 選項卡的設(shè)計圖面上。

? 在 “ 數(shù)據(jù)流 ” 設(shè)計圖面上，右鍵單擊新添加的 “ 平面文件源 ” ，單擊 “ 重命名 ” ，然后將該名稱更改為 Source Data 。

? 雙擊此平面文件源，打開 “ 平面文件源編輯器 ” 對話框。

? 在 “ 平面文件連接管理器 ” 框中，鍵入或選擇 Source 。

? 單擊 “ 列 ” 并驗證列名是否正確。

? 單擊 “ 確定 ” 。

6. 在數(shù)據(jù)流任務(wù)中添加查找處理組件

? 在“工具箱”中，展開“數(shù)據(jù)流轉(zhuǎn)換”，然后將“查找”拖動到“數(shù)據(jù)流”選項卡的設(shè)計圖面上。將“查找”直接放置在 Source Data 源的下面。

? 單擊 Source Data 平面文件源，并將綠色箭頭拖動到新添加的 “ 查找 ” 轉(zhuǎn)換中，以連接這兩個組件。

? 在 “ 數(shù)據(jù)流 ” 設(shè)計圖面上，右鍵單擊新添加的 “ 查找 ” 轉(zhuǎn)換，單擊 “ 重命名 ” ，然后將該名稱更改為 Lookup id 。

? 雙擊 Lookup id 轉(zhuǎn)換。

? 在 “ 查找轉(zhuǎn)換編輯器 ” 對話框的 “OLE DB 連接管理器 ” 框中，確保顯示 localhost.tempdb 。

? 在 “ 使用表或視圖 ” 框中，鍵入或選擇 [dbo].[tb] 。

? 單擊 “ 列 ” 選項卡。

? 在 “ 可用輸入列 ” 面板中，將 id 拖放到 “ 可用查找列 ” 面板的 id 上。

? 單擊 “ 確定 ” 。

7. 在數(shù)據(jù)流任務(wù)中添加插入數(shù)據(jù)處理需要的目標數(shù)據(jù)源

? 在“工具箱”中，展開“數(shù)據(jù)流目標”，并將“ OLE DB 目標 ” 拖到 “ 數(shù)據(jù)流 ” 選項卡的設(shè)計圖面上。將 OLE DB 目標直接放置在 “Lookup id” 轉(zhuǎn)換的下面。

? 單擊 “Lookup id” 轉(zhuǎn)換，并將 紅色 箭頭拖到新添加的 “OLE DB 目標 ” 上，以便將兩個組件連接在一起。

? 在出現(xiàn)的 “ 配置錯誤輸出 ” 對話框中，“錯誤”列中選擇“重定向行”

? 單擊 “ 確定 ” 。

? 在 “ 數(shù)據(jù)流 ” 設(shè)計圖面上，右鍵單擊新添加的 “OLE DB 目標 ” 組件，單擊 “ 重命名 ” ，然后將名稱更改為 Insert data 。

? 雙擊 Insert data 。

? 在 “OLE DB 目標編輯器 ” 對話框中，確保已在 “OLE DB 連接管理器 ” 框中選中 localhost.tempdb 。

? 在 “ 表或視圖的名稱 ” 框中，鍵入或選擇 [dbo].[tb] 。

? 單擊 “ 映射 ” 。

? 驗證 id, name 輸入列是否已正確映射到目標列。如果映射了同名列，則說明映射正確。

? 單擊 “ 確定 ” 。

8. 在數(shù)據(jù)流任務(wù)中添加更新數(shù)據(jù)處理需要的 OLE DB 命令組件

? 在“工具箱”中，展開“數(shù)據(jù)流組件轉(zhuǎn)換”，并將“ OLE DB 命令 ” 拖到 “ 數(shù)據(jù)流 ” 選項卡的設(shè)計圖面上。將 OLE DB 目標直接放置在 “Lookup id” 轉(zhuǎn)換的下面。

? 單擊 “Lookup id” 轉(zhuǎn)換，并將 綠色 箭頭拖到新添加的 “OLE DB 命令 ” 上，以便將兩個組件連接在一起。

? 在 “ 數(shù)據(jù)流 ” 設(shè)計圖面上，右鍵單擊新添加的 “OLE DB 命令 ” 組件，單擊 “ 重命名 ” ，然后將名稱更改為 Update data 。

? 雙擊 Update data 。

? 在 “Update Data 高級編輯器 ” 對話框中，“連接管理”選項的“連接管理器”列中，選中 localhost.tempdb 。

? 在“組件屬性”選項中，“自定義屬性”的“ SQLCommand ”屬性中輸入：

UPDATE dbo . tb SET name = ? WHERE id = ?

? 在 “ 列映射 ” 選項中，設(shè)置“輸入列”，將 name 映射到 param_0 ，將 id 映射到 param_1 。注： param_0 對應(yīng) UPDAT 語句中的第 1 個 ? ，而 param_1 對應(yīng) UPDATE 語句中的第 2 個 ? ，這是固定的。

? 單擊 “ 確定 ” 。

9. 測試

? 按“ F5 ”執(zhí)行 SSIS 包

? 執(zhí)行結(jié)束（所有的組件都變?yōu)榫G色），你會看到數(shù)據(jù)流向“ Inset Data” 的有兩條數(shù)據(jù)

? 雙擊“連接管理器”中的 Source ，重新設(shè)置文件名為 D:\test\d2.txt 。

? 單擊“確定”

? 按“ Ctrl+Shift+F<chmetcnv w:st="on" tcsc="0" numbertype="1" negative="False" hasspace="False" sourcevalue="5" unitname="”"><font face="Times New Roman">5</font><span lang="EN-US" style="FONT-FAMILY: 宋體; mso-ascii-font-family: 'Times New Roman'; mso-hansi-font-family: 'Times New Roman'"><span lang="EN-US">”</span></span></chmetcnv> ，重新啟動 SSIS

? 執(zhí)行結(jié)束（所有的組件都變?yōu)榫G色），你會看到數(shù)據(jù)流向“ Inset Data” 的有兩條數(shù)據(jù)，流向“ Update Data ”的有 1 條數(shù)據(jù)

? 最后，在數(shù)據(jù)庫中查詢 tempdb.dbo.tb ，驗證數(shù)據(jù)導(dǎo)入的正確性

10. 添加循環(huán)，一次完成 test 目錄下所有文件的導(dǎo)入

<span style=