다음을 통해 공유

로컬 패키지의 출력 로드

  • 아티클

클라이언트 애플리케이션은 출력이 ADO.NET 사용하여 SQL Server 대상에 저장되거나 출력이 System.IO 네임스페이스의 클래스를 사용하여 플랫 파일 대상에 저장되는 경우 Integration Services 패키지의 출력을 읽을 수 있습니다. 그러나 클라이언트 애플리케이션은 데이터를 유지하기 위한 중간 단계 없이 메모리에서 직접 패키지의 출력을 읽을 수도 있습니다. 이 솔루션의 핵심은 System.Data 네임스페이 Microsoft.SqlServer.Dts.DtsClient 스의 IDbConnectionIDbCommand특수화된 구현 및 IDbDataParameter 인터페이스를 포함하는 네임스페이스입니다. 어셈블리 Microsoft.SqlServer.Dts.DtsClient.dll %ProgramFiles%\Microsoft SQL Server\100\DTS\Binn에 기본적으로 설치됩니다.

참고 항목

이 항목에 설명된 절차에서는 데이터 흐름 태스크 및 부모 개체의 DelayValidation 속성을 기본값인 False로 설정해야 합니다.

설명

이 절차에서는 메모리에서 직접 DataReader 대상을 사용하여 패키지의 출력을 로드하는 관리 코드에서 클라이언트 애플리케이션을 개발하는 방법을 보여 줍니다. 여기에 요약된 단계는 다음 코드 샘플에 설명되어 있습니다.

데이터 패키지 출력을 클라이언트 애플리케이션으로 로드하려면

  1. 패키지에서 클라이언트 애플리케이션에 읽으려는 출력을 수신하도록 DataReader 대상을 구성합니다. 나중에 클라이언트 애플리케이션에서 이 이름을 사용하므로 DataReader 대상에 설명이 포함된 이름을 지정합니다. DataReader 대상의 이름을 기록해 둡다.

  2. 개발 프로젝트에서 어셈블리 Microsoft.SqlServer.Dts.DtsClient.dll 찾아 네임스페이스에 대한 참조 Microsoft.SqlServer.Dts.DtsClient 를 설정합니다. 기본적으로 이 어셈블리는 C:\Program Files\Microsoft SQL Server\100\DTS\Binn에 설치됩니다. C# Using 또는 Visual Basic Imports 문을 사용하여 네임스페이스를 코드로 가져옵니다.

  3. 코드에서 dtexec.exe 패키지를 실행하는 데 필요한 명령줄 매개 변수가 포함된 연결 문자열 사용하여 형식 DtsClient.DtsConnection 의 개체를 만듭니다. 자세한 내용은 dtexec Utility를 참조하세요. 그런 다음 이 연결 문자열을 사용하여 연결을 엽니다. dtexecui 유틸리티를 사용하여 필요한 연결 문자열 시각적으로 만들 수도 있습니다.

    참고 항목

    샘플 코드는 구문을 사용하여 파일 시스템에서 패키지를 로드하는 방법을 /FILE <path and filename> 보여 줍니다. 그러나 구문을 사용하거나 구문을 사용하여 /SQL <package name> /DTS \<folder name>\<package name> Integration Services 패키지 저장소에서 MSDB 데이터베이스에서 패키지를 로드할 수도 있습니다.

  4. 이전에 만든 형식 DtsClient.DtsCommand 의 개체를 만들고 DtsConnection 해당 CommandText 속성을 패키지의 DataReader 대상 이름으로 설정합니다. 그런 다음 명령 개체의 메서드를 호출 ExecuteReader 하여 패키지 결과를 새 DataReader로 로드합니다.

  5. 필요에 따라 개체의 개체 컬렉션을 사용하여 패키지에 정의된 변수에 DtsCommand 값을 전달하여 패키지의 DtsDataParameter 출력을 간접적으로 매개 변수화할 수 있습니다. 패키지 내에서 이러한 변수를 쿼리 매개 변수로 사용하거나 식에서 DataReader 대상으로 반환된 결과에 영향을 줄 수 있습니다. 클라이언트 애플리케이션의 개체와 함께 사용하려면 먼저 DtsClient 네임스페이스의 패키지에서 이러한 변수를 DtsDataParameter 정의해야 합니다. (다음을 클릭해야 할 수 있습니다.변수 창에서 변수 열 도구 모음 단추를 선택하여 네임스페이스 열을 표시합니다.) 클라이언트 코드에서 컬렉션DtsCommand에 추가할 DtsDataParameter Parameters 때 변수 이름에서 DtsClient 네임스페이스 참조를 생략합니다. 예시:

    command.Parameters.Add(new DtsDataParameter("MyVariable", 1));

  6. Read 필요에 따라 DataReader의 메서드를 반복적으로 호출하여 출력 데이터의 행을 반복합니다. 클라이언트 애플리케이션에서 데이터를 사용하거나 나중에 사용할 수 있는 데이터를 저장합니다.

    Important

    DataReader 구현의 메서드는 Read 데이터의 마지막 행을 읽은 후 한 번 더 반환 true 합니다. 따라서 반환true하는 동안 Read DataReader를 반복하는 일반적인 코드를 사용하기가 어렵습니다. 코드가 메서드에 대한 추가 최종 호출 Read 없이 예상 행 수를 읽은 후 DataReader 또는 연결을 닫으려고 하면 코드에서 처리되지 않은 예외가 발생합니다. 그러나 코드가 루프 Read 를 통해 이 최종 반복의 데이터를 읽으려고 시도하는 경우 여전히 반환 true 되지만 마지막 행이 전달된 경우 코드는 "SSIS IDataReader가 결과 집합의 끝을 지났습니다."라는 메시지와 함께 처리 ApplicationException 되지 않은 상태로 발생합니다. 이 동작은 다른 DataReader 구현의 동작과 다릅니다. 따라서 루프를 사용하여 반환하는 동안 Read DataReader의 행을 읽는 경우 메서드에 대한 마지막 성공적인 호출에서 예상한 ApplicationException 것을 catch, 테스트 및 삭제하는 Read 코드를 작성해야 true합니다. 또는 예상되는 행 수를 미리 알고 있는 경우 행을 처리한 다음 DataReader 및 연결을 닫기 전에 메서드를 한 번 더 호출 Read 할 수 있습니다.

  7. 개체의 Dispose 메서드를 호출합니다 DtsCommand . 개체를 사용한 DtsDataParameter 경우 특히 중요합니다.

  8. DataReader와 연결 개체를 닫습니다.

