使用 C# 和 VB.NET 在 SSIS 2012 中编写的示例包
这是一个用 SSIS 2012 编写的示例包,它使用脚本任务完成您正在寻找的工作。您不需要使用 SSIS。您甚至可以使用简单的 C# 或 VB.NET 控制台应用程序来做到这一点,但 SSIS 提供了记录信息和安排作业的灵活性。
文件夹结构(初始)
假设文件夹的结构如下所示:
有一个您要复制的源文件。
Source
|- Sample_File.txt
这是目标文件夹结构。
Target
|- Target_1
| |- Archive
| |- Sample_File.txt
|- Target_2
|- Target_3
|- Sample_File.txt
创建一个 SSIS 包并创建文件夹变量:
Variable name Data type Value
------------------ ---------- ----------------------
Backup_FolderName String Archive
Source_FileName String Sample_File.txt
Source_FilePath String
Source_Folder String D:\SSIS\Files\Source\
Target_Folder String D:\SSIS\Files\Target\
选择变量Source_FilePath
并单击F4
以查看属性。将属性更改EvaluateAsExpression
为 true。单击属性旁边的省略号按钮Expression
以打开Expression Builder。将表达式设置为@[User::Source_Folder] + "\\" + @[User::Source_FileName]
。
您可以只有一个变量来存储源文件路径。我通常更喜欢将源文件夹和文件名分开。
将脚本任务拖放到控制流选项卡上。双击脚本任务以打开脚本任务编辑器。在脚本标签页,点击旁边的省略号按钮ReadOnlyVariables
,选择以下变量,因为我们将在脚本任务代码中使用这些变量。
User::Source_FilePath
User::Target_Folder
User::Backup_FolderName
单击Edit Script...按钮并输入代码,如下所示。
C# 中的脚本任务代码仅适用于 SSIS 2008 及更高版本:
脚本任务代码执行以下操作:
它将检查源文件路径是否有效。如果无效,它将抛出一条消息并退出该过程。
它将检查目标文件夹是否有效。如果无效,它将抛出一条消息并退出该过程。
如果源文件路径和目标文件夹有效,则逻辑将遍历目标文件夹中子文件夹中源文件名的所有匹配位置。如果有匹配的文件,它会将目标文件复制到备份文件夹,然后用源文件覆盖目标文件。
脚本任务将发出适当的信息,以便您可以在 SSIS 2012 中的 SQL Server Data Tools (SSDT) 或 SSIS 2005 - SSIS 2008 R2 中的商业智能开发工作室 (BIDS) 上的进度/执行结果选项卡中跟踪状态。
区域命名空间
使用系统;使用 System.Data;使用 Microsoft.SqlServer.Dts.Runtime;使用 System.Windows.Forms;使用 System.IO;
端区
命名空间 ST_523853dfbc0d4123be43383671f8a6c6 { [Microsoft.SqlServer.Dts.Tasks.ScriptTask.SSISScriptTaskEntryPointAttribute] 公共部分类 ScriptMain : Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTARTScriptObjectModelBase { public void Main() { try { bool fireAgain = false; 字符串备份文件夹 = string.Empty; 字符串备份文件路径 = string.Empty;
string sourcFilePath = Dts.Variables["User::Source_FilePath"].Value.ToString();
string targetFolder = Dts.Variables["User::Target_Folder"].Value.ToString();
string backupFolderName = Dts.Variables["User::Backup_FolderName"].Value.ToString();
if (String.IsNullOrEmpty(sourcFilePath) || !File.Exists(sourcFilePath))
{
// Check if a valid source file path was specified on the package variable
Dts.Events.FireError(101, "Source path error", String.Format("You need to set a valid source file path in the package variable 'Source_FilePath'. Invalid path: '{0}'", sourcFilePath), string.Empty, 0);
Dts.TaskResult = (int)ScriptResults.Failure;
}
else if (String.IsNullOrEmpty(targetFolder) || !Directory.Exists(targetFolder))
{
// Check if a valid target folder was specified on the package variable
Dts.Events.FireError(102, "Target folder error", String.Format("You need to set a valid target folder location in the package variable 'Target_Folder'. Invalid folder: '{0}'", targetFolder), string.Empty, 0);
Dts.TaskResult = (int)ScriptResults.Failure;
}
else
{
FileInfo sourceInfo = new FileInfo(sourcFilePath);
// Loop through each file that matches the name of the source file
foreach (string targetFilePath in Directory.EnumerateFiles(targetFolder, sourceInfo.Name, SearchOption.AllDirectories))
{
FileInfo targetInfo = new FileInfo(targetFilePath);
backupFolder = Path.Combine(targetInfo.Directory.FullName, backupFolderName);
backupFilePath = Path.Combine(backupFolder, backupFolderName);
// If the backup folder does not exist in the folder within root target folder, create the backup folder.
if (!Directory.Exists(backupFolder))
{
Directory.CreateDirectory(backupFolder);
Dts.Events.FireInformation(401, "Backup folder created", String.Format("Backup folder '{0}' was created.", backupFolder), string.Empty, 0, ref fireAgain);
}
// Archive the target file to the backup folder.
File.Copy(targetFilePath, backupFilePath, true);
Dts.Events.FireInformation(402, "Target file archived", String.Format("Target file '{0}' was archived to the backup folder '{1}'.", targetFilePath, backupFolder), string.Empty, 0, ref fireAgain);
// Overwrite the target file with the source file.
File.Copy(sourcFilePath, targetFilePath, true);
Dts.Events.FireInformation(403, "Target file overwritten", String.Format("Target file '{0}' was overwritten with the source file '{1}'.", sourcFilePath, targetFilePath), string.Empty, 0, ref fireAgain);
}
Dts.TaskResult = (int)ScriptResults.Success;
}
}
catch (Exception ex)
{
Dts.Events.FireError(100, "Unhandled exception", ex.ToString(), string.Empty, 0);
}
}
#region ScriptResults declaration
enum ScriptResults
{
Success = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Success,
Failure = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Failure
};
#endregion
}
}
SSIS 2005 及更高版本的 VB.NET 中的脚本任务代码:
#Region "Imports"
Imports System
Imports System.Data
Imports System.Math
Imports System.IO
Imports Microsoft.SqlServer.Dts.Runtime
#End Region
<Microsoft.SqlServer.Dts.Tasks.ScriptTask.SSISScriptTaskEntryPointAttribute()> _
<System.CLSCompliantAttribute(False)> _
Partial Public Class ScriptMain
Inherits Microsoft.SqlServer.Dts.Tasks.ScriptTask.VSTARTScriptObjectModelBase
Public Sub Main()
Try
Dim fireAgain As Boolean = False
Dim backupFolder As String = String.Empty
Dim backupFilePath As String = String.Empty
Dim sourcFilePath As String = Dts.Variables("User::Source_FilePath").Value.ToString()
Dim targetFolder As String = Dts.Variables("User::Target_Folder").Value.ToString()
Dim backupFolderName As String = Dts.Variables("User::Backup_FolderName").Value.ToString()
If String.IsNullOrEmpty(sourcFilePath) OrElse Not File.Exists(sourcFilePath) Then
' Check if a valid source file path was specified on the package variable
Dts.Events.FireError(101, "Source path error", String.Format("You need to set a valid source file path in the package variable 'Source_FilePath'. Invalid path: '{0}'", sourcFilePath), String.Empty, 0)
Dts.TaskResult = ScriptResults.Failure
ElseIf String.IsNullOrEmpty(targetFolder) OrElse Not Directory.Exists(targetFolder) Then
' Check if a valid target folder was specified on the package variable
Dts.Events.FireError(102, "Target folder error", String.Format("You need to set a valid target folder location in the package variable 'Target_Folder'. Invalid folder: '{0}'", targetFolder), String.Empty, 0)
Dts.TaskResult = ScriptResults.Failure
Else
Dim sourceInfo As FileInfo = New FileInfo(sourcFilePath)
' Loop through each file that matches the name of the source file
For Each targetFilePath As String In Directory.EnumerateFiles(targetFolder, sourceInfo.Name, SearchOption.AllDirectories)
Dim targetInfo As FileInfo = New FileInfo(targetFilePath)
backupFolder = Path.Combine(targetInfo.Directory.FullName, backupFolderName)
backupFilePath = Path.Combine(backupFolder, backupFolderName)
' If the backup folder does not exist in the folder within root target folder, create the backup folder.
If Not Directory.Exists(backupFolder) Then
Directory.CreateDirectory(backupFolder)
Dts.Events.FireInformation(401, "Backup folder created", String.Format("Backup folder '{0}' was created.", backupFolder), String.Empty, 0, fireAgain)
End If
' Archive the target file to the backup folder.
File.Copy(targetFilePath, backupFilePath, True)
Dts.Events.FireInformation(402, "Target file archived", String.Format("Target file '{0}' was archived to the backup folder '{1}'.", targetFilePath, backupFolder), String.Empty, 0, fireAgain)
' Overwrite the target file with the source file.
File.Copy(sourcFilePath, targetFilePath, True)
Dts.Events.FireInformation(403, "Target file overwritten", String.Format("Target file '{0}' was overwritten with the source file '{1}'.", sourcFilePath, targetFilePath), String.Empty, 0, fireAgain)
Next
Dts.TaskResult = ScriptResults.Success
End If
Catch ex As Exception
Dts.Events.FireError(100, "Unhandled exception", ex.ToString(), String.Empty, 0)
Dts.TaskResult = ScriptResults.Failure
End Try
End Sub
#Region "ScriptResults declaration"
Enum ScriptResults
Success = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Success
Failure = Microsoft.SqlServer.Dts.Runtime.DTSExecResult.Failure
End Enum
#End Region
End Class
当提供了无效的源文件路径时,包将抛出以下错误消息:
当提供无效的目标文件夹时,包将抛出以下错误消息:
当源位置和目标位置有效时,包将成功执行。在这个例子中,
- 下有一个备份文件夹
Target_1
,因此没有创建文件夹,但文件已复制到备份文件夹。
- 中没有匹配的文件
Target_2
,因此未采取任何措施。
- 备份文件夹在 中创建
Target_3
,文件被复制到目标位置,然后被源文件覆盖。
文件夹结构(最终)
包执行后目标位置如下图所示。
Target
|- Target_1
| |- Archive
| |- Sample_File.txt
| |- Sample_File.txt
|- Target_2
|- Target_3
|- Archive
|- Sample_File.txt
|- Sample_File.txt