C#操作mysql数据库的实例

时间：2022-09-20 18:18:40

C#操作mysql数据库实例

本文主要分享的是使用C#简单快捷的操作Mysql数据库的完整实现过程。

目录

引用MySql.Data库

管理NuGet程序包

  • 在 引用 中选择 管理NuGet程序包
    C#操作mysql数据库的实例

安装程序包 MySql.Data

  • 在联机中搜索 mysql ，选择安装程序包 MySql.Data
    C#操作mysql数据库的实例

创建Mysql连接工具类

添加引用

创建类MysqlConnector 并添加引用：

using MySql.Data.MySqlClient;

完整代码

public class MysqlConnector
{
string server = null;
string userid = null;
string password = null;
string database = null;
string port = "3306";
string charset = "utf-8";

public MysqlConnector() { }
public MysqlConnector SetServer(string server)
    {
this.server = server;
return this;
    }

public MysqlConnector SetUserID(string userid)
    {
this.userid = userid;
return this;
    }

public MysqlConnector SetDataBase(string database)
    {
this.database = database;
return this;
    }

public MysqlConnector SetPassword(string password)
    {
this.password = password;
return this;
    }
public MysqlConnector SetPort(string port)
    {
this.port = port;
return this;
    }
public MysqlConnector SetCharset(string charset)
    {
this.charset = charset;
return this;
    }



#region 建立MySql数据库连接
/// <summary>
/// 建立数据库连接.
/// </summary>
/// <returns>返回MySqlConnection对象</returns>
private MySqlConnection GetMysqlConnection()
    {
string M_str_sqlcon = string.Format("server={0};user id={1};password={2};database={3};port={4};Charset={5}", server, userid, password, database, port, charset);
        MySqlConnection myCon = new MySqlConnection(M_str_sqlcon);
return myCon;
    }
#endregion

#region 执行MySqlCommand命令
/// <summary>
/// 执行MySqlCommand
/// </summary>
/// <param name="M_str_sqlstr">SQL语句</param>
public void ExeUpdate(string M_str_sqlstr)
    {
        MySqlConnection mysqlcon = this.GetMysqlConnection();
        mysqlcon.Open();
        MySqlCommand mysqlcom = new MySqlCommand(M_str_sqlstr, mysqlcon);
        mysqlcom.ExecuteNonQuery();
        mysqlcom.Dispose();
        mysqlcon.Close();
        mysqlcon.Dispose();
    }
#endregion

#region 创建MySqlDataReader对象
/// <summary>
/// 创建一个MySqlDataReader对象
/// </summary>
/// <param name="M_str_sqlstr">SQL语句</param>
/// <returns>返回MySqlDataReader对象</returns>
public MySqlDataReader ExeQuery(string M_str_sqlstr)
    {
        Console.WriteLine(M_str_sqlstr);
        MySqlConnection mysqlcon = this.GetMysqlConnection();
        MySqlCommand mysqlcom = new MySqlCommand(M_str_sqlstr, mysqlcon);
        mysqlcon.Open();
        MySqlDataReader mysqlread = mysqlcom.ExecuteReader(CommandBehavior.CloseConnection);
return mysqlread;
    }
#endregion
}

测试数据库

数据库信息

我创建的 测试数据库 信息如下：

item value
数据库名 testdb
测试用户 testuser
口令 123456

测试数据表

创建一个数据表 user ，数据如下：

id sname age
1 张三 18
2 李四 19
3 王二麻子 20

实例代码及说明

界面设计

我使用的是 WinForm窗体程序 进行演示，界面设计如下：
C#操作mysql数据库的实例

完整代码

public partial class Form1 : Form
{
//实例化连接对象
    MysqlConnector mc = new MysqlConnector();

public Form1()
    {
        InitializeComponent();

//设置数据库连接参数
        mc.SetServer("127.0.0.1")
          .SetDataBase("testdb")
          .SetUserID("testuser")
          .SetPassword("123456")
          .SetPort("3306")
          .SetCharset("utf8");
    }

private void button1_Click(object sender, EventArgs e)
    {
string sql = textBox1.Text;
string result = "";
//执行查询
        MySqlDataReader reader = mc.ExeQuery(sql);
while (reader.Read())
        {
for (int i = 0; i < reader.FieldCount; i++)
            {
                result += reader.GetName(i) + "\t" + reader.GetValue(i) + "\r\n";
            }
        }
        textBox2.Text = result;
//执行增删改等操作
//mc.ExeUpdate(sql);
    }
}
执行sql语句有两种方法
ExeQuery 查询操作
ExeUpdate 增删改等操作

程序运行结果

执行语句 select * from user，程序运行截图：
C#操作mysql数据库的实例

结束语

第一次这么认真写博客，以后还会继续的，关于C#其实我是初学者，很多代码的Java味比较重，在实现上有可能绕了远路，还请批评指正。
因为最近做了一个C#操作Mysql的小项目，我也是边学边做，总结了一点小工具，稍后会继续与大家分享，感谢您的阅读。

标签：

相关文章