예시

다음 예제에서는 단일 집계 값을 계산하고 DataReader 대상에 값을 저장하는 패키지를 실행한 다음 DataReader에서 이 값을 읽고 Windows Form의 텍스트 상자에 값을 표시합니다.

클라이언트 애플리케이션에 패키지의 출력을 로드할 때는 매개 변수를 사용할 필요가 없습니다. 매개 변수를 사용하지 않으려면 DtsClient 네임스페이스에서 변수 사용을 생략하고 개체를 사용하는 DtsDataParameter 코드를 생략할 수 있습니다.

테스트 패키지를 만들려면

  1. 새 Integration Services 패키지를 만듭니다. 샘플 코드는 패키지 이름으로 "DtsClientWParamPkg.dtsx"를 사용합니다.

  2. DtsClient 네임스페이스에 String 형식의 변수를 추가합니다. 샘플 코드는 변수 이름으로 Country를 사용합니다. (다음을 클릭해야 할 수 있습니다.변수 창에서 변수 열 도구 모음 단추를 선택하여 네임스페이스 열을 표시합니다.)

  3. AdventureWorks2012 샘플 데이터베이스에 연결하는 OLE DB 연결 관리자를 추가합니다.

  4. 패키지에 데이터 흐름 태스크를 추가하고 데이터 흐름 디자인 화면으로 전환합니다.

  5. 데이터 흐름에 OLE DB 원본을 추가하고 이전에 만든 OLE DB 연결 관리자와 다음 SQL 명령을 사용하도록 구성합니다.

    SELECT * FROM Sales.vIndividualCustomer WHERE CountryRegionName = ?

  6. 쿼리 Parameters 매개 변수 설정 대화 상자에서 쿼리 매개 변수 0의 단일 입력 매개 변수를 DtsClient::Country 변수에 매핑합니다.

  7. 데이터 흐름에 집계 변환을 추가하고 OLE DB 원본의 출력을 변환에 연결합니다. 집계 변환 편집기를 열고 모든 입력 열(*)에서 "모두 계산" 작업을 수행하고 CustomerCount 별칭을 사용하여 집계된 값을 출력하도록 구성합니다.

  8. 데이터 흐름에 DataReader 대상을 추가하고 집계 변환의 출력을 DataReader 대상에 연결합니다. 샘플 코드는 DataReader의 이름으로 "DataReaderDest"를 사용합니다. 대상에 대해 사용 가능한 단일 입력 열인 CustomerCount를 선택합니다.

  9. 패키지를 저장합니다. 다음에 만든 테스트 애플리케이션은 패키지를 실행하고 메모리에서 직접 출력을 검색합니다.

테스트 애플리케이션을 만들려면

  1. 새 Windows Forms 애플리케이션을 만듭니다.

  2. %ProgramFiles%\Microsoft SQL Server\100\DTS\Binn에서 같은 이름의 어셈블리로 이동하여 네임스페이스에 대한 참조 Microsoft.SqlServer.Dts.DtsClient 를 추가합니다.

  3. 다음 샘플 코드를 복사하여 양식의 코드 모듈에 붙여넣습니다.

  4. dtexec.exe 패키지를 실행하는 데 필요한 명령줄 매개 변수를 포함하도록 필요에 따라 변수 값을 dtexecArgs 수정합니다. 샘플 코드는 파일 시스템에서 패키지를 로드합니다.

  5. 패키지에 DataReader 대상의 dataReaderName 이름을 포함할 수 있도록 필요에 따라 변수 값을 수정합니다.

  6. 폼에 단추와 입력란을 추가합니다. 샘플 코드는 단추 txtResults 의 이름과 텍스트 상자의 이름으로 사용합니다btnRun.

  7. 애플리케이션을 실행하고 단추를 클릭합니다. 패키지가 실행되는 동안 잠시 일시 중지한 후 양식의 텍스트 상자에 패키지(캐나다 고객 수)가 계산한 집계 값이 표시됩니다.

예제 코드

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;

    }
  }
}

Integration Services 아이콘(작음) Integration Services를 사용하여 최신 상태 유지
Microsoft의 최신 다운로드, 문서, 샘플 및 비디오와 커뮤니티에서 선택한 솔루션은 MSDN의 Integration Services 페이지를 방문하세요.

MSDN의 Integration Services 페이지 방문

이러한 업데이트에 대한 자동 알림을 보려면 페이지에서 사용할 수 있는 RSS 피드를 구독합니다.

참고 항목

프로그래밍 방식으로 원격 패키지를 프로그래밍 방식으로로드하고 실행하는 로컬 패키지의 로컬 및 원격 실행로드 및 실행 간의 차이점 이해