关于C#如何连接MySQL数据库介绍

超、凢脫俗 2024-03-23 19:27 57阅读 0赞

![d18349008a8c47ea16de3b5a8ce14365.jpeg][]

本文主要介绍了C\#如何连接MySQL数据库，帮助大家更好的理解和使用c\#，感兴趣的朋友可以了解下

本文章是建立在已经安装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类)**

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 </td> 
 <td> <code>using</code> <code>MySql.Data.MySqlClient;</code> <code>String connetStr = </code><code>"server=127.0.0.1;port=3306;user=root;password=root; database=minecraftdb;"</code><code>;</code> <code>// server=127.0.0.1/localhost 代表本机，端口号port默认是3306可以不写</code> <code>MySqlConnection conn = </code><code>new</code> <code>MySqlConnection(connetStr);</code> <code>try</code> <code>{&nbsp; </code> <code>&nbsp;&nbsp;&nbsp;</code><code>conn.Open();</code><code>//打开通道，建立连接，可能出现异常,使用try catch语句</code> <code>&nbsp;&nbsp;&nbsp;</code><code>Console.WriteLine(</code><code>"已经建立连接"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;</code><code>//在这里使用代码对数据库进行增删查改</code> <code>}</code> <code>catch</code> <code>(MySqlException ex)</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;</code><code>Console.WriteLine(ex.Message);</code> <code>}</code> <code>finally</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;</code><code>conn.Close();</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

