3

我需要执行以下概述的任务,但不确定如何继续。使用 Windows Server 2003,我可以在命令脚本或 SSIS 中的脚本任务中执行此操作吗?我一直在使用 SSIS 2005 并且知道有一个文件系统任务,但我以前从未使用过它。

  • 我在本地有一个文件'target.file'。
  • 网络服务器上有一个“目标”文件夹。
  • “目标”下有数百个文件夹。
  • 其中一些文件夹下有“备份”文件夹。
  • 我需要将“target.file”复制到“target”文件夹下的那些文件夹中。
    • 但只有在已经存在“target.file”时才复制/替换。
    • 如果“target.file”存在,如果备份文件夹存在,则将文件复制并替换到备份文件夹。
    • 如果没有,请先创建备份文件夹。
4

2 回答 2

4

使用 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
于 2013-02-19T16:54:39.737 回答
1

显然@Siva 为回答您的问题做了大量工作。但是,我想知道以下内容是否会使工作变得更糟(尽管很可能我没有花这么长时间来想出这个脚本):

@ECHO OFF

SET "srcname=target.file"
SET "srcpath=D:\path\to\source"
SET "tgtpath=\\remotehost\shared\folder"
SET "bakname=Backup"

FOR /D %%D IN ("%tgtpath%\*") DO (
  IF EXIST "%%D\%srcname%" (
    IF NOT EXIST "%%D\%bakname%" MKDIR "%%D\%bakname%"
    COPY /Y "%%D\%srcname%" "%%D\%bakname%"
    COPY /Y "%srcpath%\%srcname%" "%%D"
  )
)
于 2013-02-20T13:13:38.160 回答