C#（.net） MySql数据库链接工具类

先下载和安装MySQLDriverCS 
http://sourceforge.net/projects/mysqldrivercs/

在安装文件夹下面找到MySQLDriver.dll，然后将MySQLDriver.dll添加引用到项目中

应用程序配置文件：

App.config:

    <?xml version="1.0" encoding="utf-8" ?>  
    <configuration>  
      
      
      <connectionStrings>  
      
        <add name="server" connectionString="localhost"></add>  
        <add name="database" connectionString="housing"></add>  
        <add name="login" connectionString="root"></add>  
        <add name="password" connectionString="root"></add>  
      </connectionStrings>  
    </configuration>  

SqlHelper.cs内容：

    using System;  
    using System.Collections.Generic;  
    using System.Linq;  
    using System.Text;  
    using System.Configuration;  
    using MySQLDriverCS;  
    using System.Data;  
      
    namespace Demo  
    {  
        class SqlHelper  
        {  
      
            private static string server = ConfigurationManager.ConnectionStrings["server"].ConnectionString;  
            private static string database = ConfigurationManager.ConnectionStrings["database"].ConnectionString;  
            private static string login = ConfigurationManager.ConnectionStrings["login"].ConnectionString;  
            private static string password = ConfigurationManager.ConnectionStrings["password"].ConnectionString;  
      
      
            public static int ExecuteNoQuery(String sql,MySQLParameter[] parameters)  
            {  
      
                using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString(server, database, login, password).AsString))  
                {  
      
                    conn.Open();  
      
                    
                    //防止乱码  
                    MySQLCommand commn = new MySQLCommand("set names gb2312", conn);  
                    commn.ExecuteNonQuery();  
                    //连接语句和SQL  
                    MySQLCommand cmd = new MySQLCommand(sql, conn);  
                    //添加参数  
                    cmd.Parameters.AddRange( parameters);  
                    //返回执行结果  
                    return cmd.ExecuteNonQuery();  
      
                }  
              
            }  
            public static object ExecuteScalar(String sql, MySQLParameter[] parameters)  
            {  
      
                using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString(server, database, login, password).AsString))  
                {  
      
                    conn.Open();  
                    //防止乱码  
                    MySQLCommand commn = new MySQLCommand("set names gb2312", conn);  
                    commn.ExecuteNonQuery();  
      
                    MySQLCommand cmd = new MySQLCommand(sql, conn);  
                    //添加参数  
                    cmd.Parameters.AddRange(parameters);  
                      
                    return cmd.ExecuteNonQuery();  
                }  
              
            }  
      
            //较少的时候  
            public static DataTable ExecuteReaderEx(String sql, MySQLParameter[] parameters)  
            {  
      
                using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString(server, database, login, password).AsString))  
                {  
      
                    conn.Open();  
                    //防止乱码  
                    MySQLCommand commn = new MySQLCommand("set names gb2312", conn);  
                    commn.ExecuteNonQuery();  
      
                    MySQLCommand cmd = new MySQLCommand(sql, conn);  
                    //添加参数  
                    cmd.Parameters.AddRange(parameters);  
      
                    MySQLDataAdapter mda = new MySQLDataAdapter(cmd);  
      
                    //查询出的数据是存在DataTable中的，DataTable可以理解成为一个虚拟的表，DataTable中的一行为一条记录，一列为一个数据库字段    
      
      
                    DataTable dt = new DataTable();  
                    mda.Fill(dt);    
      
                    return dt;  
                }  
      
            }  
            public static DataSet ExecuteReaderEx2(String sql, MySQLParameter[] parameters)  
            {  
      
      
                using (MySQLConnection conn = new MySQLConnection(new MySQLConnectionString(server, database, login, password).AsString))  
                {  
      
                    conn.Open();  
                    //防止乱码  
                    MySQLCommand commn = new MySQLCommand("set names gb2312", conn);  
                    commn.ExecuteNonQuery();  
      
                    MySQLCommand cmd = new MySQLCommand(sql, conn);  
                    //添加参数  
                    cmd.Parameters.AddRange(parameters);  
      
                    MySQLDataAdapter mda = new MySQLDataAdapter(cmd);  
      
                    //查询出的数据是存在DataTable中的，DataTable可以理解成为一个虚拟的表，DataTable中的一行为一条记录，一列为一个数据库字段    
      
      
                    DataSet ds = new DataSet();  
                    mda.Fill(ds);  
                    return ds;  
                }  
      
            }  
      
      
      
      
        }  
    }  

使用示例：

    //sql语句  
                  string sql = "update tbl_sysuser set isActived=@isActived where id=@id";  
              
      
                  int number = SqlHelper.ExecuteNoQuery(sql, new MySQLParameter[]   
                  {  
                      new MySQLParameter("@isActived", "YES"),  
                      new MySQLParameter("@id", 2)  
                  });  
                   
      
                  Console.WriteLine("受影响的行数:" + number);  

标签： Mysql 数据库

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点！
本站所提供的图片等素材，版权归原作者所有，如需使用，请与原作者联系。