Chargement de la sortie d'un package local

Article
2017-03-09

Les applications clientes peuvent lire la sortie des packages Integration Services quand la sortie est enregistrée dans les destinations SQL Server via ADO.NET, ou quand la sortie est enregistrée dans une destination de fichier plat à l’aide des classes présentes dans l’espace de noms System.IO. Toutefois, une application cliente peut également lire directement la sortie d'un package dans la mémoire, sans avoir besoin d'étape intermédiaire pour rendre les données persistantes. La clé de cette solution est l’espace Microsoft.SqlServer.Dts.DtsClient de noms, qui contient des implémentations spécialisées des IDbConnectioninterfaces , IDbCommandet IDbDataParameter de l’espace de noms System.Data . L’assembly Microsoft.SqlServer.Dts.DtsClient.dll est installé par défaut dans %ProgramFiles%\Microsoft SQL Server\100\DTS\Binn.

Remarque

Conformément à la procédure décrite dans cette rubrique, la propriété DelayValidation de la tâche de flux de données et de tous les objets parents doit avoir la valeur par défaut False.

Description

Cette procédure montre comment développer une application cliente en code managé qui charge directement la sortie d'un package avec une destination DataReader à partir de la mémoire. Les étapes résumées ici sont illustrées dans l'exemple de code qui suit.

Pour charger la sortie d'un package de données dans une application cliente

Dans le package, configurez une destination DataReader afin de recevoir la sortie que vous souhaitez lire dans l'application cliente. Donnez un nom descriptif à la destination DataReader, puisque vous l'utiliserez ultérieurement dans votre application cliente. Prenez note du nom de la destination DataReader.
Dans le projet de développement, définissez une référence à l’espace Microsoft.SqlServer.Dts.DtsClient de noms en localisant l’assembly Microsoft.SqlServer.Dts.DtsClient.dll. Par défaut, cet assembly est installé dans C:\Program Files\Microsoft SQL Server\100\DTS\Binn. Importez l’espace de noms dans votre code à l’aide de l’instruction C# Using ou Visual Basic Imports .
Dans votre code, créez un objet de type DtsClient.DtsConnection avec un chaîne de connexion qui contient les paramètres de ligne de commande requis par dtexec.exe pour exécuter le package. Pour plus d'informations, consultez Utilitaire dtexec. Ouvrez ensuite la connexion à l'aide de cette chaîne de connexion. Vous pouvez également vous servir de l’utilitaire dtexecui pour créer visuellement la chaîne de connexion nécessaire.

Notes

L'exemple de code montre le chargement du package à partir du système de fichiers en utilisant la syntaxe /FILE <path and filename>. Toutefois, vous pouvez également charger le package à partir de la base de données MSDB en utilisant la syntaxe /SQL <package name> ou à partir du magasin de packages Integration Services en utilisant la syntaxe /DTS \<folder name>\<package name>.
Créez un objet de type DtsClient.DtsCommand qui utilise le DtsConnection créé précédemment et qui définit sa propriété CommandText sur le nom de la destination DataReader dans le package. Appelez ensuite la méthode ExecuteReader de l'objet de commande pour charger les résultats de package dans un nouveau DataReader.
Vous pouvez éventuellement paramétrer indirectement la sortie du package en utilisant la collection d'objets DtsDataParameter sur l'objet DtsCommand pour passer des valeurs aux variables définies dans le package. Dans le package, vous pouvez utiliser ces variables comme paramètres de requête ou dans des expressions pour affecter les résultats retournés à la destination DataReader. Vous devez définir ces variables dans le package dans l’espace de noms DtsClient avant de pouvoir les utiliser avec l’objet DtsDataParameter d’une application cliente. (Vous devrez peut-être cliquer sur le bouton Bouton De la barre d’outils Colonnes variables dans la fenêtre Variables pour afficher la colonne Espace de noms .) Dans votre code client, lorsque vous ajoutez une DtsDataParameter à la Parameters collection de l’espace DtsCommandde noms , omettez la référence de l’espace de noms DtsClient à partir du nom de la variable. Par exemple :
```
command.Parameters.Add(new DtsDataParameter("MyVariable", 1));
```
Appelez la méthode Read du DataReader autant de fois que nécessaire pour faire une boucle dans les lignes de données de sortie. Utilisez les données, ou enregistrez-les à des fins d'utilisation ultérieure, dans l'application cliente.

