清华大佬耗费三个月吐血整理的几百G的资源,免费分享!....>>>
先下载和安装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);