[SqlHelper] 看大家都在发,我也发出我写的，欢迎指教。

xiaomu · 发表于 2013-9-28 18:25:36

本帖最后由 xiaomu 于 2013-9-29 13:43 编辑

看大家都在发,我也发出我写的，小学毕业，自学成渣，欢迎指教。

class SqlHelper//by.穆建情 2013-09-28
{
#region //SqlConnectionStr
/// <summary>
/// 数据库连接字符串
/// </summary>
private static string connStr = ConfigurationManager.ConnectionStrings["connStr"].ConnectionString;
#endregion
#region //ExecteQuery
/// <summary>
/// 执行 Transact-SQL 查询语句并返回DataTable.
/// </summary>
/// <param name="sqlStr">存储过程或者T-SQL语句</param>
/// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
/// <returns>返回一个查询结果集DataTable</returns>
public static DataTable ExecteTable(string sqlStr, params SqlParameter[] Parameters)
{
using (SqlConnection conn = new SqlConnection(connStr))
{
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = sqlStr.Trim();
cmd.Parameters.AddRange(Parameters);
using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
{
DataTable dt = new DataTable();
adapter.Fill(dt);
return dt;
}
}
}
}
/// <summary>
/// 执行 Transact-SQL 查询语句并返回DataTable.
/// </summary>
/// <param name="sqlStr">存储过程或者T-SQL语句</param>
///<param name="cmdType">SqlCommand命令类型 (存储过程,T-SQL语句,等等.)</param>
/// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
/// <returns>返回一个查询结果集DataTable</returns>
public static DataTable ExecteTable(string sqlStr, CommandType cmdType, params SqlParameter[] Parameters)
{
using (SqlConnection conn = new SqlConnection(connStr))
{
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = sqlStr.Trim();
cmd.CommandType = cmdType;
cmd.Parameters.AddRange(Parameters);
using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
{
DataTable dt = new DataTable();
adapter.Fill(dt);
return dt;
}
}
}
}
/// <summary>
/// 执行 Transact-SQL 查询语句并返回DataSet.
/// </summary>
/// <param name="cmdText">存储过程或者T-SQL语句</param>
/// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
/// <returns>返回一个查询结果集DataSet</returns>
public static DataSet ExecteDataSet(string sqlStr, params SqlParameter[] Parameters)
{
using (SqlConnection conn = new SqlConnection(connStr))
{
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = sqlStr.Trim();
cmd.Parameters.AddRange(Parameters);
using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
{
DataSet ds = new DataSet();
adapter.Fill(ds);
return ds;
}
}
}
}
/// <summary>
/// 执行 Transact-SQL 查询语句并返回DataSet.
/// </summary>
/// <param name="cmdText">存储过程或者T-SQL语句</param>
/// <param name="cmdType">SqlCommand命令类型 (存储过程,T-SQL语句,等等.)</param>
/// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
/// <returns>返回一个查询结果集DataSet</returns>
public static DataSet ExecteDataSet(string sqlStr, CommandType cmdType, params SqlParameter[] Parameters)
{
using (SqlConnection conn = new SqlConnection(connStr))
{
conn.Open();
using (SqlCommand cmd = conn.CreateCommand())
{
cmd.CommandText = sqlStr.Trim();
cmd.CommandType = cmdType;
cmd.Parameters.AddRange(Parameters);
using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
{
DataSet ds = new DataSet();
adapter.Fill(ds);
return ds;
}
}
}
}
/// <summary>
/// 执行 Transact-SQL 查询语句并返回SqlDataReader.
/// </summary>
/// <param name="cmdText">存储过程或者T-SQL语句</param>
/// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
/// <returns>返回一个SqlDataReader</returns>
public static SqlDataReader ExecteReader(string sqlStr, params SqlParameter[] Parameters)
{
SqlConnection conn = new SqlConnection(connStr);

复制代码

xiaomu · 发表于 2013-9-28 18:41:42

本帖最后由 xiaomu 于 2013-9-29 09:49 编辑

由于帖子长度限制不能完全发出，完整代码打包附件了。
另外谢谢"站长苏飞 "提出的一处bug。{:soso_e121:}

站长苏飞 · 发表于 2013-9-29 08:03:05

[code=csharp]/// <summary>
      /// 执行 Transact-SQL 查询语句并返回SqlDataReader.
      /// </summary>
      /// <param name="cmdText">存储过程或者T-SQL语句</param>
      /// <param name="cmdType">SqlCommand命令类型 (存储过程,T-SQL语句,等等.)</param>
      /// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
      /// <returns>返回一个SqlDataReader</returns>
      public static SqlDataReader ExecteReader(string sqlStr, CommandType cmdType, params SqlParameter[] Parameters)
      {
         using (SqlConnection conn = new SqlConnection(connStr))
         {
            conn.Open();
            using (SqlCommand cmd = conn.CreateCommand())
            {
                  cmd.CommandText = sqlStr.Trim();
                  cmd.CommandType = cmdType;
                  cmd.Parameters.AddRange(Parameters);
                  SqlDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
                  return reader;
            }
         }
      }[/code]
这个方法你应该是从来都没有用过吧，
SqlDataReader 里都使用Using把SqlConnection都关闭了，还怎么让人读啊。

站长苏飞 · 发表于 2013-9-29 08:04:46

可以参考下我的
http://www.sufeinet.com/thread-12-1-1.html

xiaomu · 发表于 2013-9-29 09:32:13

恩应该去掉 SqlConnection 的 using

站长苏飞 · 发表于 2013-9-29 09:36:21

最好把这个参数也加上
SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);

xiaomu · 发表于 2013-9-29 09:47:40

站长苏飞发表于 2013-9-29 09:36
最好把这个参数也加上
SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);

那个必须加哇。加了的

xiaomu · 发表于 2013-9-29 12:05:30

本帖最后由 xiaomu 于 2013-9-29 13:42 编辑

补充一个SqlBulkCopy方法

#region//SqlBulkCopy
/// <summary>
/// 批量复制数据到数据库表。
/// </summary>
/// <param name="conn">数据库连接对象</param>
/// <param name="table">DataTable对象，TableName要与目标库中Table名称一致</param>
/// <returns>成功返回true,失败返回异常</returns>
public static bool SqlBulkCopy(SqlConnection conn, DataTable table)
{
if (conn.State != ConnectionState.Open) { conn.Open(); }
using (SqlTransaction transaction = conn.BeginTransaction())
{
using (SqlBulkCopy sbc = new SqlBulkCopy(conn, SqlBulkCopyOptions.CheckConstraints, transaction))
{
try
{
//sbc.BulkCopyTimeout = 600;
sbc.NotifyAfter = table.Rows.Count;
sbc.DestinationTableName = table.TableName;
sbc.WriteToServer(table);
transaction.Commit();
return true;
}
catch (Exception e)
{
transaction.Rollback();
throw new Exception(e.Message);
}
finally//应该由外部调用时using
{
conn.Close();
}
}
}
}
/// <summary>
/// 批量复制数据到数据库表。
/// </summary>
/// <param name="conn">数据库连接对象</param>
/// <param name="tableName">目标数据库表名</param>
/// <param name="Reader">SqlDataReader对象</param>
/// <returns>成功返回true,失败返回异常</returns>
public static bool SqlBulkCopy(SqlConnection conn, string tableName, SqlDataReader Reader)
{

复制代码

		自动登录	找回密码
密码			马上注册

[功能帮助类] [SqlHelper] 看大家都在发,我也发出我写的，欢迎指教。