Important

La méthode Read de cette implémentation du DataReader retourne true une dernière fois une fois que la dernière ligne de données a été lue. Cela rend difficile l'utilisation du code habituel qui effectue une boucle dans le DataReader alors que Read retourne true. Si votre code essaie de fermer le DataReader ou la connexion après avoir lu le nombre attendu de lignes, sans un dernier appel supplémentaire de la méthode Read, le code déclenchera une exception non prise en charge. Toutefois, si votre code tente de lire des données sur cette itération finale par le biais d’une boucle, lorsqu’il Read retourne true toujours mais que la dernière ligne a été passée, le code génère un message non géré ApplicationException avec le message « The SSIS IDataReader is past the end of the resultset ». Ce comportement est différent de celui des autres implémentations de DataReader. Par conséquent, lors de l'utilisation d'une boucle pour lire les lignes du DataReader pendant que Read retourne true, vous devez écrire le code de sorte à détecter, tester et ignorer ce ApplicationException anticipé sur le dernier appel réussi de la méthode Read. Ou, si vous connaissez à l'avance le nombre de lignes attendu, vous pouvez traiter les lignes, puis appeler la méthode Read une fois de plus avant de fermer le DataReader et la connexion.
Appelez la méthode Dispose de l'objet DtsCommand. Cet appel s'avère particulièrement important si vous avez utilisé des objets DtsDataParameter.
Fermez le DataReader et les objets de connexion.

Exemple

L'exemple suivant exécute un package qui calcule une valeur d'agrégation unique et qui enregistre cette valeur dans une destination DataReader, puis qui lit cette valeur depuis le DataReader et qui l'affiche dans une zone de texte sur un Windows Form.

L'utilisation de paramètres n'est pas requise lors du chargement de la sortie d'un package dans une application cliente. Si vous ne souhaitez pas utiliser de paramètre, vous pouvez omettre l’utilisation de la variable dans l’espace de noms DtsClient et omettre le code qui utilise l’objet DtsDataParameter .

Pour créer le package de test

Créez un nouveau package Integration Services. L'exemple de code utilise « DtsClientWParamPkg.dtsx » comme nom de package.
Ajoutez une variable de type Chaîne à l'espace de noms DtsClient. L'exemple de code utilise le pays comme nom de la variable. (Vous pouvez être amené à cliquer sur le bouton de barre d’outils Choisir les colonnes variables dans la fenêtre Variables pour afficher la colonne Espace de noms.)
Ajoutez un gestionnaire de connexions OLE DB qui se connecte à l’exemple de base de données AdventureWorks2012.
Ajoutez une tâche de flux de données au package et basculez vers l'aire de conception du flux de données.
Ajoutez une source OLE DB au flux de données et configurez-la afin d'utiliser le gestionnaire de connexions OLE DB créé précédemment, ainsi que la commande SQL suivante :
```
SELECT * FROM Sales.vIndividualCustomer WHERE CountryRegionName = ?
```
Cliquez Parameters et, dans la boîte de dialogue Définir les paramètres de requête, mappez le paramètre d’entrée unique dans la requête, Parameter0, à la variable DtsClient ::Country.
Ajoutez une transformation d'agrégation au flux de données et connectez la sortie de la source OLE DB à la transformation. Ouvrez l’Éditeur de transformation d’agrégation et configurez-le pour effectuer une opération « Compter tout » sur toutes les colonnes d’entrée (*) et pour générer la valeur agrégée avec l’alias CustomerCount.
Ajoutez une destination DataReader au flux de données et connectez la sortie de la transformation d'agrégation à la destination DataReader. L'exemple de code utilise « DataReaderDest » comme nom du DataReader. Sélectionnez l'unique colonne d'entrée disponible, CustomerCount, pour la destination.
Enregistrez le package. L'application de test créée par la suite va exécuter le package et extraire directement sa sortie de la mémoire.

