C# MySqlDB, MariaDB 연동하기

C# PostgresqlDB 연동하는 방법가 동일합니다^^

 

1. 프로젝트 우 클릭 

2. NuGet 패키지 관리 선택

3. 찾아보기 탭에서 MySql.Data 설치 

4. 아래 클래스 작성 및 MySql 및 MariaDB 연동

 public class cMariaDB
    {
        private string strConn;
        private MySqlConnection sqlConn;
        public MySqlCommand cmd;
        cLog log = new cLog();
        String add;
      
        /*
         * 
         * **/
        public int fn_Open(String Add, int Port)
        {
            int iret = 0;
          
 
         
            strConn = "Data Source=" + Add + ";Port=" + Port + ";Database=db명;Uid=root;Pwd=pwd;Allow User Variables=true;CharSet=utf8;SSL Mode=None;";//SSL Mode=Required
 
            sqlConn = new MySqlConnection(strConn);
            try
            {
                iret = 1;
                sqlConn.Open();
                log.fn_LogWrite("마리아DB 오픈완료" );
            }
            catch(Exception e)
            {
                log.fn_LogWrite("DB 오픈 : " + e.Message.ToString());
                fn_Close();
                iret = -1;
 
            }
            return iret;
        }
        /*
         * dddd
         * **/
        public void fn_Close()
        {
            sqlConn.Close();
            log.fn_LogWrite("DB 클로즈");
        }
 
//DB 트랜잭션 사용하기
public int fn_ExecuteNonQuery(string[] strSql)
        {
            int iret=0;
            int i;
 
            if (cKstarSetupData.MariaDBCon == 1)
            {
                MySqlCommand cmd = sqlConn.CreateCommand();
                MySqlTransaction tran = sqlConn.BeginTransaction();// Start a local transaction
 
                cmd.Connection = sqlConn;
                cmd.Transaction = tran;
                if (sqlConn == null || tran == null) iret = -2; 
                try
                {
                    for (i = 0; i < strSql.Length; i++)
                    {
                        cmd.CommandText = strSql[i];
 
                        iret += cmd.ExecuteNonQuery();//정상이면 1 리턴
                    }
                    log.fn_LogWrite("DB try : " + strSql.Length.ToString());
                    tran.Commit();
                    log.fn_LogWrite("마리아DB 커밋 완료 :");
                }
                catch (Exception e)
                {
                    log.fn_LogWrite("DB catch : " + strSql.Length.ToString());
                    log.fn_LogWrite("DB 트랜잭션 : " + e.Message.ToString());
                    tran.Rollback();
                    fn_Close();
                    iret = -1;
                    //MessageBox.Show(e.StackTrace);
                }
                finally { }
            }
            return iret;
        }

 

[C#] - C# Postgresql DB 트랜잭션 사용하기

C# Postgresql DB 트랜잭션 사용하기

[C#] - C# Postgresql 연동하기

C# Postgresql 연동하기