Dodaj połączenia programowo

Dotyczy:SQL Server Środowisko SSIS Integration Runtime w usłudze Azure Data Factory

Klasa reprezentuje ConnectionManager fizyczne połączenia z zewnętrznymi źródłami danych. Klasa izoluje ConnectionManager szczegóły implementacyjne połączenia od czasu działania. Pozwala to na regularną i przewidywalną interakcję z każdym menedżerem połączeń. Menedżery połączeń zawierają własności stockowe, które wszystkie połączenia mają wspólne, takie jak Name, ID, Description, oraz ConnectionString. Jednak właściwości i Name są zazwyczaj jedynymi właściwościami ConnectionString wymaganymi do skonfigurowania menedżera połączeń. W przeciwieństwie do innych paradygmatów programowania, gdzie klasy połączeń udostępniają metody takie jak Open czy Connect umożliwiające fizyczne nawiązanie połączenia ze źródłem danych, silnik uruchomieniowy zarządza wszystkimi połączeniami dla pakietu podczas jego działania.

Klasa Connections ta to zbiór menedżerów połączeń dodanych do tego pakietu i dostępnych do użycia w czasie działania. Możesz dodać więcej menedżerów połączeń do kolekcji, używając Add metody kolekcji i dostarczając ciąg wskazujący typ menedżera połączeń. Metoda zwraca Add instancję ConnectionManager dodaną do pakietu.

Własności wewnętrzne

Klasa ta ConnectionManager ujawnia zbiór właściwości wspólnych dla wszystkich połączeń. Jednak czasem potrzebujesz dostępu do właściwości unikalnych dla konkretnego typu połączenia. Kolekcja PropertiesConnectionManager klasy zapewnia dostęp do tych właściwości. Właściwości można pobrać z kolekcji za pomocą indeksatora lub nazwy właściwości oraz metody GetValue , a wartości są ustalane metodą SetValue . Właściwości obiektu powiązania można również ustawić, przejmując rzeczywistą instancję obiektu i ustawiając jej właściwości bezpośrednio. Aby uzyskać podstawowe połączenie, użyj InnerObject właściwości menedżera połączeń. Następny wiersz kodu pokazuje linię C#, która tworzy menedżera połączeń ADO.NET z klasą bazową, ConnectionManagerAdoNetClass.

ConnectionManagerAdoNetClass cmado = cm.InnerObject as ConnectionManagerAdoNet;

To przekazuje obiekt zarządzanego menedżera połączeń do jego obiektu połączenia. Jeśli używasz C++, wywołuje się metodę QueryInterface obiektu ConnectionManager i żąda interfejsu obiektu połączenia.

Poniższa tabela przedstawia menedżery połączeń dołączone do Integration Services oraz ciąg znaków używanych w package.Connections.Add("xxx") instrukcji. Listę wszystkich menedżerów połączeń można znaleźć w sekcji Usługi integracyjne (SSIS) Połączenia.

String Menedżer połączeń
"OLEDB" Menedżer połączeń dla połączeń OLE DB.
"ODBC" Menedżer połączeń dla połączeń ODBC.
"ADO" Menedżer połączeń dla połączeń ADO.
"ADO.NET:SQL" Menedżer połączeń dla połączeń ADO.NET (dostawcy danych SQL).
"ADO.NET:OLEDB" Menedżer połączeń dla połączeń ADO.NET (dostawca danych OLE DB).
"FLATFILE" Menedżer połączeń dla połączeń z płaskimi plikami.
"PLIK" Menedżer połączeń dla połączeń plików.
"MULTIFLATFILE" Menedżer połączeń dla wielu połączeń płaskich plików.
"MULTIFILE" Menedżer połączeń dla wielu połączeń plików.
"SQLMOBILE" Menedżer połączeń dla połączeń SQL Server Compact.
"MSOLAP100" Menedżer połączeń dla połączeń usług analitycznych.
"FTP" Menedżer połączeń dla połączeń FTP.
HTTP Menedżer połączeń dla połączeń HTTP.
"MSMQ" Menedżer połączeń dla połączeń Message Queuing (znanego również jako MSMQ).
"SMTP" Menedżer połączeń dla połączeń SMTP.
"WMI" Menedżer połączeń dla połączeń Microsoft Windows Management Instrumentation (WMI).

Poniższy przykład kodu demonstruje dodanie połączenia OLE DB i FILE do kolekcji Connections .Package Przykład następnie ustawia ConnectionString, Name, oraz Description własności.

using System;
using Microsoft.SqlServer.Dts.Runtime;
  
