如何在SSIS的脚本组件中访问变量
這是一個小問題,我們在SSIS的設(shè)計中很多地方都會用到變量,我習(xí)慣性地將“變量”和“表達式”稱為SSIS的靈魂,雖然不見得絕對準(zhǔn)確,但它們確實是保證一個SSIS包靈活性的根本。
同時,我們可能也會在數(shù)據(jù)流任務(wù)中添加“腳本組件”,用我們熟知的C#或者VB.NET編寫一些數(shù)據(jù)轉(zhuǎn)換處理的邏輯。這里可能就有一個需求,我們希望在腳本組件中訪問變量(讀或者寫),但默認情況下,這個需求并不是那么容易實現(xiàn)。我們來看下面的例子
?
這個例子中,我們在Package級別定義了一個變量,名稱為test
然后,我們在數(shù)據(jù)流中有一個Script Component,我們嘗試在里面對上面這個變量進行讀寫
代碼大致如下
/* Microsoft SQL Server Integration Services Script Component * Write scripts using Microsoft Visual C# 2008. * ScriptMain is the entry point class of the script.*/using System; using System.Data; using Microsoft.SqlServer.Dts.Pipeline.Wrapper; using Microsoft.SqlServer.Dts.Runtime.Wrapper;using System.Windows.Forms;[Microsoft.SqlServer.Dts.Pipeline.SSISScriptComponentEntryPointAttribute] public class ScriptMain : UserComponent {public override void PreExecute(){base.PreExecute();/* Add your code here for preprocessing or remove if not needed */}public override void PostExecute(){base.PostExecute();/* Add your code here for postprocessing or remove if not needed You can set read/write variables here, for example: Variables.MyIntVar = 100 */}public override void Input0_ProcessInputRow(Input0Buffer Row){/* Add your code here */}}?
代碼很簡單,也很自然。我只是作為演示,這里讀取到那個變量之后,顯示出來。
但是這個代碼是不能運行的,有如下錯誤
上述錯誤的意思是,除非在PostExecute方法里面,是不可以對變量進行讀寫的。這里的原因是,ProcessInputRow這個方法,因為是每一行數(shù)據(jù)都會執(zhí)行一次,所以如果這里隨意讀寫變量的話,會因為要頻繁加鎖和解鎖,造成效率方面的問題。
?
這里談到了一個加鎖的問題。為什么會有這個問題呢?其實很簡單,因為變量是定義在Package級別,所以很可能幾個任務(wù)在同時訪問這些變量,都在對其進行讀寫。如果不加鎖,則可能導(dǎo)致不可預(yù)期的結(jié)果。
?
如果你理解了上述機制,而且也確定可以承擔(dān)鎖定可能帶來的性能損耗,那么要解決問題,可以通過如下的方式實現(xiàn)
?
public override void Input0_ProcessInputRow(Input0Buffer Row){/* Add your code here */VariableDispenser.LockForRead("User::test");//這里先聲明對某個變量進行鎖定IDTSVariables100 vs = null;this.VariableDispenser.GetVariables(out vs);//通過VariableDispenser獲取變量集合MessageBox.Show(vs["User::test"].Value.ToString());vs.Unlock();//解鎖}總結(jié)
以上是生活随笔為你收集整理的如何在SSIS的脚本组件中访问变量的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: psql error: psql: sy
- 下一篇: 1707: [Usaco2007 Nov