苏飞论坛

标题: [SqlHelper] 看大家都在发,我也发出我写的，欢迎指教。 [打印本页]
作者: xiaomu    时间: 2013-9-28 18:25
标题: [SqlHelper] 看大家都在发,我也发出我写的，欢迎指教。
本帖最后由 xiaomu 于 2013-9-29 13:43 编辑

看大家都在发,我也发出我写的，小学毕业，自学成渣，欢迎指教。
  1. class SqlHelper//by.穆建情 2013-09-28
  2.     {
  3.         #region //SqlConnectionStr
  4.         /// <summary>
  5.         /// 数据库连接字符串
  6.         /// </summary>
  7.         private static string connStr = ConfigurationManager.ConnectionStrings["connStr"].ConnectionString;

  9.         #endregion

  11.         #region //ExecteQuery

  13.         /// <summary>
  14.         /// 执行 Transact-SQL 查询语句并返回DataTable.
  15.         /// </summary>
  16.         /// <param name="sqlStr">存储过程或者T-SQL语句</param>
  17.         /// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
  18.         /// <returns>返回一个查询结果集DataTable</returns>
  19.         public static DataTable ExecteTable(string sqlStr, params SqlParameter[] Parameters)
  20.         {
  21.             using (SqlConnection conn = new SqlConnection(connStr))
  22.             {
  23.                 conn.Open();
  24.                 using (SqlCommand cmd = conn.CreateCommand())
  25.                 {
  26.                     cmd.CommandText = sqlStr.Trim();
  27.                     cmd.Parameters.AddRange(Parameters);
  28.                     using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
  29.                     {
  30.                         DataTable dt = new DataTable();
  31.                         adapter.Fill(dt);
  32.                         return dt;
  33.                     }
  34.                 }
  35.             }
  36.         }

  38.         /// <summary>
  39.         /// 执行 Transact-SQL 查询语句并返回DataTable.
  40.         /// </summary>
  41.         /// <param name="sqlStr">存储过程或者T-SQL语句</param>
  42.         ///<param name="cmdType">SqlCommand命令类型 (存储过程,T-SQL语句,等等.)</param>
  43.         /// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
  44.         /// <returns>返回一个查询结果集DataTable</returns>
  45.         public static DataTable ExecteTable(string sqlStr, CommandType cmdType, params SqlParameter[] Parameters)
  46.         {
  47.             using (SqlConnection conn = new SqlConnection(connStr))
  48.             {
  49.                 conn.Open();
  50.                 using (SqlCommand cmd = conn.CreateCommand())
  51.                 {
  52.                     cmd.CommandText = sqlStr.Trim();
  53.                     cmd.CommandType = cmdType;
  54.                     cmd.Parameters.AddRange(Parameters);
  55.                     using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
  56.                     {
  57.                         DataTable dt = new DataTable();
  58.                         adapter.Fill(dt);
  59.                         return dt;
  60.                     }
  61.                 }
  62.             }
  63.         }

  65.         /// <summary>
  66.         /// 执行 Transact-SQL 查询语句并返回DataSet.
  67.         /// </summary>
  68.         /// <param name="cmdText">存储过程或者T-SQL语句</param>
  69.         /// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
  70.         /// <returns>返回一个查询结果集DataSet</returns>
  71.         public static DataSet ExecteDataSet(string sqlStr, params SqlParameter[] Parameters)
  72.         {
  73.             using (SqlConnection conn = new SqlConnection(connStr))
  74.             {
  75.                 conn.Open();
  76.                 using (SqlCommand cmd = conn.CreateCommand())
  77.                 {
  78.                     cmd.CommandText = sqlStr.Trim();
  79.                     cmd.Parameters.AddRange(Parameters);
  80.                     using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
  81.                     {
  82.                         DataSet ds = new DataSet();
  83.                         adapter.Fill(ds);
  84.                         return ds;
  85.                     }
  86.                 }
  87.             }
  88.         }

  90.         /// <summary>
  91.         /// 执行 Transact-SQL 查询语句并返回DataSet.
  92.         /// </summary>
  93.         /// <param name="cmdText">存储过程或者T-SQL语句</param>
  94.         /// <param name="cmdType">SqlCommand命令类型 (存储过程,T-SQL语句,等等.)</param>
  95.         /// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
  96.         /// <returns>返回一个查询结果集DataSet</returns>
  97.         public static DataSet ExecteDataSet(string sqlStr, CommandType cmdType, params SqlParameter[] Parameters)
  98.         {
  99.             using (SqlConnection conn = new SqlConnection(connStr))
  100.             {
  101.                 conn.Open();
  102.                 using (SqlCommand cmd = conn.CreateCommand())
  103.                 {
  104.                     cmd.CommandText = sqlStr.Trim();
  105.                     cmd.CommandType = cmdType;
  106.                     cmd.Parameters.AddRange(Parameters);
  107.                     using (SqlDataAdapter adapter = new SqlDataAdapter(cmd))
  108.                     {
  109.                         DataSet ds = new DataSet();
  110.                         adapter.Fill(ds);
  111.                         return ds;
  112.                     }
  113.                 }
  114.             }
  115.         }

  117.         /// <summary>
  118.         /// 执行 Transact-SQL 查询语句并返回SqlDataReader.
  119.         /// </summary>
  120.         /// <param name="cmdText">存储过程或者T-SQL语句</param>
  121.         /// <param name="Parameters">以数组形式提供SqlCommand命令中的参数</param>
  122.         /// <returns>返回一个SqlDataReader</returns>
  123.         public static SqlDataReader ExecteReader(string sqlStr, params SqlParameter[] Parameters)
  124.         {
  125.             SqlConnection conn = new SqlConnection(connStr);
复制代码
作者: xiaomu    时间: 2013-9-28 18:41
本帖最后由 xiaomu 于 2013-9-29 09:49 编辑

由于帖子长度限制不能完全发出，完整代码打包附件了。
另外谢谢"站长苏飞 "提出的一处bug。{:soso_e121:}
作者: 站长苏飞    时间: 2013-9-29 08:03
[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
可以参考下我的
http://www.sufeinet.com/thread-12-1-1.html
作者: xiaomu    时间: 2013-9-29 09:32
恩 应该去掉 SqlConnection 的 using
作者: 站长苏飞    时间: 2013-9-29 09:36
最好把这个参数也加上
SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
作者: xiaomu    时间: 2013-9-29 09:47
站长苏飞 发表于 2013-9-29 09:36
最好把这个参数也加上
SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection);

那个必须加哇。加了的
作者: xiaomu    时间: 2013-9-29 12:05
本帖最后由 xiaomu 于 2013-9-29 13:42 编辑

补充一个SqlBulkCopy方法
  1. #region//SqlBulkCopy

  3.         /// <summary>
  4.         /// 批量复制数据到数据库表。
  5.         /// </summary>
  6.         /// <param name="conn">数据库连接对象</param>
  7.         /// <param name="table">DataTable对象，TableName要与目标库中Table名称一致</param>
  8.         /// <returns>成功返回true,失败返回异常</returns>
  9.         public static bool SqlBulkCopy(SqlConnection conn, DataTable table)
  10.         {
  11.             if (conn.State != ConnectionState.Open) { conn.Open(); }
  12.             using (SqlTransaction transaction = conn.BeginTransaction())
  13.             {
  14.                 using (SqlBulkCopy sbc = new SqlBulkCopy(conn, SqlBulkCopyOptions.CheckConstraints, transaction))
  15.                 {
  16.                     try
  17.                     {
  18.                         //sbc.BulkCopyTimeout = 600;
  19.                         sbc.NotifyAfter = table.Rows.Count;
  20.                         sbc.DestinationTableName = table.TableName;
  21.                         sbc.WriteToServer(table);
  22.                         transaction.Commit();
  23.                         return true;
  24.                     }
  25.                     catch (Exception e)
  26.                     {
  27.                         transaction.Rollback();
  28.                         throw new Exception(e.Message);
  29.                     }
  30.                     finally//应该由外部调用时using
  31.                     {
  32.                         conn.Close();
  33.                     }
  34.                 }
  35.             }
  36.         }

  38.         /// <summary>
  39.         /// 批量复制数据到数据库表。
  40.         /// </summary>
  41.         /// <param name="conn">数据库连接对象</param>
  42.         /// <param name="tableName">目标数据库表名</param>
  43.         /// <param name="Reader">SqlDataReader对象</param>
  44.         /// <returns>成功返回true,失败返回异常</returns>
  45.         public static bool SqlBulkCopy(SqlConnection conn, string tableName, SqlDataReader Reader)
  46.         {
复制代码




欢迎光临 苏飞论坛 (http://www.sufeinet.com/) Powered by Discuz! X3.4