namespace Microsoft.SqlServer.Dts.Samples
{
  class Program
  {
    static void Main(string[] args)
    {
      // Create a package, and retrieve its connections.
      Package pkg = new Package();
      Connections pkgConns = pkg.Connections;
  
      // Add an OLE DB connection to the package, using the
      // method defined in the AddConnection class.
      CreateConnection myOLEDBConn = new CreateConnection();
      myOLEDBConn.CreateOLEDBConnection(pkg);
  
      // View the new connection in the package.
      Console.WriteLine("Connection description: {0}",
         pkg.Connections["SSIS Connection Manager for OLE DB"].Description);
  
      // Add a second connection to the package.
      CreateConnection myFileConn = new CreateConnection();
      myFileConn.CreateFileConnection(pkg);
  
      // View the second connection in the package.
      Console.WriteLine("Connection description: {0}",
        pkg.Connections["SSIS Connection Manager for Files"].Description);
  
      Console.WriteLine();
      Console.WriteLine("Number of connections in package: {0}", pkg.Connections.Count);
  
      Console.Read();
    }
  }
  // <summary>
  // This class contains the definitions for multiple
  // connection managers.
  // </summary>
  public class CreateConnection
  {
    // Private data.
    private ConnectionManager ConMgr;
  
    // Class definition for OLE DB Provider.
    public void CreateOLEDBConnection(Package p)
    {
      ConMgr = p.Connections.Add("OLEDB");
      ConMgr.ConnectionString = "Provider=SQLOLEDB.1;" +
        "Integrated Security=SSPI;Initial Catalog=AdventureWorks;" +
        "Data Source=(local);";
      ConMgr.Name = "SSIS Connection Manager for OLE DB";
      ConMgr.Description = "OLE DB connection to the AdventureWorks database.";
    }
    public void CreateFileConnection(Package p)
    {
      ConMgr = p.Connections.Add("File");
      ConMgr.ConnectionString = @"\\<yourserver>\<yourfolder>\books.xml";
      ConMgr.Name = "SSIS Connection Manager for Files";
      ConMgr.Description = "Flat File connection";
    }
  }
  
}

Imports Microsoft.SqlServer.Dts.Runtime
  
Module Module1
  
  Sub Main()
  
    ' Create a package, and retrieve its connections.
    Dim pkg As New Package()
    Dim pkgConns As Connections = pkg.Connections
  
    ' Add an OLE DB connection to the package, using the
    ' method defined in the AddConnection class.
    Dim myOLEDBConn As New CreateConnection()
    myOLEDBConn.CreateOLEDBConnection(pkg)
  
    ' View the new connection in the package.
    Console.WriteLine("Connection description: {0}", _
      pkg.Connections("SSIS Connection Manager for OLE DB").Description)
  
    ' Add a second connection to the package.
    Dim myFileConn As New CreateConnection()
    myFileConn.CreateFileConnection(pkg)
  
    ' View the second connection in the package.
    Console.WriteLine("Connection description: {0}", _
      pkg.Connections("SSIS Connection Manager for Files").Description)
  
    Console.WriteLine()
    Console.WriteLine("Number of connections in package: {0}", pkg.Connections.Count)
  
    Console.Read()
  
  End Sub
  
End Module
  
' This class contains the definitions for multiple
' connection managers.
  
Public Class CreateConnection
  ' Private data.
  Private ConMgr As ConnectionManager
  
  ' Class definition for OLE DB provider.
  Public Sub CreateOLEDBConnection(ByVal p As Package)
    ConMgr = p.Connections.Add("OLEDB")
    ConMgr.ConnectionString = "Provider=SQLOLEDB.1;" & _
      "Integrated Security=SSPI;Initial Catalog=AdventureWorks;" & _
      "Data Source=(local);"
    ConMgr.Name = "SSIS Connection Manager for OLE DB"
    ConMgr.Description = "OLE DB connection to the AdventureWorks database."
  End Sub
  
  Public Sub CreateFileConnection(ByVal p As Package)
    ConMgr = p.Connections.Add("File")
    ConMgr.ConnectionString = "\\<yourserver>\<yourfolder>\books.xml"
    ConMgr.Name = "SSIS Connection Manager for Files"
    ConMgr.Description = "Flat File connection"
  End Sub
  
End Class

Przykładowe dane wyjściowe:

Connection description: OLE DB connection to the AdventureWorks database.

Connection description: Flat File connection.

Number of connections in package: 2

Treści powiązane

  • Last updated on