C#连接MySQL数据库操作类

首先需要安装MySQL Connector Net 6.8.3

然后在项目中引用MySQL Connector，如下图所示

C#连接MySQL的操作类代码如下：

public class MySQLHelper
{
    private string db_host = "localhost"; //数据库服务器
    private string db_port = "3306"; //数据库端口号
    private string db_user = "root"; //数据库用户
    private string db_pass = "123456"; //数据库密码
    private string db_name = "myblog"; //数据库名
    
    private MySqlConnection dbconn;

    public MySQLHelper()
    {
        //do nothing
    }

    ~MySQLHelper()
    {
        this.CloseDBconn();
    }

    //连接数据库
    public void OpenDBconn()
    {
        this.dbconn = new MySqlConnection();
        this.dbconn.ConnectionString = "server=" + this.db_host + ";uid=" + this.db_user + ";pwd=" + this.db_pass + ";database=" + this.db_name + ";";
        if (this.db_port.Length > 0)
        {
            this.dbconn.ConnectionString += ";port=" + this.db_port;
        }
        try
        {
            this.dbconn.Open();
        }
        catch (MySqlException ex)
        {
            string message = "无法连接数据库: "+ ex.Message;
            string caption = "系统提示";
            MessageBoxButtons buttons = MessageBoxButtons.OK;
            DialogResult result = MessageBox.Show(message, caption, buttons);
            Environment.Exit(0);
        }
    }

    //关闭数据库
    public void CloseDBconn()
    {
        if (this.dbconn != null)
        {
            this.dbconn.Close();
        }
    }

    //查询数据
    public MySqlDataReader query(string sqltext)
    {
        MySqlCommand cmd = new MySqlCommand();
        cmd.Connection = this.dbconn;
        cmd.CommandType = CommandType.Text;
        cmd.CommandText = sqltext;
        MySqlDataReader reader = cmd.ExecuteReader();
        return reader;
    }

    //更新数据
    public int execute(string sqltext)
    {
        MySqlCommand cmd = new MySqlCommand();
        cmd.Connection = this.dbconn;
        cmd.CommandType = CommandType.Text;
        cmd.CommandText = sqltext;
        int result = cmd.ExecuteNonQuery();
        return result;
    }
}

使用方法(查询数据)：

this.dbhelper = new MySQLHelper();
this.dbhelper.OpenDBconn();
string sqltext = "s.e.l.e.c.t * from blog w.h.e.r.e id=123 order by id asc limit 0,1";
MySqlDataReader reader = this.dbhelper.query(sqltext);
if (reader.HasRows == false)
{
    this.logtext = "\r\n" + DateTime.Now.ToString() + ", 内容处理完成。";
    textBox1.AppendText(this.logtext);
    textBox1.ScrollToCaret();
    return;
}
else
{
    while (reader.Read() == true)
    {
        this.curr_id = Convert.ToInt32(reader["id"]);
        this.curr_title = reader["title"].ToString();
        this.curr_fileext = reader["fileext"].ToString();
        this.curr_filesize = Convert.ToDouble(reader["filesize"]) * 1024;
    }
    //do something more
}
reader.Close();
this.dbhelper.CloseDBconn();

使用方法(更新数据)：

this.dbhelper.OpenDBconn();
string sqlchan = "u.p.d.a.t.e blog set isfixed=1 w.h.e.r.e id=123";
this.dbhelper.execute(sqlchan);
this.dbhelper.CloseDBconn();