C#实现操作MySql数据层类MysqlHelper实例
本文实例讲述了C#实现操作MySql数据层类MysqlHelper。分享给大家供大家参考。具体如下：
usingSystem;
usingSystem.Data;
usingSystem.Configuration;
usingSystem.Collections.Generic;
usingSystem.Linq;
usingSystem.Text;
usingSystem.Xml.Linq;
usingMySql.Data;
usingMySql.Data.MySqlClient;
namespaceVideoWorks.ITmanage.DAL
{
publicabstractclassMySqlHelper
{
//数据库连接字符串
publicstaticstringConn="Database='device_manage';DataSource='localhost';UserId='root';Password='123456';charset='utf8';pooling=true;AllowZeroDatetime=True";
///<summary>
///给定连接的数据库用假设参数执行一个sql命令（不返回数据集）
///</summary>
///<paramname="connectionString">一个有效的连接字符串</param>
///<paramname="cmdType">命令类型(存储过程,文本,等等)</param>
///<paramname="cmdText">存储过程名称或者sql命令语句</param>
///<paramname="commandParameters">执行命令所用参数的集合</param>
///<returns>执行命令所影响的行数</returns>
publicstaticintExecuteNonQuery(stringconnectionString,CommandTypecmdType,stringcmdText,paramsMySqlParameter[]commandParameters)
{
MySqlCommandcmd=newMySqlCommand();
using(MySqlConnectionconn=newMySqlConnection(connectionString))
{
PrepareCommand(cmd,conn,null,cmdType,cmdText,commandParameters);
intval=cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
returnval;
}
}
///<summary>
///用现有的数据库连接执行一个sql命令（不返回数据集）
///</summary>
///<paramname="connection">一个现有的数据库连接</param>
///<paramname="cmdType">命令类型(存储过程,文本,等等)</param>
///<paramname="cmdText">存储过程名称或者sql命令语句</param>
///<paramname="commandParameters">执行命令所用参数的集合</param>
///<returns>执行命令所影响的行数</returns>
publicstaticintExecuteNonQuery(MySqlConnectionconnection,CommandTypecmdType,stringcmdText,paramsMySqlParameter[]commandParameters)
{
MySqlCommandcmd=newMySqlCommand();
PrepareCommand(cmd,connection,null,cmdType,cmdText,commandParameters);
intval=cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
returnval;
}
///<summary>
///使用现有的SQL事务执行一个sql命令（不返回数据集）
///</summary>
///<remarks>
///举例:
///intresult=ExecuteNonQuery(connString,CommandType.StoredProcedure,"PublishOrders",newMySqlParameter("@prodid",24));
///</remarks>
///<paramname="trans">一个现有的事务</param>
///<paramname="cmdType">命令类型(存储过程,文本,等等)</param>
///<paramname="cmdText">存储过程名称或者sql命令语句</param>
///<paramname="commandParameters">执行命令所用参数的集合</param>
///<returns>执行命令所影响的行数</returns>
publicstaticintExecuteNonQuery(MySqlTransactiontrans,CommandTypecmdType,stringcmdText,paramsMySqlParameter[]commandParameters)
{
MySqlCommandcmd=newMySqlCommand();
PrepareCommand(cmd,trans.Connection,trans,cmdType,cmdText,commandParameters);
intval=cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
returnval;
}
///<summary>
///用执行的数据库连接执行一个返回数据集的sql命令
///</summary>
///<remarks>
///举例:
///MySqlDataReaderr=ExecuteReader(connString,CommandType.StoredProcedure,"PublishOrders",newMySqlParameter("@prodid",24));
///</remarks>
///<paramname="connectionString">一个有效的连接字符串</param>
///<paramname="cmdType">命令类型(存储过程,文本,等等)</param>
///<paramname="cmdText">存储过程名称或者sql命令语句</param>
///<paramname="commandParameters">执行命令所用参数的集合</param>
///<returns>包含结果的读取器</returns>
publicstaticMySqlDataReaderExecuteReader(stringconnectionString,CommandTypecmdType,stringcmdText,paramsMySqlParameter[]commandParameters)
{
//创建一个MySqlCommand对象
MySqlCommandcmd=newMySqlCommand();
//创建一个MySqlConnection对象
MySqlConnectionconn=newMySqlConnection(connectionString);
//在这里我们用一个try/catch结构执行sql文本命令/存储过程，因为如果这个方法产生一个异常我们要关闭连接，因为没有读取器存在，
//因此commandBehaviour.CloseConnection就不会执行
try
{
//调用PrepareCommand方法，对MySqlCommand对象设置参数
PrepareCommand(cmd,conn,null,cmdType,cmdText,commandParameters);
//调用MySqlCommand的ExecuteReader方法
MySqlDataReaderreader=cmd.ExecuteReader(CommandBehavior.CloseConnection);
//清除参数
cmd.Parameters.Clear();
returnreader;
}
catch
{
//关闭连接，抛出异常
conn.Close();
throw;
}
}
///<summary>
///返回DataSet
///</summary>
///<paramname="connectionString">一个有效的连接字符串</param>
///<paramname="cmdType">命令类型(存储过程,文本,等等)</param>
///<paramname="cmdText">存储过程名称或者sql命令语句</param>
///<paramname="commandParameters">执行命令所用参数的集合</param>
///<returns></returns>
publicstaticDataSetGetDataSet(stringconnectionString,CommandTypecmdType,stringcmdText,paramsMySqlParameter[]commandParameters)
{
//创建一个MySqlCommand对象
MySqlCommandcmd=newMySqlCommand();
//创建一个MySqlConnection对象
MySqlConnectionconn=newMySqlConnection(connectionString);
//在这里我们用一个try/catch结构执行sql文本命令/存储过程，
//因为如果这个方法产生一个异常我们要关闭连接，因为没有读取器存在，
try
{
//调用PrepareCommand方法，对MySqlCommand对象设置参数
PrepareCommand(cmd,conn,null,cmdType,cmdText,commandParameters);
//调用MySqlCommand的ExecuteReader方法
MySqlDataAdapteradapter=newMySqlDataAdapter();
adapter.SelectCommand=cmd;
DataSetds=newDataSet();
adapter.Fill(ds);
//清除参数
cmd.Parameters.Clear();
conn.Close();
returnds;
}
catch(Exceptione)
{
throwe;
}
}
///<summary>
///用指定的数据库连接字符串执行一个命令并返回一个数据集的第一列
///</summary>
///<remarks>
///例如:
///Objectobj=ExecuteScalar(connString,CommandType.StoredProcedure,"PublishOrders",newMySqlParameter("@prodid",24));
///</remarks>
///<paramname="connectionString">一个有效的连接字符串</param>
///<paramname="cmdType">命令类型(存储过程,文本,等等)</param>
///<paramname="cmdText">存储过程名称或者sql命令语句</param>
///<paramname="commandParameters">执行命令所用参数的集合</param>
///<returns>用Convert.To{Type}把类型转换为想要的</returns>
publicstaticobjectExecuteScalar(stringconnectionString,CommandTypecmdType,stringcmdText,paramsMySqlParameter[]commandParameters)
{
MySqlCommandcmd=newMySqlCommand();
using(MySqlConnectionconnection=newMySqlConnection(connectionString))
{
PrepareCommand(cmd,connection,null,cmdType,cmdText,commandParameters);
objectval=cmd.ExecuteScalar();
cmd.Parameters.Clear();
returnval;
}
}
///<summary>
///用指定的数据库连接执行一个命令并返回一个数据集的第一列
///</summary>
///<remarks>
///例如:
///Objectobj=ExecuteScalar(connString,CommandType.StoredProcedure,"PublishOrders",newMySqlParameter("@prodid",24));
///</remarks>
///<paramname="connection">一个存在的数据库连接</param>
///<paramname="cmdType">命令类型(存储过程,文本,等等)</param>
///<paramname="cmdText">存储过程名称或者sql命令语句</param>
///<paramname="commandParameters">执行命令所用参数的集合</param>
///<returns>用Convert.To{Type}把类型转换为想要的</returns>
publicstaticobjectExecuteScalar(MySqlConnectionconnection,CommandTypecmdType,stringcmdText,paramsMySqlParameter[]commandParameters)
{
MySqlCommandcmd=newMySqlCommand();
PrepareCommand(cmd,connection,null,cmdType,cmdText,commandParameters);
objectval=cmd.ExecuteScalar();
cmd.Parameters.Clear();
returnval;
}
///<summary>
///准备执行一个命令
///</summary>
///<paramname="cmd">sql命令</param>
///<paramname="conn">OleDb连接</param>
///<paramname="trans">OleDb事务</param>
///<paramname="cmdType">命令类型例如存储过程或者文本</param>
///<paramname="cmdText">命令文本,例如:Select*fromProducts</param>
///<paramname="cmdParms">执行命令的参数</param>
privatestaticvoidPrepareCommand(MySqlCommandcmd,MySqlConnectionconn,MySqlTransactiontrans,CommandTypecmdType,stringcmdText,MySqlParameter[]cmdParms)
{
if(conn.State!=ConnectionState.Open)
conn.Open();
cmd.Connection=conn;
cmd.CommandText=cmdText;
if(trans!=null)
cmd.Transaction=trans;
cmd.CommandType=cmdType;
if(cmdParms!=null)
{
foreach(MySqlParameterparmincmdParms)
cmd.Parameters.Add(parm);
}
}
}
}
希望本文所述对大家的C#程序设计有所帮助。