在本文中除了講創建一個DTS自定義任務外,還包括一下部分內容:
1、這篇文章中自定義的代碼分為編譯、註冊和安裝自定義任務;
2、這部分一個有特色的部分就是你可以運行自定義的任務;
3、在開發過程中你可以使用本文提及的一些工具(除非另有說明,這些工具已經包含在.NET中了,您可以通過.NET的命令行運行這些工具)。
為DTSSpkg.dll創建一個及時的包
如果一個基於微軟.NET客戶機訪問一個COM元件,你必須使用一個包(這個元件包含的)。這類的包是及時的運行包(RCW)並且你也可以通過開放Dtspkg.dll的類型庫編譯。你也可以使用類型庫導出工具(Tlbimp.exe)編譯RCW,如:
tlbimp.exe “C:\ProgramFiles\Microsoft SQLServer\80\tools\Binn\dtspkg.dll”/out:Microsoft.SQLServver.DTSPKG80.dll/keyfile:DTSPkg.snk
“/keyfile”參數代表Microsoft.SQLServer.DTSPkg80.dll帶有強類型名用public或private關鍵字。使用強類型名工具(sn.exe)在DTSPkg.snk 前創建關鍵字:
sn.exe –k DTSPkg.snk
你應該使用一個強類型名像其他的全局集合緩存,因為你安裝了運行包。
在全局集合緩存中安裝運行包
用全局集合緩存工具(GaCutil.exe)安裝運行包:
gacutil.exe /I Microsoft.SQLServer.DTSPkg80.dll
安裝了運行包後,你可以像添加.NETC#工程中的引用一樣的添加。
為自定義的任務添加代碼
代碼的自定義註冊。.NET沒有開放DllReginsterServer 和DllUnregisterServer 像COM元件的入口,但是你可以使用ComRegisterFunctionAttribute 類執行任務註冊和撤銷註冊。在自定義類聲明之前添加下面代碼:
[Guid("A39847F3-5845-4459-A25E-DE73A8E3CD48"), ComVisible(true)]
[ProgId("DTS.SimpleTask")]
public class SimpleTask : CustomTask
{
//implementation of custom task
}
下面的代碼是一個函數註冊的範例執行。函數的全部代碼在自定義任務的編譯、註冊和安裝部分 。
[System.Runtime.InteropServices.ComRegisterFunctionAttribute()]
static void RegisterServer(Type t)
{
//code to register custom task
}
註冊函數增加下面的鍵值用來註冊。
HKEY_CLASSES_ROOT\CLSID\A39847F3-5845-4459-A25E-DE73A8E3CD48\Implemented Categories\{10020200-EB1C-11CF-AE6E-00AA004A34D5}
10020200-EB1C-11CF-AE6E-00AA004A34D5是DTS包對象的類編號。因為所有的自定義的任務執行自定義的介面所以必須註冊。註冊函數添加下面的註冊鍵值:
HKEY_CURRENT_USER\Software\Microsoft\Microsoft SQL Server\80\DTS\Enumeration\Tasks\A39847F3-5845-4459-A25E-DE73A8E3CD48
下面的DTS任務緩存目錄列表,使自定義的任務出現在DTS設計器中:
HKEY_CURRENT_USER\Software\Microsoft\Microsoft SQL Server\80\DTS\Enumeration\Tasks\
下面的代碼示範非註冊函數的任務移出的執行。面註冊函數是ComUnregisterFunctionAttribute類在.NET運行庫的一部分。想流覽這個函數的完整代碼,你可以看“編譯、註冊和安裝自定義任務”部分:
[System.Runtime.InteropServices.ComUnregisterFunctionAttribute()]
static void UnregisterServer(Type t)
{
//code to unregister custom task
}
免註冊函數通過從註冊表中刪除下面鍵值從DTS任務緩存中移出任務
HKEY_CURRENT_USER\Software\Microsoft\Microsoft SQL Server\80\DTS\Enumeration\Tasks\A39847F3-5845-4459-A25E-DE73A8E3CD48
最後,自定義的任務像dual_interface COM元件一樣被開放。您從所有的類的public,非靜態的欄位,屬性和方法創建一個默認的介面。在下面的一行代碼在自定義任務原始檔案中USING應用之後:
[assembly:ClassInterface(ClassInterfaceType.AutoDual)]
這部分的代碼已經完全列舉了。
增加功能性的自定義任務
本文“編譯、註冊和安裝自定義任務”部分包含一個簡單的DTS自定義任務代碼。 任務有兩個屬性:Name 和Description,Description屬性的值就會出現在訊息方塊中。這個例子的描述了一個最小化的代碼你可以使用已有的功能性的DTS定義任務。然而,你可以通過執行CustomTaskUI介面創建一個用戶介面,但是那並不作討論。通過只執行自定義的介面,DTS設計者為自定義任務創建一個默認的有戶介面。
所有的DTS自定義任務執行自定義任務介面。自定義的用戶介面是由兩個屬性,一個集合和一個方法:
1、 Name和Description屬性;
2、 Properties集;
3、 Execute方法。
所有的自定義任務應該執行屬性、屬性集和Execute方法。
編譯、註冊和安裝自定義任務
using System;
using System.Runtime.InteropServices;
using Microsoft.SQLServer.DTSPkg80;
using Microsoft.Win32;
using System.Windows.Forms;
[assembly:ClassInterface(ClassInterfaceType.AutoDual)]
namespace DTS
{
[Guid("38ED4F80-9EF4-4752-8478-65D2DB3BA7DD"), ComVisible(true)] //GUID is created by using GUIDGEN.EXE
[ProgId("DTS.SimpleCustomTask")]
public class SimpleCustomTask : CustomTask
{
private string name;
private string description;
public SimpleCustomTask()
{
name = "";
description = "SimpleCustomTask description";
}
public void Execute(object pPackage, object pPackageEvents, object pPackageLog, ref Microsoft.SQLServer.DTSPkg80.DTSTaskExecResult pTaskResult)
{
//Assume failure at the outset
pTaskResult= DTSTaskExecResult.DTSTaskExecResult_Failure;
try
{
Package2 package = (Package2) pPackage;
PackageEvents packageEvents = (PackageEvents) pPackageEvents;
PackageLog packageLog = (PackageLog) pPackageLog;
MessageBox.Show(description);
}
//First catch COM exceptions, and then all other exceptions
catch(System.Runtime.InteropServices.COMException e)
{
Console.WriteLine(e);
}
catch(System.Exception e)
{
Console.WriteLine(e);
}
//Return success
pTaskResult = DTSTaskExecResult.DTSTaskExecResult_Success;
}
public string Description
{
get { return this.description; }
set { this.description = value; }
}
public string Name
{
get { return name; }
set { this.name = value; }
}
public Microsoft.SQLServer.DTSPkg80.Properties Properties
{
get { return null; }
}
[System.Runtime.InteropServices.ComVisible(false)]
override public string ToString()
{
return base.ToString();
}
//Registration function for custom task.
[System.Runtime.InteropServices.ComRegisterFunctionAttribute()]
static void RegisterServer(Type t)
{
try
{
const string TASK_CACHE = "Software\\Microsoft\\Microsoft SQL Server\\80\\DTS\\Enumeration\\Tasks";
const string CATID_DTSCustomTask = "{10020200-EB1C-11CF-AE6E-00AA004A34D5}";
string guid = "{" + t.GUID.ToString() + "}";
guid = guid.ToUpper();
Console.WriteLine("RegisterServer {0}", guid);
RegistryKey root;
RegistryKey rk;
RegistryKey nrk;
// Add COM Category in HKEY_CLASSES_ROOT
root = Registry.ClassesRoot;
rk = root.OpenSubKey("CLSID\\" + guid + "\\Implemented Categories", true);
nrk = rk.CreateSubKey(CATID_DTSCustomTask);
nrk.Close();
rk.Close();
root.Close();
// Add to DTS Cache in HKEY_CURRENT_USER
root = Registry.CurrentUser;
rk = root.OpenSubKey(TASK_CACHE, true);
nrk = rk.CreateSubKey(guid);
nrk.SetValue("", t.FullName);
nrk.Close();
rk.Close();
root.Close();
SimpleCustomTask ct = new SimpleCustomTask();
root = Registry.ClassesRoot;
rk = root.OpenSubKey("CLSID\\" + guid, true);
rk.SetValue("DTSTaskDescription", ct.description);
nrk.Close();
rk.Close();
root.Close();
}
catch(Exception e)
{
System.Console.WriteLine(e.ToString());
}
}
//Unregistration function for custom task.
[System.Runtime.InteropServices.ComUnregisterFunctionAttribute()]
static void UnregisterServer(Type t)
{
try
{
const string TASK_CACHE = "Software\\Microsoft\\Microsoft SQL Server\\80\\DTS\\Enumeration\\Tasks";
string guid = "{" + t.GUID.ToString() + "}";
guid = guid.ToUpper();
Console.WriteLine("UnregisterServer {0}", guid);
RegistryKey root;
RegistryKey rk;
// Delete from DTS Cache in HKEY_CURRENT_USER
root = Registry.CurrentUser;
rk = root.OpenSubKey(TASK_CACHE, true);
rk.DeleteSubKey(guid, false);
rk.Close();
root.Close();
}
catch(Exception e)
{
System.Console.WriteLine(e.ToString());
}
}
}
}
留言列表