SqlHelper

//获得配置文件的连接字符串
public static string strConn = System.Configuration.ConfigurationManager.ConnectionStrings["connStr"].ConnectionString;

#region 01.查询数据表 +static DataTable GetTabel(string strSql, params SqlParameter[] paras)
/// <summary>
/// 查询数据表
/// </summary>
/// <param name="strSql">sql语句</param>
/// <param name="paras">参数数组</param>
/// <returns></returns>
public static DataTable GetDataTable(string strSql, params SqlParameter[] paras)
{
SqlConnection conn = new SqlConnection(strConn);
//创建 适配器对象（sql命令，连接通道）
SqlDataAdapter da = new SqlDataAdapter(strSql, conn);
//添加参数
da.SelectCommand.Parameters.AddRange(paras);
//创建数据表对象
DataTable dt = new DataTable();
//适配器 读取数据库，并将查询的结果 装入程序的 dt里
da.Fill(dt);
return dt;
}
#endregion

#region 02.执行 增删改 (非查询语句) +int ExcuteNonQuery(string strSql, params SqlParameter[] paras)
/// <summary>
/// 执行 增删改 (非查询语句)
/// </summary>
/// <param name="strSql"></param>
/// <param name="paras"></param>
/// <returns></returns>
public static int ExcuteNonQuery(string strSql, params SqlParameter[] paras)
{
int res = -1;
//创建连接通道
using (SqlConnection conn = new SqlConnection(strConn))
{
//创建命令对象（sql语句，连接通道）
SqlCommand cmd = new SqlCommand(strSql, conn);
//添加参数
cmd.Parameters.AddRange(paras);
conn.Open();
res = cmd.ExecuteNonQuery();
}
return res;
}
#endregion

#region 02a.执行 多条增删改 (非查询语句) +int ExcuteNonQuery(string strSql, params SqlParameter[] paras)
/// <summary>
/// 执行 多条增删改 (非查询语句)
/// </summary>
/// <param name="strSql"></param>
/// <param name="paras"></param>
/// <returns></returns>
public static int ExcuteNonQuerys(string[] strSqls, SqlParameter[][] paras2Arr)
{
int res = 0;
//创建连接通道
using (SqlConnection conn = new SqlConnection(strConn))
{
conn.Open();
//创建 事务
SqlTransaction tran = conn.BeginTransaction();
//创建命令对象
SqlCommand cmd = new SqlCommand();
//为命令对象指定连接通道
cmd.Connection = conn;
//为命令对象指定事务
cmd.Transaction = tran;
try
{
//循环执行sql语句
for (int i = 0; i < strSqls.Length; i++)
{
//获得要执行的sql语句
string strSql = strSqls[i];
//为命令对象指定 此次执行的 sql语句
cmd.CommandText = strSql;
//添加参数
if (paras2Arr.Length > i)//如果 参数2维数组的长度大于当前循环的下标
{
cmd.Parameters.AddRange(paras2Arr[i]);//将 交错数组 的第一个元素（其实也是一个数组，添加到参数集合中）
}
res += cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
}
tran.Commit();//提交事务
}
catch (Exception ex)
{
res = 0;
tran.Rollback();//回滚事务
throw ex;
}
}
return res;
}
#endregion

#region 02.执行 查询单个值 +int ExcuteScalar(string strSql, params SqlParameter[] paras)
/// <summary>
/// 执行 增删改 (非查询语句)
/// </summary>
/// <param name="strSql"></param>
/// <param name="paras"></param>
/// <returns></returns>
public static int ExcuteScalar(string strSql, params SqlParameter[] paras)
{
int res = -1;
//创建连接通道
using (SqlConnection conn = new SqlConnection(strConn))
{
//创建命令对象（sql语句，连接通道）
SqlCommand cmd = new SqlCommand(strSql, conn);
//添加参数
cmd.Parameters.AddRange(paras);
conn.Open();
res = Convert.ToInt32(cmd.ExecuteScalar());
}
return res;
}
#endregion

