Bagikan melalui

Menjalankan paket SSIS dengan kode C# di aplikasi .NET

  • Artikel

Berlaku untuk: SQL Server SSIS Integration Runtime di Azure Data Factory

Mulai cepat ini menunjukkan cara menulis kode C# untuk menyambungkan ke server database dan menjalankan paket SSIS.

Anda dapat menggunakan Visual Studio, Visual Studio Code, atau alat lain pilihan Anda untuk membuat aplikasi C#.

Prasyarat

Sebelum memulai, pastikan Anda telah menginstal Visual Studio atau Visual Studio Code. Unduh Visual Studio edisi Komunitas gratis, atau Visual Studio Code gratis, dari Unduhan Visual Studio.

Server Azure SQL Database mendengarkan port 1433. Jika Anda mencoba menyambungkan ke server Azure SQL Database dari dalam firewall perusahaan, port ini harus terbuka di firewall perusahaan agar Anda berhasil tersambung.

Untuk Azure SQL Database, dapatkan info koneksi

Untuk menjalankan paket di Azure SQL Database, dapatkan informasi koneksi yang Anda butuhkan untuk menyambungkan ke database Katalog SSIS (SSISDB). Anda memerlukan nama server dan informasi masuk yang sepenuhnya memenuhi syarat dalam prosedur berikut.

  1. Masuk ke portal Azure.
  2. Pilih SQL Database dari menu sebelah kiri, lalu pilih database SSISDB di halaman database SQL.
  3. Pada halaman Gambaran Umum untuk database Anda, tinjau nama server yang sepenuhnya memenuhi syarat. Untuk melihat opsi Klik untuk menyalin , arahkan kursor ke nama server.
  4. Jika Anda lupa informasi masuk server Azure SQL Database Anda, navigasikan ke halaman server SQL Database untuk melihat nama admin server. Anda dapat mengatur ulang kata sandi jika perlu.
  5. Klik Perlihatkan string koneksi database.
  6. Tinjau string koneksi ADO.NET lengkap. Secara opsional, kode Anda dapat menggunakan SqlConnectionStringBuilder untuk membuat ulang string koneksi ini dengan nilai parameter individual yang Anda berikan.

Membuat proyek Visual Studio baru

  1. Di Visual Studio, pilih File, Baru, Proyek.
  2. Dalam dialog Proyek Baru, dan perluas Visual C#.
  3. Pilih Aplikasi Konsol dan masukkan run_ssis_project untuk nama proyek.
  4. Klik OK untuk membuat dan membuka proyek baru di Visual Studio.

Menambahkan referensi

  1. Di Penjelajah Solusi, klik kanan folder Referensi dan pilih Tambahkan Referensi. Kotak dialog Manajer Referensi terbuka.
  2. Dalam kotak dialog Manajer Referensi, perluas Rakitan dan pilih Ekstensi.
  3. Pilih dua referensi berikut untuk ditambahkan:
    • Microsoft.SqlServer.Management.Sdk.Sfc
    • Microsoft.SqlServer.Smo
  4. Klik tombol Telusuri untuk menambahkan referensi ke Microsoft.SqlServer.Management.IntegrationServices. (Rakitan ini hanya diinstal di cache perakitan global (GAC).) Kotak dialog Pilih file yang akan dirujuk terbuka.
  5. Dalam kotak dialog Pilih file untuk direferensikan , navigasikan ke folder GAC yang berisi rakitan. Biasanya folder ini adalah C:\Windows\assembly\GAC_MSIL\Microsoft.SqlServer.Management.IntegrationServices\14.0.0.0__89845dcd8080cc91.
  6. Pilih rakitan (yaitu, file .dll) di folder dan klik Tambahkan.
  7. Klik OK untuk menutup kotak dialog Manajer Referensi dan menambahkan tiga referensi. Untuk memastikan referensi ada di sana, periksa daftar Referensi di Penjelajah Solusi.

Menambahkan kode C#

  1. Buka Program.cs.

  2. Ganti konten Program.cs dengan kode berikut. Tambahkan nilai yang sesuai untuk server, database, pengguna, dan kata sandi Anda.

Catatan

Contoh berikut menggunakan Autentikasi Windows. Untuk menggunakan autentikasi SQL Server, ganti Integrated Security=SSPI; argumen dengan User ID=<user name>;Password=<password>;. Jika Anda menyambungkan ke server Azure SQL Database, Anda tidak dapat menggunakan autentikasi Windows.

using Microsoft.SqlServer.Management.IntegrationServices;
using System.Data.SqlClient;

namespace run_ssis_package
{
    class Program
    {
        static void Main(string[] args)
        {
            // Variables
            string targetServerName = "localhost";
            string folderName = "Project1Folder";
            string projectName = "Integration Services Project1";
            string packageName = "Package.dtsx";

            // Create a connection to the server
            string sqlConnectionString = "Data Source=" + targetServerName +
                ";Initial Catalog=master;Integrated Security=SSPI;";
            SqlConnection sqlConnection = new SqlConnection(sqlConnectionString);

            // Create the Integration Services object
            IntegrationServices integrationServices = new IntegrationServices(sqlConnection);

            // Get the Integration Services catalog
            Catalog catalog = integrationServices.Catalogs["SSISDB"];

            // Get the folder
            CatalogFolder folder = catalog.Folders[folderName];

            // Get the project
            ProjectInfo project = folder.Projects[projectName];

            // Get the package
            PackageInfo package = project.Packages[packageName];

            // Run the package
            package.Execute(false, null);

        }
    }
}

Menjalankan kode

  1. Untuk menjalankan aplikasi, tekan F5.
  2. Verifikasi bahwa paket berjalan seperti yang diharapkan lalu tutup jendela aplikasi.

Langkah berikutnya