查看: 140|回复: 3

简写的通用数据层代码!

[复制链接]

`|楛纞♂ぺ﹖

电梯直达

1^#

发表于 2009-9-14 06:53:50 | 只看该作者回帖奖励

|正序浏览 |阅读模式

public class SqlHelper
...{
      ExecuteNonQuery的两个重载#region ExecuteNonQuery的两个重载
      public static int ExecuteNonQuery(string connStr, CommandType commandType, string commStr)
      ...{
         SqlConnection conn = new SqlConnection(connStr);
         SqlCommand comm = new SqlCommand(commStr, conn);
         comm.CommandType = commandType;
         conn.Open();
         int rowNum = comm.ExecuteNonQuery();
         comm.Dispose();
         conn.Close();

         return rowNum;
      }
      public static int ExecuteNonQuery(string connStr, CommandType commandType, string commStr, params SqlParameter[] commandParameters)
      ...{
         SqlConnection conn = new SqlConnection(connStr);
         SqlCommand comm = new SqlCommand(commStr, conn);
         comm.CommandType = commandType;

         for (int i = 0; i < commandParameters.Length; i++)
            comm.Parameters.Add(commandParameters);

         conn.Open();
         int rowNum = comm.ExecuteNonQuery();
         comm.Dispose();
         conn.Close();

         return rowNum;
      }
      #endregion

      ExecuteScalar的两个重载#region ExecuteScalar的两个重载
      public static object ExecuteScalar(string connStr, CommandType commandType, string commStr)
      ...{
         SqlConnection conn = new SqlConnection(connStr);
         SqlCommand comm = new SqlCommand(commStr, conn);
         comm.CommandType = commandType;

         conn.Open();
         object firstObj = comm.ExecuteScalar();
         comm.Dispose();
         conn.Close();

         return firstObj;
      }

      public static object ExecuteScalar(string connStr, CommandType commandType, string commStr, params SqlParameter[] commandParameters)
      ...{
         SqlConnection conn = new SqlConnection(connStr);
         SqlCommand comm = new SqlCommand(commStr, conn);
         comm.CommandType = commandType;

         for (int i = 0; i < commandParameters.Length; i++)
            comm.Parameters.Add(commandParameters);

         conn.Open();
         object firstObj = comm.ExecuteScalar();
         comm.Dispose();
         conn.Close();

         return firstObj;
      }
      #endregion

      ExecuteReader的两个重载#region ExecuteReader的两个重载
      public static SqlDataReader ExecuteReader(string connStr, CommandType commandType, string commStr)
      ...{
         SqlConnection conn = new SqlConnection(connStr);
         SqlCommand comm = new SqlCommand(commStr, conn);
         comm.CommandType = commandType;

         conn.Open();
         SqlDataReader reader = comm.ExecuteReader(CommandBehavior.CloseConnection);

         return reader;
      }

      public static SqlDataReader ExecuteReader(string connStr, CommandType commandType, string commStr, params SqlParameter[] commandParameters)
      ...{
         SqlConnection conn = new SqlConnection(connStr);
         SqlCommand comm = new SqlCommand(commStr, conn);
         comm.CommandType = commandType;

         for (int i = 0; i < commandParameters.Length; i++)
            comm.Parameters.Add(commandParameters);

         conn.Open();
         SqlDataReader reader = comm.ExecuteReader(CommandBehavior.CloseConnection);

         return reader;
      }
      #endregion

      SqlDataSetAdapter的两个重载#region SqlDataSetAdapter的两个重载
      public static DataSet SqlDataSetAdapter(string connStr, CommandType commandType, string commStr, params SqlParameter[] commandParameters)
      ...{
         SqlConnection conn = new SqlConnection(connStr);
         SqlCommand comm = new SqlCommand(commStr, conn);
         comm.CommandType = commandType;

         for (int i = 0; i < commandParameters.Length; i++)
            comm.Parameters.Add(commandParameters);

         SqlDataAdapter sda = new SqlDataAdapter(comm);
         DataSet ds = new DataSet();

         sda.Fill(ds);
         return ds;
      }

      public static DataSet SqlDataSetAdapter(string connStr, CommandType commandType, string commStr)
      ...{
         SqlConnection conn = new SqlConnection(connStr);
         SqlCommand comm = new SqlCommand(commStr, conn);
         comm.CommandType = commandType;

         SqlDataAdapter sda = new SqlDataAdapter(comm);
         DataSet ds = new DataSet();

         sda.Fill(ds);
         return ds;
      }
      #endregion

}

收藏0