L'exportation de données à partir de plusieurs tables SQL pour différents fichiers à plat à l'aide de SSIS Tâche de Script

Ici est un moyen possible d'exporter les tables de structure différente à dossier plat en utilisant Script Task. Cet exemple permet d'exporter des deux tables contenant les différents champs et les données dans un fichier plat, à l'aide de Script. Pour exporter les données, vous pouvez utiliser le DataReader au lieu d'utiliser le DataGrid. Il pourrait y avoir d'autres façons de procéder.

Étape-par-étape du processus:

1. Créer trois tables nommé dbo.TablesList, dbo.Source1 et dbo.Source2 en utilisant des scripts donné en vertu de l' Scripts SQL section.
2. Remplir les tables dbo.TablesList, dbo.Source1 et `dbo.Source2` avec des données indiqué dans la capture d'écran #1.
3. Sur le package SSIS de Connection manager, créer un OLE DB connection nommé SQLServer pour se connecter à l'instance de SQL Server comme indiqué dans la capture d'écran #2.
4. Dans le paquet, création de 4 variables, comme indiqué dans la capture d'écran #3.
5. Dans le Flux de Contrôle, placez un Execute SQL Task, un Foreach Loop Container et un Script Task dans le Foreach loop container comme indiqué dans la capture d'écran #4.
6. Configurer le Execute SQL task comme indiqué dans les captures d'écran #5 et #6.
7. Configurer le Foreach Loop container comme indiqué dans les captures d'écran #7 et #8.
8. Remplacer la méthode main à l'intérieur de la Tâche de Script avec le code donné en vertu de l'article Script Task Code.
9. Capture d'écran #9 montre l'exécution d'un package.
10. Captures d'écran #10 - #12 afficher les fichiers exportés à partir de SSIS l'aide d'un Script code de la Tâche.

Espère que ça aide.

Scripts SQL:

CREATE TABLE [dbo].[Source1](
    [Id] [int] IDENTITY(1,1) NOT NULL,
    [ItemNumber] [varchar](20) NOT NULL,
    [ItemName] [varchar](50) NOT NULL,
CONSTRAINT [PK_Source1] PRIMARY KEY CLUSTERED ([Id] ASC)) ON [PRIMARY]
GO

CREATE TABLE [dbo].[Source2](
    [Id] [int] IDENTITY(1,1) NOT NULL,
    [Country] [varchar](20) NOT NULL,
    [StateProvince] [varchar](50) NOT NULL,
CONSTRAINT [PK_Source2] PRIMARY KEY CLUSTERED ([Id] ASC)) ON [PRIMARY]
GO

CREATE TABLE [dbo].[TablesList](
    [Id] [int] IDENTITY(1,1) NOT NULL,
    [TableName] [varchar](50) NOT NULL,
    [FilePath] [varchar](255) NOT NULL,
CONSTRAINT [PK_Tables] PRIMARY KEY CLUSTERED ([Id] ASC)) ON [PRIMARY]
GO

Script Code de la Tâche: (Utiliser le code donné ci-dessous pour remplacer la méthode main() dans votre tâche de Script)

VB méthode main() de code qui peut être utilisé dans SSIS 2005 and above:

Public Sub Main()
Dim varCollection As Variables = Nothing
Dts.VariableDispenser.LockForRead("User::TableName")
Dts.VariableDispenser.LockForRead("User::FileName")
Dts.VariableDispenser.LockForRead("User::Delimiter")
Dts.VariableDispenser.GetVariables(varCollection)
Dim fileName As String = varCollection("User::FileName").Value.ToString()
Dim query As String = "SELECT * FROM " & varCollection("User::TableName").Value.ToString()
Dim delimiter As String = varCollection("User::Delimiter").Value.ToString()
Dim writer As StreamWriter = Nothing
Dim connection As OleDbConnection = New OleDbConnection(Dts.Connections("SQLServer").ConnectionString)
Dim command As OleDbCommand = Nothing
Dim reader As OleDbDataReader = Nothing
Try
If File.Exists(fileName) Then
File.Delete(fileName)
End If
connection.Open()
command = New OleDbCommand(query, connection)
reader = command.ExecuteReader()
If reader.HasRows Then
writer = New System.IO.StreamWriter(fileName)
Dim row As Integer = 0
While reader.Read()
Dim header As Integer = 0
Dim counter As Integer = 0
Dim fieldCount As Integer = reader.FieldCount - 1
If row = 0 Then
While header <= fieldCount
If header <> fieldCount Then
writer.Write(reader.GetName(header).ToString() & delimiter)
Else
writer.WriteLine(reader.GetName(header).ToString())
End If
header += 1
End While
End If
While counter <= fieldCount
If counter <> fieldCount Then
writer.Write(reader(counter).ToString() & delimiter)
Else
writer.WriteLine(reader(counter).ToString())
End If
counter += 1
End While
row += 1
End While
End If
Catch ex As Exception
Throw ex
Finally
connection.Close()
writer.Close()
End Try
Dts.TaskResult = ScriptResults.Success
End Sub

Capture d'écran #1:

Capture d'écran #2:

Capture d'écran #3:

Capture d'écran #4:

Capture d'écran #5:

Capture d'écran #6:

Capture d'écran #7:

Capture d'écran n ° 8:

Capture d'écran n ° 9:

Capture d'écran n ° 10:

Capture d'écran #11:

Capture d'écran n ° 12:

OriginalL'auteur