C#连接MySql数据库的方法

左手的ㄟ右手 2024-03-23 18:39 53阅读 0赞

![a14030b8280b10572f7179cd828b9e16.jpeg][]

最近两天在解决C\#连接MySql数据库的问题，通过不同的从网上学习，最终找到了解决的办法，现在和大家分享一下

1、要连接MySql数据库必须首先下载MySql官方的连接.net的文件，文件下载地址为http://dev.mysql.com/downloads/connector/net/6.6.html\#downloads ，下载平台选择.Net&Mono,下载ZIP免安装版。  
2、解压缩刚才下载的mysql-connector-net-6.6.6-noinstall.zip文件，里面有几个版本选择，在这里我选V4，

![0709887dbe42c8828b242754fceb0321.jpeg][]

选中这几个文件，然后添加到C\#项目的引用中，然后就可以编写程序进行数据库的操作了。

3、数据库操作代码 InsertMySql.cs

<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 </td> 
 <td> <code>using</code> <code>System;</code> <code>using</code> <code>System.Collections;</code> <code>using</code> <code>System.Configuration;</code> <code>using</code> <code>MySql.Data;</code> <code>using</code> <code>MySql.Data.MySqlClient;</code> <code>using</code> <code>System.Data;</code> <code>namespace</code> <code>Sql</code> <code>//数据库简单测试</code> <code>{ </code> <code>&nbsp;&nbsp;</code><code>class</code> <code>InsertSql1</code> <code>&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>static</code> <code>void</code> <code>Main(</code><code>string</code><code>[] args)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>string</code> <code>constr=</code><code>"server=localhost;User Id=root;password=219229;Database=reg"</code><code>;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>MySqlConnection mycon=</code><code>new</code> <code>MySqlConnection(constr);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>mycon.Open();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>MySqlCommand mycmd = </code><code>new</code> <code>MySqlCommand(</code><code>"insert into buyer(name,password,email) values('小王','dikd3939','1134384387@qq.com')"</code><code>,mycon);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>if</code> <code>(mycmd.ExecuteNonQuery()&gt;0)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Console.WriteLine(</code><code>"数据插入成功！"</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>Console.ReadLine();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>mycon.Close();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

推荐使用下面的方法，下面的方法更详细

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

<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 = </code><code>"select * from user where username='"</code><code>+username+</code><code>"' and password='"</code><code>+password+</code><code>"'"</code><code>; //我们自己按照查询条件去组拼</code> <code>string sql = </code><code>"select * from user where username=@para1 and password=@para2"</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]

[a14030b8280b10572f7179cd828b9e16.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/548b49bb7c13474e940c2afe2810628a.png
[0709887dbe42c8828b242754fceb0321.jpeg]: https://image.dandelioncloud.cn/pgy_files/images/2024/03/14/8fa3a89db1ef4fcba8cc1d5155a40da4.png
[Link 1]: https://www.weidianyuedu.com