C#如何连接MySQL数据库

本文章是建立在已经安装mysql数据库的前提，默认安装在c:\program files (x86)\mysql,建议在安装时选中connector.net 6.9的安装，里面有mysql与c#连接的动态链接库。

　　帮助文档c:\program files (x86)\mysql\connector.net 6.9\documentation\connectornet.chm是我撰写此文章的主要依据。其中users guide下，programming是对动态链接库8个类的介绍，tutorial是案例代码。

　　连接数据库、操作数据库，本质是利用数据库提供的动态链接库mysql.data.dll进行操作。mysql.data.dll提供以下8个类：

• mysqlconnection: 连接mysql服务器数据库。
• mysqlcommand:执行一条sql语句。
• mysqldatareader: 包含sql语句执行的结果，并提供一个方法从结果中阅读一行。
• mysqltransaction: 代表一个sql事务在一个mysql数据库。
• mysqlexception: mysql报错时返回的exception。
• mysqlcommandbuilder: automatically generates single-table commands used to reconcile changes made to a dataset with the associated mysql database.
• mysqldataadapter: represents a set of data commands and a database connection that are used to fill a data set and update a mysql database.
• mysqlhelper: helper class that makes it easier to work with the provider.
  

1.添加动态链接库文件

　　方法一：visual studio,在 项目(右键)-管理nuget程序包(n) 然后在浏览里面搜索mysql.data并进行安装。

　　方法二：安装数据库mysql时要选中connector.net 6.9的安装，将c:\program files (x86)\mysql\connector.net 6.9\assemblies里v4.0或v4.5中的mysql.data.dll添加到项目的引用。v4.0和v4.5，对应visual studio具体项目 属性-应用程序-目标框架 里的.net framework的版本号。

2.建立连接(mysqlconnection类)

using mysql.data.mysqlclient;
string connetstr = "server=127.0.0.1;port=3306;user=root;password=root; database=minecraftdb;";
// server=127.0.0.1/localhost 代表本机，端口号port默认是3306可以不写
mysqlconnection conn = new mysqlconnection(connetstr);
try
{  
   conn.open();//打开通道，建立连接，可能出现异常,使用try catch语句
   console.writeline("已经建立连接");
   //在这里使用代码对数据库进行增删查改
}
catch (mysqlexception ex)
{
   console.writeline(ex.message);
}
finally
{
   conn.close();
}

3.捕捉异常(mysqlexception类)

　　连接错误时mysqlconnection会返回一个mysqlexception，其中包括2个变量:

　　message: a message that describes the current exception.

　　number: the mysql error number. (0: cannot connect to server. 1045: invalid user name and/or password.)

catch (mysqlexception ex)
{
  switch (ex.number)
  {
    case 0:
    console.writeline("cannot connect to server. contact administrator");
    break;
  case 1045:
    console.writeline("invalid username/password, please try again");
    break;
  }
}

4.增删查改的代码(mysqlcommand类、mysqldatareader类)

　　executereader——用于查询数据库。查询结果是返回mysqldatareader对象，mysqldatareader包含sql语句执行的结果，并提供一个方法从结果中阅读一行。

　　executenonquery——用于插入、更新和删除数据。

　　executescalar——用于查询数据时，返回查询结果集中第一行第一列的值，即只返回一个值。

　　(1) 查询

　　a.查询条件固定

string sql= "select * from user";
mysqlcommand cmd = new mysqlcommand(sql,conn);
mysqldatareader reader =cmd.executereader();//执行executereader()返回一个mysqldatareader对象
while (reader.read())//初始索引是-1，执行读取下一行数据，返回值是bool
{
  //console.writeline(reader[0].tostring() + reader[1].tostring() + reader[2].tostring());
  //console.writeline(reader.getint32(0)+reader.getstring(1)+reader.getstring(2));
  console.writeline(reader.getint32("userid") + reader.getstring("username") + reader.getstring("password"));//"userid"是数据库对应的列名，推荐这种方式
}

b.查询条件不固定

//string sql = "select * from user where username='"+username+"' and password='"+password+"'"; //我们自己按照查询条件去组拼
string sql = "select * from user where username=@para1 and password=@para2";//在sql语句中定义parameter，然后再给parameter赋值
mysqlcommand cmd = new mysqlcommand(sql, conn);
cmd.parameters.addwithvalue("para1", username);
cmd.parameters.addwithvalue("para2", password);

mysqldatareader reader = cmd.executereader();
if (reader.read())//如果用户名和密码正确则能查询到一条语句，即读取下一行返回true
{
  return true;
}

c.需要查询返回一个值

string sql = "select count(*) from user";
mysqlcommand cmd = new mysqlcommand(sql, conn);
object result=cmd.executescalar();//执行查询，并返回查询结果集中第一行的第一列。所有其他的列和行将被忽略。select语句无记录返回时，executescalar()返回null值
if (result != null)
{
  int count = int.parse(result.tostring());
}

(2) 插入、删除、更改

string sql = "insert into user(username,password,registerdate) values('啊宽','123','"+datetime.now+"')";
//string sql = "delete from user where userid='9'";
//string sql = "update user set username='啊哈',password='123' where userid='8'";
mysqlcommand cmd = new mysqlcommand(sql,conn);
int result =cmd.executenonquery();//3.执行插入、删除、更改语句。执行成功返回受影响的数据的行数，返回1可做true判断。执行失败不返回任何数据，报错，下面代码都不执行

5.事务(mysqltransaction类)

string connetstr = "server=127.0.0.1;user=root;password=root;database=minecraftdb;";
mysqlconnection conn = new mysqlconnection(connetstr);
conn.open();//必须打开通道之后才能开始事务
mysqltransaction transaction = conn.begintransaction();//事务必须在try外面赋值不然catch里的transaction会报错:未赋值
console.writeline("已经建立连接");
try
{
  string date = datetime.now.year + "-" + datetime.now.month + "-" + datetime.now.day;
  string sql1= "insert into user(username,password,registerdate) values('啊宽','123','" + date + "')";
  mysqlcommand cmd1 = new mysqlcommand(sql1,conn);
  cmd1.executenonquery();

  string sql2 = "insert into user(username,password,registerdate) values('啊宽','123','" + date + "')";
  mysqlcommand cmd2 = new mysqlcommand(sql2, conn);
  cmd2.executenonquery();
}
catch (mysqlexception ex)
{
  console.writeline(ex.message);
  transaction.rollback();//事务executenonquery()执行失败报错，username被设置unique
  conn.close();
}
finally
{
  if (conn.state != connectionstate.closed)
  {
    transaction.commit();//事务要么回滚要么提交，即rollback()与commit()只能执行一个
    conn.close();
  }
}

结语：连接数据库、操作数据库，本质是利用数据库提供的动态链接库mysql.data.dll进行操作。动态链接库中的8个类上面常用操作只用到了类1-5，类6-8 的相关操作未涉及， 大家可以去看帮助文档c:\program files (x86)\mysql\connector.net 6.9\documentation\connectornet.chm学习。

以上就是c#如何连接mysql数据库的详细内容，更多关于c#连接mysql的资料请关注其它相关文章！