스크립트 구성 요소를 사용하여 대상 만들기

아티클
05/07/2013

Integration Services 패키지의 데이터 흐름에서 대상 구성 요소를 사용하여 업스트림 원본 및 변환에서 받은 데이터를 데이터 원본에 저장할 수 있습니다. 일반적으로 대상 구성 요소는 기존 연결 관리자를 통해 데이터 원본에 연결합니다.

스크립트 구성 요소에 대한 개요는 스크립트 구성 요소를 사용하여 데이터 흐름 확장을 참조하십시오.

스크립트 구성 요소 및 해당 구성 요소가 생성하는 인프라 코드를 사용하면 사용자 지정 데이터 흐름 구성 요소를 개발하는 과정이 훨씬 간단해집니다. 하지만 스크립트 구성 요소의 작동 방식을 이해하려면 사용자 지정 데이터 흐름 구성 요소 개발 섹션과 이 섹션의 사용자 지정 대상 구성 요소 개발을 통해 사용자 지정 데이터 흐름 구성 요소를 개발하는 데 필요한 단계를 파악하는 것이 좋습니다.

대상 구성 요소 시작

SSIS 디자이너의 데이터 흐름 탭에 스크립트 구성 요소를 추가하면 원본, 대상 또는 변환 스크립트를 선택하기 위한 스크립트 구성 요소 유형 선택 대화 상자가 열립니다. 이 대화 상자에서 대상을 선택합니다.

그런 다음 SSIS 디자이너에서 변환의 출력을 대상 구성 요소에 연결합니다. 테스트를 위해 변환하지 않고 원본을 대상에 직접 연결할 수 있습니다.

메타데이터 디자인 모드에서 대상 구성 요소 구성

대상 구성 요소를 만드는 옵션을 선택한 후에는 스크립트 변환 편집기를 사용하여 구성 요소를 구성합니다. 자세한 내용은 스크립트 구성 요소 편집기에서 스크립트 구성 요소 구성을 참조하십시오.

스크립트 대상에서 사용할 스크립트 언어를 선택하려면 스크립트 변환 편집기 대화 상자의 스크립트 페이지에서 ScriptLanguage 속성을 설정합니다.

[!참고]

스크립트 구성 요소에 대한 기본 스크립트 언어를 설정하려면 옵션 대화 상자의 일반 페이지에서 스크립트 언어 옵션을 사용합니다. 자세한 내용은 일반 페이지를 참조하십시오.

데이터 흐름 대상 구성 요소에는 하나의 입력이 포함되며 출력은 포함되지 않습니다. 구성 요소의 입력을 구성하는 것은 사용자 지정 스크립트를 작성하기 전에 메타데이터 디자인 모드에서 스크립트 변환 편집기를 사용하여 완료해야 하는 단계 중 하나입니다.

연결 관리자 추가

일반적으로 대상 구성 요소는 기존 연결 관리자를 사용하여 데이터 흐름에서 받은 데이터를 저장할 데이터 원본에 연결합니다. 적절한 연결 관리자를 추가하려면 스크립트 변환 편집기의 연결 관리자 페이지에서 추가를 클릭합니다.

그러나 연결 관리자는 단지 특정 유형의 데이터 원본에 연결하는 데 필요한 정보를 캡슐화하고 저장하는 편리한 단위일 뿐입니다. 데이터를 로드하거나 저장하고 데이터 원본에 대한 연결을 열고 닫는 사용자 지정 코드는 사용자가 직접 작성해야 합니다.

스크립트 구성 요소에서 연결 관리자를 사용하는 방법은 스크립트 구성 요소에서 데이터 원본에 연결을 참조하십시오.

스크립트 변환 편집기의 연결 관리자 페이지에 대한 자세한 내용은 스크립트 변환 편집기(연결 관리자 페이지)를 참조하십시오.

입력 및 입력 열 구성

대상 구성 요소에는 하나의 입력이 포함되며 출력은 포함되지 않습니다.

스크립트 변환 편집기의 입력 열 페이지에 나타나는 열 목록에는 업스트림 데이터 흐름 구성 요소의 출력에서 가져온 사용 가능한 열이 표시됩니다. 이 목록에서 저장할 열을 선택합니다.

스크립트 변환 편집기의 입력 열 페이지에 대한 자세한 내용은 스크립트 변환 편집기(입력 열 페이지)를 참조하십시오.

스크립트 변환 편집기의 입/출력 페이지에는 이름을 바꿀 수 있는 단일 입력이 표시됩니다. 스크립트에서는 자동 생성 코드에서 만들어진 접근자 속성을 사용하여 입력을 이름으로 참조합니다.

스크립트 변환 편집기의 입/출력 페이지에 대한 자세한 내용은 스크립트 변환 편집기(입/출력 페이지)를 참조하십시오.