Pour créer l'application de test

Créez une nouvelle application Windows Forms.
Ajoutez une référence à l’espace Microsoft.SqlServer.Dts.DtsClient de noms en accédant à l’assembly du même nom dans %ProgramFiles%\Microsoft SQL Server\100\DTS\Binn.
Copiez et collez l'exemple de code suivant dans le module de code pour le formulaire.
Modifiez la valeur de la dtexecArgs variable selon les besoins afin qu’elle contienne les paramètres de ligne de commande requis par dtexec.exe pour exécuter le package. L'exemple de code charge le package à partir du système de fichiers.
Modifiez la valeur de la dataReaderName variable en fonction des besoins afin qu’elle contienne le nom de la destination DataReader dans le package.
Placez un bouton et une zone de texte sur le formulaire. L’exemple de code utilise btnRun le nom du bouton et txtResults le nom de la zone de texte.
Exécutez l'application et cliquez sur le bouton. Après une brève pause pendant l'exécution du package, vous devez voir apparaître la valeur d'agrégation calculée par le package (le nombre de clients au Canada) dans la zone de texte sur le formulaire.

Exemple de code

Imports System.Data
Imports Microsoft.SqlServer.Dts.DtsClient

Public Class Form1

  Private Sub btnRun_Click(ByVal sender As System.Object, ByVal e As System.EventArgs) Handles btnRun.Click

    Dim dtexecArgs As String
    Dim dataReaderName As String
    Dim countryName As String

    Dim dtsConnection As DtsConnection
    Dim dtsCommand As DtsCommand
    Dim dtsDataReader As IDataReader
    Dim dtsParameter As DtsDataParameter

    Windows.Forms.Cursor.Current = Cursors.WaitCursor

    dtexecArgs = "/FILE ""C:\...\DtsClientWParamPkg.dtsx"""
    dataReaderName = "DataReaderDest"
    countryName = "Canada"

    dtsConnection = New DtsConnection()
    With dtsConnection
      .ConnectionString = dtexecArgs
      .Open()
    End With

    dtsCommand = New DtsCommand(dtsConnection)
    dtsCommand.CommandText = dataReaderName

    dtsParameter = New DtsDataParameter("Country", DbType.String)
    dtsParameter.Direction = ParameterDirection.Input
    dtsCommand.Parameters.Add(dtsParameter)

    dtsParameter.Value = countryName

    dtsDataReader = dtsCommand.ExecuteReader(CommandBehavior.Default)

    With dtsDataReader
      .Read()
      txtResults.Text = .GetInt32(0).ToString("N0")
    End With

    'After reaching the end of data rows,
    ' call the Read method one more time.
    Try
      dtsDataReader.Read()
    Catch ex As Exception
      MessageBox.Show("Exception on final call to Read method:" & ControlChars.CrLf & _
      ex.Message & ControlChars.CrLf & _
      ex.InnerException.Message, "Exception on final call to Read method", _
      MessageBoxButtons.OK, MessageBoxIcon.Error)
    End Try

    ' The following method is a best practice, and is
    '  required when using DtsDataParameter objects.
    dtsCommand.Dispose()

    Try
      dtsDataReader.Close()
    Catch ex As Exception
      MessageBox.Show("Exception closing DataReader:" & ControlChars.CrLf & _
      ex.Message & ControlChars.CrLf & _
      ex.InnerException.Message, "Exception closing DataReader", _
      MessageBoxButtons.OK, MessageBoxIcon.Error)
    End Try

    Try
      dtsConnection.Close()
    Catch ex As Exception
      MessageBox.Show("Exception closing connection:" & ControlChars.CrLf & _
      ex.Message & ControlChars.CrLf & _
      ex.InnerException.Message, "Exception closing connection", _
      MessageBoxButtons.OK, MessageBoxIcon.Error)
    End Try

    Windows.Forms.Cursor.Current = Cursors.Default

  End Sub

