[데이터베이스] .Net C#에서 MySQL 사용하기 (예제 파일 다운로드)

소개

지난 포스팅에서는 윈도우10에서 MySQL을 사용하기 위한 환경 구성을 소개했었습니다.

[데이터베이스] 윈도우10에 MySQL 설치 및 환경 설정하기

 

[데이터베이스] 윈도우10에 MySQL 설치 및 환경 설정하기

데이터베이스를 위한 MySQL MySQL은 가장 널리 사용되고 있는 관계형 데이터베이스 관리 시스템(RDBMS; Relational Database Management System)입니다. MySQL은 무료 버전인 커뮤니티 에디션(Community Edition)..

luckygg.tistory.com

이번 포스팅에서는 코드 레벨에서 어떻게 MySQL에 접근하여 DB에 접근하는지 소개하겠습니다.

예제 프로젝트 목표

본문의 예제 프로젝트는 간단하게 MySQL을 사용하여 전화번호부를 만들려고 합니다. 동작은 아래와 같습니다.

예제 프로젝트는 DB에 연동하여 데이터 삽입(INSERT), 수정(UPDATE), 삭제(DELETE), 조회(SELECT) 동작을 보여줍니다. 참고로 본문의 예제 코드에 사용된 DB는 아래와 같이 생성했습니다.

accounts_table 이름으로 테이블을 생성하고, Column으로 id(INT)와 name(VARCHAR) 그리고 phone(VARCHAR)을 생성했습니다. name에는 이름이, phone에는 전화번호 데이터가 입력됩니다.

.Net C#에서 MySQL을 사용하기 위한 준비

ExamMySQL이라는 이름으로 C# WinForm 프로젝트를 생성하고, 누겟(NuGet)에서 MySql.Data 패키지를 설치합니다.

그리고 아래의 코드를 추가하여 MySQL 사용을 위한 준비를 마칩니다.

//...
//MySQL namespace를 사용하기 위한 선언.
using MySql.Data.MySqlClient;
 
namespace ExamMySQL
{
    public partial class Form1 : Form
    {
        string _server = "localhost"; //DB 서버 주소, 로컬일 경우 localhost
        int _port = 3308; //DB 서버 포트
        string _database = "new_schema"; //DB 이름
        string _id = "root"; //계정 아이디
        string _pw = "root"; //계정 비밀번호
        string _connectionAddress = "";
 
        public Form1()
        {
            InitializeComponent();
			//MySQL 연결을 위한 주소 형식
            _connectionAddress = string.Format("Server={0};Port={1};Database={2};Uid={3};Pwd={4}", _server, _port, _database, _id, _pw);
        }
		
		//...
	}
}

WinForm UI 구성

이름(name)과 번호(phone) 데이터를 삽입, 수정, 삭제, 조회하는 것이므로 아래와 같이 단순하게 UI를 구성합니다.

MySQL 데이터 삽입(INSERT)

테이블에 데이터 삽입을 위한 쿼리는 다음과 같습니다.

INSERT INTO 테이블이름 [column1, column2, ...] VALUES (value1, value2, ...);

그리고 예제 코드의 데이터 삽입은 다음과 같이 구현되어 있습니다.

private void buttonInsert_Click(object sender, EventArgs e)
{
	try
	{
		using (MySqlConnection mysql = new MySqlConnection(_connectionAddress))
		{
			mysql.Open();
			//accounts_table에 name, phone column 데이터를 삽입합니다. id는 자동으로 증가합니다.
			string insertQuery = string.Format("INSERT INTO accounts_table (name, phone) VALUES ('{0}', '{1}');", textBoxName.Text, textBoxPhone.Text);
 
			MySqlCommand command = new MySqlCommand(insertQuery, mysql);
			if (command.ExecuteNonQuery() != 1)
				MessageBox.Show("Failed to insert data.");
 
			textBoxName.Text = "";
			textBoxPhone.Text = "";
 
			selectTable();
		}
	}
	catch (Exception exc)
	{
		MessageBox.Show(exc.Message);
	}
}

