DBConn

 

이게 이상적인 방법인지는 잘 모르겠지만

지난번에 DB접속 부분을 분리하여 만들면서 나온 결과물이다.

 

이 파일 하나로 DB접속은 물론이고 데이터를 가져올 수도 있다.

 

INSERT, SELECT, DELETE, UPDATE 등등등이 모두 가능하다.

혹시나 몰라서 OLEDB방법과 기본OracleClient를 이용하는 방법. 그리고 해당 Oracle에서 제공하는 방법까지 모두 적고 주석처리 해놓았다. 필요하시면...

 

 

DBConn.cs

 

 

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Data;
//using System.Data.OleDb;
using Oracle.DataAccess.Client;
//using System.Data.OracleClient;

namespace GNUNIX
{
    public class DBConn
    {
        //public static OleDbConnection conn;
        //public static OleDbDataAdapter adap;
        //public static OleDbCommand comm = new OleDbCommand();
        //public static OleDbDataReader read;

        public static OracleConnection conn;
        public static OracleDataAdapter adap;
        public static OracleCommand comm = new OracleCommand();
        public static OracleDataReader read;

        public static DataSet ds;

        public static bool Open(String SID, String ID, String PW)
        {
            try
            {
                //conn = new OleDbConnection("Provider=MSDAORA;Data Source=" + SID + ";User ID=" + ID + ";Password=" + PW);
                conn = new OracleConnection(@"Data Source=" + SID + ";User ID=" + ID + ";Password=" + PW);
                //conn = new OleDbConnection("Provider=OraOLEDB.Oracle.1;Data Source=" + SID + ";User ID=" + ID + ";Password=" + PW);
                conn.Open();
               
                comm.Connection = conn;

                return true;
            }
            catch
            {
                throw;
            }
        }

        public static void ExecuteSelectQueryRead(string query)
        {
            comm.CommandText = query;
            try
            {
                if (read!=null)
                {
                    read.Close();
                }
                read = comm.ExecuteReader();
            }
            catch//(Exception ex)
            {
                throw;
            }
        }

        public static void ExecuteSelectQueryAdapter(string query)
        {
            comm.CommandText = query;
            //ds = null;
            ds = new DataSet();
            try
            {
                if (read != null)
                {
                    read.Close();
                }
                //adap = new OleDbDataAdapter(comm);
                adap = new OracleDataAdapter(comm);
            }
            catch//(Exception ex)
            {
                //String test = ex.ToString();
                throw;
            }
        }

        //UDI = Update Delete Insert
        public static bool ExecuteUDIQuery(String query)
        {
            comm.CommandText = query;
            try
            {
                if (read != null)
                {
                    read.Close();
                }
                comm.ExecuteNonQuery();

                return true;
            }
            catch
            {
                throw;
            }
        }
       
        public static bool ExecuteSP(string sp, string[] parms)
        {
            comm.CommandText = "Call "+sp;
            for (int i=0; i<parms.Length; i++){
                comm.Parameters.Add(parms[i]);
            }

            try
            {
                if (read != null)
                {
                    read.Close();
                }

                comm.ExecuteNonQuery();
                return true;
            }
            catch
            {
                throw;
            }
        }

        public static void ExecuteSPReturnValue(string sp, string[] parms)
        {
            comm.CommandText = "Call " + sp;
            for (int i = 0; i < parms.Length; i++)
            {
                comm.Parameters.Add(parms[i]);
            }

            try
            {
                if (read != null)
                {
                    read.Close();
                }
                read = comm.ExecuteReader();
            }
            catch
            {
                throw;
            }
        }
    }
}

 

각종 의견 및 Feedback 환영합니다!

 

 

 

 

 

추가합니다.

위에는 static을 두어서 하나의 Connection을 편하게 사용하려고 했었습니다만

두개 이상의 Connection을 생성해서 쓰려니 문제가 있더군요.

그래서. static을 뺀 버젼 추가합나다;

 

DBConn.cs

 

 

 

 

추가합니다.

Oracle관련 참조가 없더라도 가능하도록 했습니다.

 

DBConn.cs

 

대학교때엔 오라클은 물론, MS-SQL이나 MY-SQL까지 다 접속 가능한 DBConn을 만들었었는데..

다시 하자니 귀찮고;;; 회사에 속해있다보니 크게 못느끼고 있는것같습니다.

 

언젠간 다시 만들겠죠 홍홍홍