End Class

using System;
using System.Windows.Forms;
using System.Data;
using Microsoft.SqlServer.Dts.DtsClient;

namespace DtsClientWParamCS
{
  public partial class Form1 : Form
  {
    public Form1()
    {
      InitializeComponent();
      this.btnRun.Click += new System.EventHandler(this.btnRun_Click);
    }

    private void btnRun_Click(object sender, EventArgs e)
    {
      string dtexecArgs;
      string dataReaderName;
      string countryName;

      DtsConnection dtsConnection;
      DtsCommand dtsCommand;
      IDataReader dtsDataReader;
      DtsDataParameter dtsParameter;

      Cursor.Current = Cursors.WaitCursor;

      dtexecArgs = @"/FILE ""C:\...\DtsClientWParamPkg.dtsx""";
      dataReaderName = "DataReaderDest";
      countryName = "Canada";

      dtsConnection = new DtsConnection();
      {
        dtsConnection.ConnectionString = dtexecArgs;
        dtsConnection.Open();
      }

      dtsCommand = new DtsCommand(dtsConnection);
      dtsCommand.CommandText = dataReaderName;

      dtsParameter = new DtsDataParameter("Country", DbType.String);
      dtsParameter.Direction = ParameterDirection.Input;
      dtsCommand.Parameters.Add(dtsParameter);

      dtsParameter.Value = countryName;

      dtsDataReader = dtsCommand.ExecuteReader(CommandBehavior.Default);

      {
        dtsDataReader.Read();
        txtResults.Text = dtsDataReader.GetInt32(0).ToString("N0");
      }

      //After reaching the end of data rows,
      // call the Read method one more time.
      try
      {
        dtsDataReader.Read();
      }
      catch (Exception ex)
      {
        MessageBox.Show(
          "Exception on final call to Read method:\n" + ex.Message + "\n" + ex.InnerException.Message,
          "Exception on final call to Read method", MessageBoxButtons.OK, MessageBoxIcon.Error);
      }

      // The following method is a best practice, and is
      //  required when using DtsDataParameter objects.
      dtsCommand.Dispose();

      try
      {
        dtsDataReader.Close();
      }
      catch (Exception ex)
      {
        MessageBox.Show(
          "Exception closing DataReader:\n" + ex.Message + "\n" + ex.InnerException.Message,
          "Exception closing DataReader", MessageBoxButtons.OK, MessageBoxIcon.Error);
      }

      try
      {
        dtsConnection.Close();
      }
      catch (Exception ex)
      {
        MessageBox.Show(
          "Exception closing connection:\n" + ex.Message + "\n" + ex.InnerException.Message,
          "Exception closing connection", MessageBoxButtons.OK, MessageBoxIcon.Error);
      }

      Cursor.Current = Cursors.Default;

    }
  }
}

Icône Integration Services (petite) Rester à jour avec Integration Services
Pour obtenir les derniers téléchargements, articles, exemples et vidéos de Microsoft, ainsi que les solutions sélectionnées de la communauté, visitez la page Integration Services sur MSDN :

Visiter la page Integration Services sur MSDN

Pour recevoir une notification automatique de ces mises à jour, abonnez-vous aux flux RSS disponibles sur la page.

Voir aussi

Comprendre les différences entre le chargement local et l’exécution d’un package local par programmation et l’exécution d’un package distant par programmation

Partager via