<">
请输入搜索内容

热门搜索

Java Linux MySQL PHP JavaScript Hibernate jQuery Nginx
ww24
10年前发布

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);