MySQL 데이터 수정(UPDATE)

테이블의 특정 데이터를 수정하기 위한 쿼리는 다음과 같습니다.

UPDATE 테이블이름 SET column1 = value1 [, column2 = value2 ...] [WHERE 조건];

마찬가지로 예제 코드도 확인해 보겠습니다.

private void buttonUpdate_Click(object sender, EventArgs e)
{
	try
	{
		using (MySqlConnection mysql = new MySqlConnection(_connectionAddress))
		{
			mysql.Open();
			int pos = listViewPhoneBook.SelectedItems[0].Index;
			int index = Convert.ToInt32(listViewPhoneBook.Items[pos].Text);
			//accounts_table의 특정 id의 name column과 phone column 데이터를 수정합니다.
			string updateQuery = string.Format("UPDATE accounts_table SET name = '{1}', phone = '{2}' WHERE id={0};", index, textBoxName.Text, textBoxPhone.Text);
 
			MySqlCommand command = new MySqlCommand(updateQuery, mysql);
			if (command.ExecuteNonQuery() != 1)
				MessageBox.Show("Failed to delete data.");
 
			textBoxName.Text = "";
			textBoxPhone.Text = "";
 
			selectTable();
		}
	}
	catch (Exception exc)
	{
		MessageBox.Show(exc.Message);
	}
}

MySQL 데이터 삭제(DELETE)

테이블의 특정 데이터를 삭제하기 위한 쿼리는 다음과 같습니다.

DELETE FROM 테이블이름 [WHERE 조건];

예제 코드도 보겠습니다.

private void buttonDelete_Click(object sender, EventArgs e)
{
	try
	{
		using (MySqlConnection mysql = new MySqlConnection(_connectionAddress))
		{
			mysql.Open();
			int pos = listViewPhoneBook.SelectedItems[0].Index;
			int index = Convert.ToInt32(listViewPhoneBook.Items[pos].Text);
			//accounts_table에서 특정 id의 데이터를 삭제합니다.
			string deleteQuery = string.Format("DELETE FROM accounts_table WHERE id={0};", index);
 
			MySqlCommand command = new MySqlCommand(deleteQuery, mysql);
			if (command.ExecuteNonQuery() != 1)
				MessageBox.Show("Failed to delete data.");
 
			textBoxName.Text = "";
			textBoxPhone.Text = "";
 
			selectTable();
		}
	}
	catch (Exception exc)
	{
		MessageBox.Show(exc.Message);
	}
}

MySQL 데이터 조회(SELECT)

테이블의 전체 데이터를 조회하기 위한 쿼리는 다음과 같습니다.

SELECT * FROM 테이블이름;

코드는 다음과 같습니다.

private void selectTable()
{
	try
	{
		using (MySqlConnection mysql = new MySqlConnection(_connectionAddress))
		{
			mysql.Open();
			//accounts_table의 전체 데이터를 조회합니다.            
			string selectQuery = string.Format("SELECT * FROM accounts_table");
 
			MySqlCommand command = new MySqlCommand(selectQuery, mysql);
			MySqlDataReader table = command.ExecuteReader();
 
			listViewPhoneBook.Items.Clear();
 
			while (table.Read())
			{
				ListViewItem item = new ListViewItem();
				item.Text = table["id"].ToString();
				item.SubItems.Add(table["name"].ToString());
				item.SubItems.Add(table["phone"].ToString());
 
				listViewPhoneBook.Items.Add(item);
			}
 
			table.Close();
		}
	}
	catch (Exception exc)
	{
		MessageBox.Show(exc.Message);
	}
}

정리

예제 코드를 쉽게 따라 하셨나요? DB 연결만 제대로 한다면 어려운 부분은 없어 보입니다. 본문의 예제는 로컬 서버 기준으로 작성되었는데, 원격 서버의 DB도 주소만 올바르게 입력하면 문제없이 될 거라 생각합니다. 본문의 예제 코드는 아래 파일을 다운로드하면 되겠습니다.

ExamMySQL.zip

0.01MB