usingSystem;
usingSystem.Collections.Generic;
usingSystem.Linq;
usingSystem.Text;
usingSystem.Data.SqlClient;
usingSystem.Configuration;
usingSystem.Data;
namespaceCommonDAL
{
publicclassSqlHelper
{
privatestaticreadonlystringCONNECTIONSTRING=ConfigurationManager.ConnectionStrings["sqlconn"].ToString();
///
///用于执行增加,删除,修改的存储过程
/// ///
存储过程名称
///存储过程中所需的参数(需要处理的数据)
publicstaticvoidExecuteProc(stringprocName,paramsSqlParameter[]sp)
{
using(SqlConnectionmyConn=newSqlConnection(CONNECTIONSTRING))
{
try
{
myConn.Open();
SqlCommandmyCmd=InitSqlCommand(myConn,procName,CommandType.StoredProcedure,sp);
myCmd.ExecuteNonQuery();
}
catch(Exceptione)
{
throwe;
}
}
}
///
///用于执行增,删,改的Sql语句
///
///要执行的SQL语句
///语句中的参数
///返回语句执行后的结果(受影响的行数)
publicstaticintExecuteNonQuery(stringsql,paramsSqlParameter[]sp)
{
intcount=0;
using(SqlConnectionmyConn=newSqlConnection(CONNECTIONSTRING))
{
myConn.Open();
SqlCommandmyCmd=InitSqlCommand(myConn,sql,CommandType.Text,sp);
count=myCmd.ExecuteNonQuery();
}
returncount;
}
///
///用于执行查询的sql语句
///
///要执行的查询语句
///语句中的参数
///返回数据读取对象,用于遍历查询后的结果
publicstaticSqlDataReaderExecuteReader(stringselect,paramsSqlParameter[]sp)
{
SqlConnectionmyConn=newSqlConnection(CONNECTIONSTRING);
myConn.Open();
SqlCommandmyCmd=InitSqlCommand(myConn,select,CommandType.Text,sp);
SqlDataReadermyReader=myCmd.ExecuteReader(CommandBehavior.CloseConnection);
returnmyReader;
}
///
///创建命令对象,用于执行sql语句和存储过程
///
///连接对象
///Sql语句或存储过程名
///命令对象的类型,用于决定命令对象是执行语句还是存储过程
///语句或存储过程中所定义的参数
///命令对象
publicstaticSqlCommandInitSqlCommand(SqlConnectionmyCon,stringcommadtext,CommandTypetype,paramsSqlParameter[]sp)
{
SqlCommandmyCmd=newSqlCommand();
myCmd.Connection=myCon;
myCmd.CommandType=type;
myCmd.CommandText=commadtext;
if(sp!=null)
myCmd.Parameters.AddRange(sp);
returnmyCmd;
}
///
///用于执行查询的存储过程
///
///要执行的过程名称
///存储过程中定义的参数
///返回数据读取对象,用于遍历查询后的结果
publicstaticSqlDataReaderExecuteProcReader(stringselect,paramsSqlParameter[]sp)
{
SqlConnectionmyConn=newSqlConnection(CONNECTIONSTRING);
myConn.Open();
SqlCommandmyCmd=InitSqlCommand(myConn,select,CommandType.StoredProcedure,sp);
SqlDataReadermyReader=myCmd.ExecuteReader(CommandBehavior.CloseConnection);
returnmyReader;
}
///
///将查询结果存入到数据集中
///
///要执行的查询语句
///存放查询结果的数据集
publicstaticDataSetGetDataSet(stringselect)
{
DataSetset=newDataSet();
using(SqlConnectionmyConn=newSqlConnection(CONNECTIONSTRING))
{
myConn.Open();
SqlDataAdapteradp=newSqlDataAdapter(select,myConn);
adp.Fill(set);
}
returnset;
}
}