C# [Mysql] Database 클래스 작성

DB_connect 클래스 작성
클래스 변수 선언 및 초기화

string _server = "DB_주소"; //DB 서버 주소(도메인 또는 IP 주소), 로컬일 경우 localhost
int _port = "server_Port"; //DB 서버 포트
string _database = "DB_Name"; //DB 이름
string _id = "userID"; //계정 아이디
string _pw = "userPassword"; //계정 비밀번호
string _connectionAddress = "";
MySqlConnection conn;

 

 

Mysql 접속 메소드

public void Open()
    {
        try
        {
            _connectionAddress = $"Server={_server};Port={_port};Database={_database};Uid={_id};Pwd={_pw}";
            if (conn == null)
            {
                conn = new MySqlConnection(_connectionAddress);
                conn.Open();
            }
        }
        catch (Exception ex)
        {
            throw ex;
        }
    }

Mysql 접속 해제 메소드

public void Close()
    {
        try
        {
            if (conn != null)
            {
                conn.Close();
            }
        }
        catch (Exception ex)
        {
            throw ex;
        }
    }

Mysql의 SQL(insert, update, delete) 삽입, 수정, 삭제 기능 구현한 메소드

public void SQLQuery(string query)
    {
        try
        {
            MySqlCommand cmd = new MySqlCommand(query, conn);
            cmd.ExecuteNonQuery();
        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message);
        }
    }

전체코드

class DB_connect
{
    string _server = "DB_주소"; //DB 서버 주소(도메인 또는 IP 주소), 로컬일 경우 localhost
    int _port = "server_Port"; //DB 서버 포트
    string _database = "DB_Name"; //DB 이름
    string _id = "userID"; //계정 아이디
    string _pw = "userPassword"; //계정 비밀번호
    string _connectionAddress = "";
    public MySqlConnection conn;
 
 
    public void Open()
    {
        try
        {
            _connectionAddress = $"Server={_server};Port={_port};Database={_database};Uid={_id};Pwd={_pw}";
            if (conn == null)
            {
                conn = new MySqlConnection(_connectionAddress);
                conn.Open();
            }
        }
        catch (Exception ex)
        {
            throw ex;
        }
    }
    public void Close()
    {
        try
        {
            if (conn != null)
            {
                conn.Close();
            }
        }
        catch (Exception ex)
        {
            throw ex;
        }
    }
    public void SQLQuery(string query)
    {
        try
        {
            MySqlCommand cmd = new MySqlCommand(query, conn);
            cmd.ExecuteNonQuery();
        }
        catch (Exception e)
        {
            Console.WriteLine(e.Message);
        }
    }