변수 추가

스크립트에 기존 변수를 사용하려면 스크립트 변환 편집기의 스크립트 페이지에서 ReadOnlyVariables 및 ReadWriteVariables 속성 필드에 해당 변수를 추가합니다.

속성 필드에 여러 변수를 추가하는 경우 변수 이름을 쉼표로 구분하십시오. ReadOnlyVariables 및 ReadWriteVariables 속성 필드 옆의 줄임표(…) 단추를 클릭한 다음 변수 선택 대화 상자에서 여러 개의 변수를 선택할 수도 있습니다.

스크립트 구성 요소에서 변수를 사용하는 방법은 스크립트 구성 요소에서 변수 사용을 참조하십시오.

스크립트 변환 편집기의 스크립트 페이지에 대한 자세한 내용은 스크립트 변환 편집기(스크립트 페이지)를 참조하십시오.

코드 디자인 모드에서 대상 구성 요소 스크립팅

구성 요소에 대한 메타데이터를 구성한 후에는 사용자 지정 스크립트를 작성할 수 있습니다. 스크립트 변환 편집기의 스크립트 페이지에서 스크립트 편집을 클릭하여 사용자 지정 스크립트를 추가할 수 있는 Microsoft VSTA(Visual Studio Tools for Applications) IDE를 엽니다. 사용하는 스크립트 언어는 스크립트 페이지의 ScriptLanguage 속성에서 스크립트 언어로 Microsoft Visual Basic 또는 Microsoft Visual C# 중 어느 것을 선택했는지에 따라 달라집니다.

스크립트 구성 요소를 사용하여 만든 모든 종류의 구성 요소에 적용되는 자세한 정보는 스크립트 구성 요소 코딩 및 디버깅을 참조하십시오.

자동 생성 코드 이해

대상 구성 요소를 만들고 구성한 후 VSTA IDE를 열면 편집 가능한 ScriptMain 클래스가 ProcessInputRow 메서드에 대한 스텁과 함께 코드 편집기에 나타납니다. 이 ScriptMain 클래스에서 사용자 지정 코드를 작성해야 하며 ProcessInputRow는 대상 구성 요소에서 가장 중요한 메서드입니다.

VSTA에서 프로젝트 탐색기 창을 열면 스크립트 구성 요소가 읽기 전용 BufferWrapper 및 ComponentWrapper 프로젝트 항목도 생성했음을 확인할 수 있습니다. ScriptMain 클래스는 ComponentWrapper 프로젝트 항목의 UserComponent 클래스에서 상속됩니다.

런타임에 데이터 흐름 엔진은 ScriptComponent 부모 클래스의 ProcessInput 메서드를 재정의하는 UserComponent 클래스의 ProcessInput 메서드를 호출합니다. 그러면 ProcessInput 메서드는 입력 버퍼의 행을 반복하고 각 행에 대해 ProcessInputRow 메서드를 한 번씩 호출합니다.

사용자 지정 코드 작성

사용자 지정 대상 구성 요소 만들기를 마치기 위해 ScriptMain 클래스에서 사용할 수 있는 다음 메서드에서 스크립트를 작성할 수 있습니다.

AcquireConnections 메서드를 재정의하여 외부 데이터 원본에 연결합니다. 연결 관리자에서 연결 개체나 필요한 연결 정보를 추출합니다.
PreExecute 메서드를 재정의하여 데이터를 저장하기 위한 준비를 합니다. 예를 들어 이 메서드에서 SqlCommand와 해당 매개 변수를 만들고 구성할 수 있습니다.
재정의된 ProcessInputRow 메서드를 사용하여 각 입력 행을 외부 데이터 원본에 복사합니다. 예를 들어 SQL Server 대상의 경우 열 값을 SqlCommand의 매개 변수에 복사하고 각 행에 대해 이 명령을 한 번씩 실행할 수 있습니다. 플랫 파일 대상의 경우 각 열의 값을 열 구분 기호로 구분하여 StreamWriter에 쓸 수 있습니다.
PostExecute 메서드를 재정의하여 필요할 경우 외부 데이터 원본과의 연결을 끊고 그 밖에 필요한 정리 작업을 수행합니다.

예

다음 예에서는 ScriptMain 클래스에서 대상 구성 요소를 만드는 데 필요한 코드를 보여 줍니다.

[!참고]

이 예에서는 AdventureWorks 예제 데이터베이스의 Person.Address 테이블을 사용하고 이 테이블의 첫 번째 열인 int AddressID와 네 번째 열인 nvarchar(30) City를 데이터 흐름을 통해 전달합니다. 이 섹션의 원본, 변환 및 대상 예제에는 동일한 데이터가 사용됩니다. 각 예에 대해 필수 구성 요소 및 가정도 설명되어 있습니다.

