[C#/DAPPER] SYS_REFCURSOR 출력 타입의 입력 매개 변수를 갖는 오라클 저장 프로시저 호출하기

728x90

반응형

728x170

TestProject.zip

다운로드

▶ 저장 프로시저

CREATE OR REPLACE PROCEDURE SCOTT.GETMEMBERLIST
(
    I_NAME   IN  VARCHAR2,
    O_CURSOR OUT SYS_REFCURSOR
)
IS
BEGIN
    OPEN O_CURSOR FOR
        SELECT *
        FROM   SCOTT.EMP
        WHERE  ENAME LIKE I_NAME || '%';
END;

※ 오라클 11G의 경우 설치하면 SCOTT 계정이 설치되어 있다.

 

728x90

 

▶ OracleDynamicParameter.cs

using System.Collections.Generic;
using System.Data;

using Dapper;

using Oracle.ManagedDataAccess.Client;

namespace TestProject
{
    /// <summary>
    /// 오라클 동적 매개 변수 목록
    /// </summary>
    public class OracleDynamicParameters : SqlMapper.IDynamicParameters
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Field
        ////////////////////////////////////////////////////////////////////////////////////////// Private

        #region Field

        /// <summary>
        /// 동적 매개 변수 목록
        /// </summary>
        private readonly DynamicParameters dynamicParameters = new DynamicParameters();

        /// <summary>
        /// 오라클 매개 변수 리스트
        /// </summary>
        private readonly List<OracleParameter> oracleParameterList = new List<OracleParameter>();

        #endregion

        //////////////////////////////////////////////////////////////////////////////////////////////////// Constructor
        ////////////////////////////////////////////////////////////////////////////////////////// Public

        #region 추가하기 - Add(name, value, dbType, direction, size)

        /// <summary>
        /// 추가하기
        /// </summary>
        /// <param name="name">명칭</param>
        /// <param name="value">값</param>
        /// <param name="dbType">DB 타입</param>
        /// <param name="direction">방향</param>
        /// <param name="size">크기</param>
        public void Add(string name, object value = null, DbType? dbType = null, ParameterDirection? direction = null, int? size = null)
        {
            this.dynamicParameters.Add(name, value, dbType, direction, size);
        }

        #endregion
        #region 추가하기 - Add(name, oracleDbType, direction)

        /// <summary>
        /// 추가하기
        /// </summary>
        /// <param name="name">명칭</param>
        /// <param name="oracleDbType">오라클 DB 타입</param>
        /// <param name="direction">방향</param>
        public void Add(string name, OracleDbType oracleDbType, ParameterDirection direction)
        {
            OracleParameter parameter = new OracleParameter(name, oracleDbType, direction);

            this.oracleParameterList.Add(parameter);
        }

        #endregion

        #region (SqlMapper.IDynamicParameters) 매개 변수 목록 추가하기 - AddParameters(command, identity)

        /// <summary>
        /// 매개 변수 목록 추가하기
        /// </summary>
        /// <param name="command">명령</param>
        /// <param name="identity">식별자</param>
        public void AddParameters(IDbCommand command, SqlMapper.Identity identity)
        {
            ((SqlMapper.IDynamicParameters)this.dynamicParameters).AddParameters(command, identity);

            OracleCommand oracleCommand = command as OracleCommand;

            if(oracleCommand != null)
            {
                oracleCommand.Parameters.AddRange(this.oracleParameterList.ToArray());
            }
        }

        #endregion
    }
}

 

300x250

 

▶ Program.cs

using System;
using System.Data;
using System.Linq;

using Oracle.ManagedDataAccess.Client;

using Dapper;

namespace TestProject
{
    /// <summary>
    /// 프로그램
    /// </summary>
    class Program
    {
        //////////////////////////////////////////////////////////////////////////////////////////////////// Method
        ////////////////////////////////////////////////////////////////////////////////////////// Static
        //////////////////////////////////////////////////////////////////////////////// Private

        #region 프로그램 시작하기 - Main()

        /// <summary>
        /// 프로그램 시작하기
        /// </summary>
        private static void Main()
        {
            string connectionString = "Data Source=(DESCRIPTION = (ADDRESS_LIST = (ADDRESS = (PROTOCOL = TCP)(HOST = 127.0.0.1)(PORT = 1521)))(CONNECT_DATA = (SERVICE_NAME = orcl)));User ID=SYSTEM;Password=P@ssw0rd";

            using(OracleConnection connection = new OracleConnection(connectionString))
            {
                OracleDynamicParameters parameters = new OracleDynamicParameters();

                parameters.Add("I_NAME"  , "S");
                parameters.Add("O_CURSOR", OracleDbType.RefCursor, ParameterDirection.Output);

                var resultList = connection.Query<dynamic>
                (
                    "SCOTT.GETMEMBERLIST",
                    param : parameters,
                    commandType : CommandType.StoredProcedure
                )
                .ToList();

                foreach(var item in resultList)
                {
                    Console.WriteLine(item.ENAME);
                }
            }
        }

        #endregion
    }
}

728x90

반응형

그리드형(광고전용)

• 카카오스토리
• 트위터
• 페이스북

'C# > Dapper' 카테고리의 다른 글

[C#/DAPPER] 누겟 설치 : Dapper  (0)	2020.09.29
[C#/DAPPER] SqlMapper 클래스 : GetRowParser 확장 메소드를 사용해 제네릭 타입 데이터의 .CSV 파일 생성하기  (0)	2020.04.25
[C#/DAPPER] CustomPropertyTypeMap 클래스 : 커스텀 컬럼 매핑 사용하기  (0)	2020.02.03
[C#/DAPPER] SqlMapper 클래스 : TypeHandler<T> 정적 메소드를 사용해 커스텀 타입 처리하기  (0)	2020.02.02
[C#/DAPPER] IDbConnection 클래스 : QueryMultiple 확장 메소드를 사용해 2개 이상의 SELECT문 조회하기  (0)	2020.02.02
[C#/DAPPER] SYS_REFCURSOR 출력 타입의 입력 매개 변수를 갖는 오라클 저장 프로시저 호출하기  (0)	2020.02.02
[C#/DAPPER] NULLABLE DATETIME 사용시 처리하기  (0)	2017.10.07
[C#/DAPPER] 부모 객체를 포함해 조회하기  (0)	2017.06.26
[C#/DAPPER] 자식 리스트를 포함해 조회하기  (0)	2017.06.26
[C#/DAPPER] IN 조건문 조회하기  (0)	2016.08.30
[C#/DAPPER] COUNT 집계 함수 사용하기  (0)	2016.05.22