1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96
|
using System;
using System.Collections.Generic;
using System.Text;
using System.IO;
using System.Messaging;
using Microsoft.SqlServer.Dts.Runtime; // Managed Runtime namespace
using Microsoft.SqlServer.Dts.Pipeline.Wrapper; // Pipeline Primary Interop Assembly
using wrap = Microsoft.SqlServer.Dts.Runtime.Wrapper;
using System.Windows.Forms;
public class ExecutePackage
{
private Package _package; // package object
private MainPipe _dataFlow; // dataFlow task object
private IDTSComponentMetaData90 _oledbSource; // OLEDB dataFlow component object
private IDTSComponentMetaData90 _dtsSort; // Sort transform dataFlow component object
private IDTSComponentMetaData90 _flatFileDestination; // FlatFile dataFlow component object
private PackageEvents _packageEvents; // class that implements the Package events interface IDTSEvents90
private ComponentEvents _pipeLineEvents; // class that implements the component events interface IDTSComponentEvents90
private MessageQueue msmq;
private string SSISMessageQueue = @".\SSISJobsResultsQueue";
#region Constructor
public ExecutePackage(string packageName)
{
Microsoft.SqlServer.Dts.Runtime.Application app = new Microsoft.SqlServer.Dts.Runtime.Application();
_packageEvents = new PackageEvents();
_package = app.LoadPackage(packageName, _packageEvents, true);
initMessageQueue();
}
#endregion
private void initMessageQueue()
{
try
{
MessageQueue.Delete(SSISMessageQueue);
}
catch (Exception ex)
{
}
msmq = new MessageQueue(SSISMessageQueue, QueueAccessMode.SendAndReceive);
msmq.Label = "For exchange with SSIS Jobs";
}
private void showDtsErrors(string phase, DtsErrors dtsErrors)
{
if (dtsErrors != null && dtsErrors.Count > 0)
{
StringBuilder packageErrors = new StringBuilder();
packageErrors.AppendLine("Errors in package during " + phase);
foreach (DtsError dtsError in dtsErrors)
{
packageErrors.Append(dtsError.ErrorCode);
packageErrors.Append(" - ");
packageErrors.AppendLine(dtsError.Description);
}
MessageBox.Show(packageErrors.ToString());
}
}
public bool Run()
{
string currentDirectory = Directory.GetCurrentDirectory();
System.Messaging.Message message = msmq.Peek();
// Validate the layout of the package.
DTSExecResult status = _package.Validate(null, null, _packageEvents, null);
if (status == DTSExecResult.Failure)
{
showDtsErrors("Validation", _package.Errors);
return false;
}
// If the package validated successfully, then execute it.
status = _package.Execute(null, null, _packageEvents, null, null);
if (status == DTSExecResult.Failure)
{
showDtsErrors("Execution", _package.Errors);
}
return (status == DTSExecResult.Success);
}
public string WaitForCompletion()
{
System.Messaging.Message message = msmq.Receive();
string text = (string)message.Body;
return text;
}
} |
Partager