本质引用MySql.Data
下载:
附赠找到Mysql的方法(知道mysql安装在哪里):
通过Navicat查找。
连接数据库:
配置文件:
<appSettings>
<add key="ConnStr" value="server=zqq;port=3306;user=root;password=malong1; database=cooperatesystem"/>
<add key="DB" value="DAL"/>
</appSettings>
命名空间:
using MySql.Data.MySqlClient;
SQLHELPER类:
如果之间写过sqlserver的可以稍稍修改即可
public class SQLHELPER
{
private MySqlConnection conn = null;
private MySqlCommand cmd = null;
private MySqlDataReader sdr = null;//从数据库中只读
public SQLHELPER()
{
string connStr = ConfigurationManager.AppSettings["connStr"]; //客户端访问配置文件,读取连接数据库信息;引用程序集的命名空间
conn = new MySqlConnection(connStr);//打开数据库的连接,此时并未连接成功
}
private MySqlConnection GetConn()
{
if (conn.State == ConnectionState.Closed) //枚举ConnectionState,用于描述数据源当前的连接状态
{
conn.Open();//连接数据库
}
return conn;
}
/// <summary>
/// 执行带参的SQL查询语句或存储过程
/// </summary>
/// <param name="cmdText"></param>
/// <param name="paras"></param>
/// <param name="ct"></param>
/// <returns></returns>
public DataTable ExecuteQuery(string cmdText, SqlParameter[] paras, CommandType ct)
{
DataTable dt = new DataTable();//实例化数据库内存中的一个表
cmd = new MySqlCommand(cmdText, GetConn()); //cmdText:查询的文本;getConn():连接数据库的方法
cmd.CommandType = ct;//指定命令对象的执行形式,默认为text
cmd.Parameters.AddRange(paras);//将参数加入到参数集中
using (sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection)) //在执行命令时,将关联 Connection 对象已关闭时关联 DataReader 对象已关闭
{
dt.Load(sdr); //将提供的数据源中的值填充到DataTable,如果已存在,则合并
}
return dt; //返回表到DAL层
}
/// <summary>
/// 执行不带参数的SQL查询语句或者存储过程
/// </summary>
/// <param name="cmdText">查询SQL语句或存储过程</param>
/// <param name="ct">命令类型</param>
/// <returns>返回受影响的行数</returns>
public DataTable ExecuteQuery(string cmdText, CommandType ct)
{
DataTable dt = new DataTable();
cmd = new MySqlCommand(cmdText, GetConn());
cmd.CommandType = ct;
using (sdr = cmd.ExecuteReader(CommandBehavior.CloseConnection))
{
dt.Load(sdr);
}
return dt;
}
/// <summary>
/// 执行不带参数的数据库操作或者存储过程heihei
/// </summary>
/// <param name="cmdText">增删改查操作</param>
/// <param name="ct">命令类型</param>
/// <returns>返回受影响的行数</returns>
public int ExecuteNonQuery(string cmdText, CommandType ct)
{
int res;
cmd = new MySqlCommand(cmdText, GetConn());
cmd.CommandType = ct;
res = cmd.ExecuteNonQuery();
if (conn.State == ConnectionState.Open)
{
conn.Close();
}
return res;
}
/// <summary>
/// 执行带参数的数据库操作或者存储过程
/// </summary>
/// <param name="cmdText">增删改查操作</param>
/// <param name="paras">要查询的参数</param>
/// <param name="ct">命令类型</param>
/// <returns>返回受影响的行数</returns>
public int ExecuteNonQuery(string cmdText, SqlParameter[] paras, CommandType ct)
{
int res;
using (cmd = new MySqlCommand(cmdText, GetConn()))
{
cmd.CommandType = ct;
cmd.Parameters.AddRange(paras);
res = cmd.ExecuteNonQuery();
}
return res;
}
}