欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

C#连接操作MySQL数据库详细步骤 帮助类等(二次改进版)

程序员文章站 2022-07-10 16:50:33
最近准备写一个仓库管理的项目 客户要求使用C#编写MySQL存储数据 为了方便,整理了数据库操作的工具类 首先在项目App.config 文件下添加节点 例如: 然后在项目引用中添加MySQL.DAL.dll 类库 vs版本低的可能找不到这个类库,,只有去网上下载,然后添加本地引用了 然后编写工具类 ......

 

 

 

 

最近准备写一个仓库管理的项目

  客户要求使用C#编写MySQL存储数据

  为了方便,整理了数据库操作的工具类

 

首先在项目App.config 文件下添加节点

<connectionStrings>
    <add name="constr" connectionString="server=localhost;port=3306;user id=root;password=pwd;database=数据库;"/>
  </connectionStrings>

例如:

C#连接操作MySQL数据库详细步骤 帮助类等(二次改进版)

 

 然后在项目引用中添加MySQL.DAL.dll  类库

C#连接操作MySQL数据库详细步骤 帮助类等(二次改进版)

 

 C#连接操作MySQL数据库详细步骤 帮助类等(二次改进版)

 

 

vs版本低的可能找不到这个类库,,只有去网上下载,然后添加本地引用了

 

 

然后编写工具类:

 

 

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using MySql.Data.MySqlClient;

/// <summary>
/// @author: 房上的猫
/// 
/// @博客地址: https://www.cnblogs.com/lsy131479/
/// </summary>

namespace ConsoleApp1
{
    public class MySQLDBHelp
    {
        public static string Constr = ConfigurationManager.ConnectionStrings["constr"].ConnectionString;

        #region  建立MySql数据库连接
        /// <summary>
        /// 建立数据库连接.
        /// </summary>
        /// <returns>返回MySqlConnection对象</returns>
        public MySqlConnection getMySqlCon()
        {
            string M_str_sqlcon = Constr;// "server=localhost;port=3306;user id=root;password=root;database=car"; //根据自己的设置
            MySqlConnection myCon = new MySqlConnection(M_str_sqlcon);
            return myCon;
        }
        #endregion

        #region  执行MySqlCommand命令
        /// <summary>
        /// 执行MySqlCommand
        /// </summary>
        /// <param name="M_str_sqlstr">SQL语句</param>
        public void getMySqlCom(string M_str_sqlstr)
        {
            MySqlConnection mysqlcon = this.getMySqlCon();
            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 getMySqlRead(string M_str_sqlstr)
        {
            MySqlConnection mysqlcon = this.getMySqlCon();
            MySqlCommand mysqlcom = new MySqlCommand(M_str_sqlstr, mysqlcon);
            mysqlcon.Open();
            MySqlDataReader mysqlread = mysqlcom.ExecuteReader(CommandBehavior.CloseConnection);
            return mysqlread;
        }
        #endregion
    }
}

 

 

 

进行测试:

 class Program
    {
        static void Main(string[] args)
        {
            MySQLDBHelp help = new MySQLDBHelp();
        
            String sql = "select * from insertcar";
            MySqlDataReader dr = help.getmysqlread(sql);
            while (dr.Read())
            {
                Console.WriteLine(dr["tax"].ToString());
            }
    
            Console.Read();
        }
    }

结果:

C#连接操作MySQL数据库详细步骤 帮助类等(二次改进版)