**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.)

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 </td> 
 <td> <code>catch</code> <code>(MySqlException ex)</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>switch</code> <code>(ex.Number)</code> <code>&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>case</code> <code>0:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Console.WriteLine(</code><code>"Cannot connect to server. Contact administrator"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>break</code><code>;</code> <code>&nbsp;&nbsp;</code><code>case</code> <code>1045:</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Console.WriteLine(</code><code>"Invalid username/password, please try again"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>break</code><code>;</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

**4.增删查改的代码(MySqlCommand类、MySqlDataReader类)**

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

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

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

(1) 查询

a.查询条件固定

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 </td> 
 <td> <code>string</code> <code>sql= </code><code>"select * from user"</code><code>;</code> <code>MySqlCommand cmd = </code><code>new</code> <code>MySqlCommand(sql,conn);</code> <code>MySqlDataReader reader =cmd.ExecuteReader();</code><code>//执行ExecuteReader()返回一个MySqlDataReader对象</code> <code>while</code> <code>(reader.Read())</code><code>//初始索引是-1，执行读取下一行数据，返回值是bool</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>//Console.WriteLine(reader[0].ToString() + reader[1].ToString() + reader[2].ToString());</code> <code>&nbsp;&nbsp;</code><code>//Console.WriteLine(reader.GetInt32(0)+reader.GetString(1)+reader.GetString(2));</code> <code>&nbsp;&nbsp;</code><code>Console.WriteLine(reader.GetInt32(</code><code>"userid"</code><code>) + reader.GetString(</code><code>"username"</code><code>) + reader.GetString(</code><code>"password"</code><code>));</code><code>//"userid"是数据库对应的列名，推荐这种方式</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

b.查询条件不固定

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 </td> 
 <td> <code>//string sql = "select * from user where username='"+username+"' and password='"+password+"'"; //我们自己按照查询条件去组拼</code> <code>string</code> <code>sql = </code><code>"select * from user where username=@para1 and password=@para2"</code><code>;</code><code>//在sql语句中定义parameter，然后再给parameter赋值</code> <code>MySqlCommand cmd = </code><code>new</code> <code>MySqlCommand(sql, conn);</code> <code>cmd.Parameters.AddWithValue(</code><code>"para1"</code><code>, username);</code> <code>cmd.Parameters.AddWithValue(</code><code>"para2"</code><code>, password);</code> <code>MySqlDataReader reader = cmd.ExecuteReader();</code> <code>if</code> <code>(reader.Read())</code><code>//如果用户名和密码正确则能查询到一条语句，即读取下一行返回true</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>return</code> <code>true</code><code>;</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

c.需要查询返回一个值

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 </td> 
 <td> <code>string</code> <code>sql = </code><code>"select count(*) from user"</code><code>;</code> <code>MySqlCommand cmd = </code><code>new</code> <code>MySqlCommand(sql, conn);</code> <code>Object result=cmd.ExecuteScalar();</code><code>//执行查询，并返回查询结果集中第一行的第一列。所有其他的列和行将被忽略。select语句无记录返回时，ExecuteScalar()返回NULL值</code> <code>if</code> <code>(result != </code><code>null</code><code>)</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>int</code> <code>count = </code><code>int</code><code>.Parse(result.ToString());</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

(2) 插入、删除、更改

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

**5.事务(MySqlTransaction类)**

<table> 
 <tbody> 
 <tr> 
 <td> 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 </td> 
 <td> <code>String connetStr = </code><code>"server=127.0.0.1;user=root;password=root;database=minecraftdb;"</code><code>;</code> <code>MySqlConnection conn = </code><code>new</code> <code>MySqlConnection(connetStr);</code> <code>conn.Open();</code><code>//必须打开通道之后才能开始事务</code> <code>MySqlTransaction transaction = conn.BeginTransaction();</code><code>//事务必须在try外面赋值不然catch里的transaction会报错:未赋值</code> <code>Console.WriteLine(</code><code>"已经建立连接"</code><code>);</code> <code>try</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>string</code> <code>date = DateTime.Now.Year + </code><code>"-"</code> <code>+ DateTime.Now.Month + </code><code>"-"</code> <code>+ DateTime.Now.Day;</code> <code>&nbsp;&nbsp;</code><code>string</code> <code>sql1= </code><code>"insert into user(username,password,registerdate) values('啊宽','123','"</code> <code>+ date + </code><code>"')"</code><code>;</code> <code>&nbsp;&nbsp;</code><code>MySqlCommand cmd1 = </code><code>new</code> <code>MySqlCommand(sql1,conn);</code> <code>&nbsp;&nbsp;</code><code>cmd1.ExecuteNonQuery();</code> <code>&nbsp;&nbsp;</code><code>string</code> <code>sql2 = </code><code>"insert into user(username,password,registerdate) values('啊宽','123','"</code> <code>+ date + </code><code>"')"</code><code>;</code> <code>&nbsp;&nbsp;</code><code>MySqlCommand cmd2 = </code><code>new</code> <code>MySqlCommand(sql2, conn);</code> <code>&nbsp;&nbsp;</code><code>cmd2.ExecuteNonQuery();</code> <code>}</code> <code>catch</code> <code>(MySqlException ex)</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>Console.WriteLine(ex.Message);</code> <code>&nbsp;&nbsp;</code><code>transaction.Rollback();</code><code>//事务ExecuteNonQuery()执行失败报错，username被设置unique</code> <code>&nbsp;&nbsp;</code><code>conn.Close();</code> <code>}</code> <code>finally</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>if</code> <code>(conn.State != ConnectionState.Closed)</code> <code>&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>transaction.Commit();</code><code>//事务要么回滚要么提交，即Rollback()与Commit()只能执行一个</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>conn.Close();</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

**结语：**

连接数据库、操作数据库，本质是利用数据库提供的动态链接库MySql.Data.dll进行操作。动态链接库中的8个类上面常用操作只用到了类1-5，类6-8 的相关操作未涉及， 大家可以去看帮助文档C:\\Program Files (x86)\\MySQL\\Connector.NET 6.9\\Documentation\\ConnectorNET.chm学习。

转自：[微点阅读][Link 1] [https://www.weidianyuedu.com][Link 1]

[d18349008a8c47ea16de3b5a8ce14365.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/5d61affdce284abbbde942d363fcfd96.png
[Link 1]: https://www.weidianyuedu.com