ADO.NET 대상 예

이 예에서는 기존 ADO.NET 연결 관리자를 사용하여 데이터 흐름에서 받은 데이터를 SQL Server 테이블에 저장하는 대상 구성 요소를 보여 줍니다.

이 예제 코드를 실행하려면 다음과 같이 패키지와 구성 요소를 구성해야 합니다.

SqlClient 공급자를 사용하여 AdventureWorks 데이터베이스에 연결하는 ADO.NET 연결 관리자를 만듭니다.
AdventureWorks 데이터베이스에서 다음 Transact-SQL 명령을 실행하여 대상 테이블을 만듭니다.
```
CREATE TABLE [Person].[Address2](
    [AddressID] [int] NOT NULL,
    [City] [nvarchar](30) NOT NULL
)
```
데이터 흐름 디자이너 화면에 새 스크립트 구성 요소를 추가하고 이 구성 요소를 대상으로 구성합니다.
업스트림 원본 또는 변환의 출력을 SSIS 디자이너의 대상 구성 요소에 연결합니다. 변환하지 않고 원본을 대상에 직접 연결할 수 있습니다. 이 출력은 AdventureWorks 예제 데이터베이스의 Person.Address 테이블에서 적어도 AddressID 및 City 열이 포함된 데이터를 제공해야 합니다.
스크립트 변환 편집기를 엽니다. 입력 열 페이지에서 AddressID 및 City 입력 열을 선택합니다.
입/출력 페이지에서 입력의 이름을 MyAddressInput과 같이 보다 알기 쉬운 이름으로 바꿉니다.
연결 관리자 페이지에서 MyADONETConnectionManager와 같은 이름으로 ADO.NET 연결 관리자를 추가하거나 만듭니다.
스크립트 페이지에서 스크립트 편집을 클릭하고 다음과 같이 스크립트를 입력합니다. 그런 다음 스크립트 개발 환경을 닫습니다.
스크립트 변환 편집기를 닫고 예제를 실행합니다.

Imports System.Data.SqlClient
...
Public Class ScriptMain
    Inherits UserComponent

    Dim connMgr As IDTSConnectionManager100
    Dim sqlConn As SqlConnection
    Dim sqlCmd As SqlCommand
    Dim sqlParam As SqlParameter

    Public Overrides Sub AcquireConnections(ByVal Transaction As Object)

        connMgr = Me.Connections.MyADONETConnectionManager
        sqlConn = CType(connMgr.AcquireConnection(Nothing), SqlConnection)

    End Sub

    Public Overrides Sub PreExecute()

        sqlCmd = New SqlCommand("INSERT INTO Person.Address2(AddressID, City) " & _
            "VALUES(@addressid, @city)", sqlConn)
        sqlParam = New SqlParameter("@addressid", SqlDbType.Int)
        sqlCmd.Parameters.Add(sqlParam)
        sqlParam = New SqlParameter("@city", SqlDbType.NVarChar, 30)
        sqlCmd.Parameters.Add(sqlParam)

    End Sub

    Public Overrides Sub MyAddressInput_ProcessInputRow(ByVal Row As MyAddressInputBuffer)
        With sqlCmd
            .Parameters("@addressid").Value = Row.AddressID
            .Parameters("@city").Value = Row.City
            .ExecuteNonQuery()
        End With
    End Sub

    Public Overrides Sub ReleaseConnections()

        connMgr.ReleaseConnection(sqlConn)

    End Sub

End Class

using System.Data.SqlClient;
public class ScriptMain:
    UserComponent

{
    IDTSConnectionManager100 connMgr;
    SqlConnection sqlConn;
    SqlCommand sqlCmd;
    SqlParameter sqlParam;

    public override void AcquireConnections(object Transaction)
    {

        connMgr = this.Connections.MyADONETConnectionManager;
        sqlConn = (SqlConnection)connMgr.AcquireConnection(null);

    }

    public override void PreExecute()
    {

        sqlCmd = new SqlCommand("INSERT INTO Person.Address2(AddressID, City) " +
            "VALUES(@addressid, @city)", sqlConn);
        sqlParam = new SqlParameter("@addressid", SqlDbType.Int);
        sqlCmd.Parameters.Add(sqlParam);
        sqlParam = new SqlParameter("@city", SqlDbType.NVarChar, 30);
        sqlCmd.Parameters.Add(sqlParam);

    }

    public override void MyAddressInput_ProcessInputRow(MyAddressInputBuffer Row)
    {
        {
            sqlCmd.Parameters["@addressid"].Value = Row.AddressID;
            sqlCmd.Parameters["@city"].Value = Row.City;
            sqlCmd.ExecuteNonQuery();
        }
    }

    public override void ReleaseConnections()
    {

        connMgr.ReleaseConnection(sqlConn);

    }

}