#region 02a.执行 查询单个值 +int ExcuteScalars(string strSql, params SqlParameter[] paras2Arr)
///// <summary>
///// 执行 多个 查询单个值语句
///// </summary>
///// <param name="strSqls">sql语句数组</param>
///// <param name="paras2Arr">参数数组</param>
///// <returns></returns>
//public static int ExcuteScalars(string [] strSqls, params SqlParameter[][] paras2Arr)
//{
// int res = -1;
// //创建连接通道
// using (SqlConnection conn = new SqlConnection(strConn))
// {
// conn.Open();
// SqlTransaction tran = conn.BeginTransaction();//创建事务对象
// //创建命令对象（sql语句，连接通道）
// SqlCommand cmd = new SqlCommand();
// cmd.Connection = conn;//指定连接通道
// cmd.Transaction = tran;//指定事务对象
// for (int i = 0; i < strSqls.Length; i++)
// {
// //设置要执行的sql语句
// cmd.CommandText=strSqls[i];
// //添加参数
// cmd.Parameters.AddRange(paras2Arr[i]);
// res += Convert.ToInt32(cmd.ExecuteScalar());
// cmd.Parameters.Clear();//清空参数
// }
// }
// return res;
//}
#endregion

#region 04.执行 特殊的 分页存储过程 +DataTable GetPageListByProc(int pageIndex, int pageSize,out int pageCount,out int rowCount)
/// <summary>
///04.执行 特殊的 分页存储过程
/// </summary>
/// <param name="pageIndex">页码</param>
/// <param name="pageSize">页容量</param>
/// <param name="pageCount">总页数--输出</param>
/// <param name="rowCount">总行数--输出</param>
/// <returns></returns>
public static DataTable GetPageListByProc(int pageIndex, int pageSize,out int pageCount,out int rowCount)
{
DataTable dt = new DataTable();
//创建连接通道
using (SqlConnection conn = new SqlConnection(strConn))
{
//创建适配器对象
SqlDataAdapter da = new SqlDataAdapter("up_GetPagedData0809_rownum", conn);
//设置 命令类型 为存储过程
da.SelectCommand.CommandType = CommandType.StoredProcedure;
//设置 参数
da.SelectCommand.Parameters.AddWithValue("@pageIndex", pageIndex);//当前页码
da.SelectCommand.Parameters.AddWithValue("@pageSize", pageSize);//页容量

//在存储过程中 输出参数
da.SelectCommand.Parameters.Add(new SqlParameter("@pageCount", SqlDbType.Int));
da.SelectCommand.Parameters.Add(new SqlParameter("@rowCount",SqlDbType.Int));
//将后面两个参数 设置为 输出类型
da.SelectCommand.Parameters[2].Direction = ParameterDirection.Output;
da.SelectCommand.Parameters[3].Direction = ParameterDirection.Output;
//执行 并将查询到的 结果 赋给 数据表对象
da.Fill(dt);
//获得 存储过程 返回的 输出参数
pageCount = Convert.ToInt32(da.SelectCommand.Parameters[2].Value);
rowCount = Convert.ToInt32(da.SelectCommand.Parameters[3].Value);
}
//返回数据表
return dt;
}
#endregion

/// <summary>
/// 01.3为 对象数据源控件 提供 分页数据
/// </summary>
/// <param name="pageSize">页容量</param>
/// <param name="startRowIndex">起始行下标</param>
/// <returns></returns>
public static DataTable GetPagedListForObjectDataSource(int pageSize, int startRowIndex)
{
string strSql = "select * from(select Row_Number() over(order by cid) as num, * from Classes)as temp where num>@startRowIndex and num<=@size";
SqlParameter[] paras = {
new SqlParameter("@startRowIndex",startRowIndex),
new SqlParameter("@size",pageSize+startRowIndex)
};
return GetDataTable(strSql, paras);
}