[C#][Database] Mysql Database 연결하기

---

2020/02/28 - [IT] - [C#] 가계부 프로그램 만들기 DAY1. Database 설정 및 연결

[C#] 가계부 프로그램 만들기 DAY1. Database 설정 및 연결

2020.10.15 포스팅 수정

가계부 프로그램에서 사용하기 위해 DBMySql 클래스를 수정하였습니다.

각각의 Select, Insert, Update, Delete 함수는 사용자가 사용방식에 맞게 수정하여 사용할 수 있습니다.

String Sql 구문에서 DataBase에서 입력할 쿼리를 입력하고, 각각의 변수들을 변경하여 사용할 수 있습니다.

현재 아래에 있는 코드들은 가계부 프로그램에서 사용하기 위해 작성한 코드입니다.

using MySql.Data.MySqlClient;
using System;
using System.Data;
using System.Windows.Forms;
 
namespace AccountBook
{
    public class DBMySql
    {
        MySqlConnection conn = new MySqlConnection($"server={Config.Server};uid={Config.UserID};" + 
           $"pwd={Config.UserPassword};database={Config.Database};pooling=false;allow user variables=true");
        MySqlDataAdapter adpt;
        MySqlCommand cmd;
 
        public void Connection()
        {
            try
            {
                conn.Open();
            }
            catch (Exception e)
            {
                MessageBox.Show(e.ToString());
                throw;
            }
            conn.Close();
        }
 
        public DataSet SelectAll(string table)
        {
            try
            {
                DataSet ds = new DataSet();
 
                string sql = $"SELECT * FROM {table}";
                adpt = new MySqlDataAdapter(sql, conn);
                adpt.Fill(ds, table);
                if(ds.Tables.Count > 0)
                {
                    return ds;
                } else
                {
                    return null;
                }
            }
            catch (Exception e)
            {
                MessageBox.Show(e.ToString());
                throw;
            }
        }
 
        public DataSet SelectDetail(string table, string condition, string where = "")
        {
            try
            {
                DataSet ds = new DataSet();
 
                string sql = $"SELECT {condition} FROM {table} {where}";
                adpt = new MySqlDataAdapter(sql, conn);
                adpt.Fill(ds, table);
                if (ds.Tables.Count > 0)
                {
                    return ds;
                }
                else
                {
                    return null;
                }
            }
            catch (Exception e)
            {
                MessageBox.Show(e.ToString());
                throw;
            }
        }
 
        public void Insert(string table, string value)
        {
            try
            {
                conn.Open();
                string sql = $"INSERT INTO {table} VALUES ({value})";
                cmd = new MySqlCommand(sql, conn);
                cmd.ExecuteNonQuery();
                conn.Close();
            }
            catch (Exception e)
            {
                MessageBox.Show(e.ToString());
                throw;
            }
        }
 
        public void Update(string table, string setvalue, string wherevalue)
        {
            try
            {
                conn.Open();
                string sql = $"UPDATE {table} SET {setvalue} WHERE {wherevalue}";
                cmd = new MySqlCommand(sql, conn);
                cmd.ExecuteNonQuery();
                conn.Close();
            }
            catch (Exception e)
            {
                MessageBox.Show(e.ToString());
                throw;
            }
        }
 
        public void DeleteAll(string table)
        {
            try
            {
                conn.Open();
                string sql = $"DELETE FROM {table}";
                cmd = new MySqlCommand(sql, conn);
                cmd.ExecuteNonQuery();
                conn.Close();
            }
            catch (Exception e)
            {
                MessageBox.Show(e.ToString());
                throw;
            }
        }
 
        public void DeleteDetail(string table, string wherecol, string wherevalue)
        {
            try
            {
                conn.Open();
                string sql = $"DELETE FROM {table} WHERE {wherecol}='{wherevalue}'";
                cmd = new MySqlCommand(sql, conn);
                cmd.ExecuteNonQuery();
                conn.Close();
            }
            catch (Exception e)
            {
                MessageBox.Show(e.ToString());
                throw;
            }
        }
    }
}