C# - 닷넷 응용 프로그램에서 MySQL(MySqlConnector) 사용
예전에 PHP를 통해 MySQL을 사용하는 방법을 소개했었는데요.
.NET 개발자가 처음 해보는 PHP + MySQL 연동
; https://www.sysnet.pe.kr/2/0/1058
MySQL의 환경 설정은 중복 설명하지 않고 ^^ 위의 것을 그대로 따를 것입니다. (하지만, 이 글에서 테스트한 MySQL 버전은 5.5입니다. 별 차이는 없겠지만. ^^)
DB(Schema): mytestdb
테이블: mytable
칼럼: id int NOT NULL
name varchar(50)
age int
description varchar(150)
C#에서 MySQL을 사용하려면 ODBC나 전용 ADO.NET Data Provider를 사용해야 할텐데요. 다행히 MySQL 측에서 Connector/Net이라는 "ADO.NET driver for MySQL"을 제공해 주고 있으니 이를 사용하면 됩니다. (소스 코드도 공개되어 있습니다.)
다운로드는 다음의 경로에서 받고,
Download Connector/Net
; http://dev.mysql.com/downloads/connector/net/
오늘 날짜(2012-01-16) 기준으로 6.6.4 버전이 최신입니다. 제 경우에는 MSI 파일로 설치했습니다.
정상적으로 설치되고 나면, C:\Program Files (x86)\MySQL\MySQL Connector Net 6.6.4\Assemblies 경로에 v2.0, v4.0의 하위 폴더가 생기고 그 안에 각각 다음의 어셈블리들이 포함되어 있습니다. (물론, GAC에도 등록됩니다.)
- MySql.Data.CF.dll
- MySql.Data.dll
- MySql.Data.Entity.dll
- MySql.Web.dll
이 중에서 일반적인 ASP.NET에서 사용하는 용도로는 MySql.Data.dll만 있으면 됩니다. 그 파일만 복사해서 다른 컴퓨터의 Visual Studio에서 참조 추가한 후 다음과 같이 코딩을 해도 MySQL 사용이 가능합니다. (즉, 굳이 MSI 파일을 설치할 필요는 없습니다.)
nuget을 통해 설치할 수 있습니다.
// https://www.nuget.org/packages/MySqlConnector/
Install-Package MySqlConnector
using System;
using System.Data;
using MySql.Data.MySqlClient;
namespace ConsoleApplication1
{
class Program
{
private void CreateMySqlTable(MySqlConnection connection)
{
string query = "CREATE TABLE IF NOT EXISTS mytable(";
query += " id INT NOT NULL, ";
query += " NAME VARCHAR(50) NOT NULL PRIMARY KEY, ";
query += " age INT NOT NULL, ";
query += " DESCRIPTION VARCHAR(150) NOT NULL)";
MySqlCommand createCommand = new MySqlCommand();
createCommand.Connection = connection;
createCommand.CommandText = query;
createCommand.ExecuteNonQuery();
}
static void Main(string[] args)
{
using (MySqlConnection myConnection =
new MySqlConnection(@"Data Source=192.168.0.11;Database=mytestdb;User Id=mytest;Password=mytest@2008"))
{
myConnection.Open();
CreateMySqlTable(myConnection);
// Create
MySqlCommand insertCommand = new MySqlCommand();
insertCommand.Connection = myConnection;
insertCommand.CommandText = "INSERT INTO mytable(id, NAME, age, DESCRIPTION) VALUES (@id, @NAME, @age, @DESCRIPTION)";
insertCommand.Parameters.Add("@id", MySqlDbType.Int32, 50);
insertCommand.Parameters.Add("@NAME", MySqlDbType.VarChar, 50);
insertCommand.Parameters.Add("@age", MySqlDbType.Int32, 50);
insertCommand.Parameters.Add("@DESCRIPTION", MySqlDbType.VarChar, 150);
string nameValue = "Name" + Guid.NewGuid().ToString();
insertCommand.Parameters[0].Value = 0;
insertCommand.Parameters[1].Value = nameValue;
insertCommand.Parameters[2].Value = 10;
insertCommand.Parameters[3].Value = nameValue + "_Description";
int affected = insertCommand.ExecuteNonQuery();
Console.WriteLine("# of affected row: " + affected);
// Update
MySqlCommand updateCommand = new MySqlCommand();
updateCommand.Connection = myConnection;
updateCommand.CommandText = "UPDATE mytable SET DESCRIPTION=@DESCRIPTION WHERE NAME=@NAME";
updateCommand.Parameters.Add("@NAME", MySqlDbType.VarChar, 50);
updateCommand.Parameters.Add("@DESCRIPTION", MySqlDbType.VarChar, 150);
updateCommand.Parameters[0].Value = nameValue;
updateCommand.Parameters[1].Value = nameValue + "_Description2";
affected = updateCommand.ExecuteNonQuery();
Console.WriteLine("# of affected row: " + affected);
// Select - ExecuteScalar
MySqlCommand selectCommand = new MySqlCommand();
selectCommand.Connection = myConnection;
selectCommand.CommandText = "SELECT count(*) FROM mytable";
object result = selectCommand.ExecuteScalar();
Console.WriteLine("# of records: " + result);
// Select - DataTable
DataSet ds = new DataSet();
MySqlDataAdapter da = new MySqlDataAdapter("SELECT * FROM mytable", myConnection);
da.Fill(ds, "mytable");
DataTable dt = ds.Tables["mytable"];
foreach (DataRow dr in dt.Rows)
{
Console.WriteLine(string.Format("Name = {0}, Desc = {1}", dr["NAME"], dr["DESCRIPTION"]));
}
// Delete
MySqlCommand deleteCommand = new MySqlCommand();
deleteCommand.Connection = myConnection;
deleteCommand.CommandText = "DELETE FROM mytable WHERE NAME=@NAME";
deleteCommand.Parameters.Add("@NAME", MySqlDbType.VarChar, 50);
deleteCommand.Parameters[0].Value = nameValue;
affected = deleteCommand.ExecuteNonQuery();
Console.WriteLine("# of affected row: " + affected);
}
}
}
}
사용이 정말 쉬워졌군요. ^^ 영국의 어떤 개발자 한 분이 애플리케이션 서버는 C#/닷넷/윈도우가 담당하고 그 외 기반은 오픈 소스 기반으로 한다는데... 제법 현실성이 있습니다. C#/닷넷의 생산성과 인프라의 저비용화가 적절히 맞아떨어지는 것 같습니다.
참고로, mysql.exe 실행시 Access denied 오류가 발생하는 경우가 있었습니다.
C:\Program Files\MySQL\MySQL Server 5.5\bin>mysql
ERROR 1045 (28000): Access denied for user 'ODBC'@'localhost' (using password: NO)
C:\Program Files\MySQL\MySQL Server 5.5\bin>mysql -u root
ERROR 1045 (28000): Access denied for user 'root'@'localhost' (using password: NO)
이럴 때는 그냥 -p 옵션을 부과해서 암호까지 입력하겠다고 명시해야 합니다.
C:\Program Files\MySQL\MySQL Server 5.5\bin>mysql -u root -p
Enter password:
첨부된 파일은 MySql.Data.dll이 포함된 간단한 소스 코드 예제입니다.
[이 글에 대해서 여러분들과 의견을 공유하고 싶습니다. 틀리거나 미흡한 부분 또는 의문 사항이 있으시면 언제든 댓글 남겨주십시오.]