플랫 파일 대상의 예

이 예에서는 기존 플랫 파일 연결 관리자를 사용하여 데이터 흐름에서 받은 데이터를 플랫 파일에 저장하는 대상 구성 요소를 보여 줍니다.

이 예제 코드를 실행하려면 다음과 같이 패키지와 구성 요소를 구성해야 합니다.

대상 파일에 연결하는 플랫 파일 연결 관리자를 만듭니다. 대상 파일이 없는 경우에는 대상 구성 요소가 대상 파일을 만듭니다. 대상 파일을 AddressID 및 City 열이 들어 있는 쉼표로 구분된 파일로 구성합니다.
데이터 흐름 디자이너 화면에 새 스크립트 구성 요소를 추가하고 이 구성 요소를 대상으로 구성합니다.
업스트림 원본 또는 변환의 출력을 SSIS 디자이너의 대상 구성 요소에 연결합니다. 변환하지 않고 원본을 대상에 직접 연결할 수 있습니다. 이 출력은 AdventureWorks 예제 데이터베이스의 Person.Address 테이블의 데이터를 제공해야 하며 적어도 AddressID 및 City 열을 포함해야 합니다.
스크립트 변환 편집기를 엽니다. 입력 열 페이지에서 AddressID 및 City 열을 선택합니다.
입/출력 페이지에서 입력의 이름을 MyAddressInput과 같이 보다 알기 쉬운 이름으로 바꿉니다.
연결 관리자 페이지에서 MyFlatFileDestConnectionManager와 같이 알기 쉬운 이름으로 플랫 파일 연결 관리자를 추가하거나 만듭니다.
스크립트 페이지에서 스크립트 편집을 클릭하고 다음과 같이 스크립트를 입력합니다. 그런 다음 스크립트 개발 환경을 닫습니다.
스크립트 변환 편집기를 닫고 예제를 실행합니다.

Imports System.IO
...
Public Class ScriptMain
    Inherits UserComponent

    Dim copiedAddressFile As String
    Private textWriter As StreamWriter
    Private columnDelimiter As String = ","

    Public Overrides Sub AcquireConnections(ByVal Transaction As Object)

        Dim connMgr As IDTSConnectionManager100 = _
            Me.Connections.MyFlatFileDestConnectionManager
        copiedAddressFile = CType(connMgr.AcquireConnection(Nothing), String)

    End Sub

    Public Overrides Sub PreExecute()

        textWriter = New StreamWriter(copiedAddressFile, False)

    End Sub

    Public Overrides Sub MyAddressInput_ProcessInputRow(ByVal Row As MyAddressInputBuffer)

        With textWriter
            If Not Row.AddressID_IsNull Then
                .Write(Row.AddressID)
            End If
            .Write(columnDelimiter)
            If Not Row.City_IsNull Then
                .Write(Row.City)
            End If
            .WriteLine()
        End With

    End Sub

    Public Overrides Sub PostExecute()

        textWriter.Close()

    End Sub

End Class

using System.IO;
public class ScriptMain:
    UserComponent

{
    string copiedAddressFile;
    private StreamWriter textWriter;
    private string columnDelimiter = ",";

    public override void AcquireConnections(object Transaction)
    {

        IDTSConnectionManager100 connMgr = this.Connections.MyFlatFileDestConnectionManager;
        copiedAddressFile = (string) connMgr.AcquireConnection(null);

    }

    public override void PreExecute()
    {

        textWriter = new StreamWriter(copiedAddressFile, false);

    }

    public override void MyAddressInput_ProcessInputRow(MyAddressInputBuffer Row)
    {

        {
            if (!Row.AddressID_IsNull)
            {
                textWriter.Write(Row.AddressID);
            }
            textWriter.Write(columnDelimiter);
            if (!Row.City_IsNull)
            {
                textWriter.Write(Row.City);
            }
            textWriter.WriteLine();
        }

    }

    public override void PostExecute()
    {

        textWriter.Close();

    }

}

Integration Services 관련 최신 정보 얻기

Microsoft의 최신 다운로드, 문서, 예제 및 비디오와 커뮤니티에서 선택된 솔루션을 보려면 MSDN의 Integration Services 페이지를 방문하십시오.

MSDN의 Integration Services 페이지를 방문하십시오.

이러한 업데이트에 대한 자동 알림을 받으려면 해당 페이지에서 제공하는 RSS 피드를 구독하십시오.

참고 항목

개념

스크립트 구성 요소를 사용하여 원본 만들기

사용자 지정 대상 구성 요소 개발