C#(.net) MySql数据库链接工具类

C#(.net) MySql数据库链接工具类

先下载和安装MySQLDriverCS

应用程序配置文件:

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();//连接语句和SQLMySQLCommand 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);

不能接受失败,也意味太想去成功了,从心理学上解释,

C#(.net) MySql数据库链接工具类

相关文章:

你感兴趣的文章:

标签云: