Pastebin.vip

Connect to the database, add, delete, modify and query the database

From , 4 Years ago, written in C#, viewed 54 times.
URL https://pastebin.vip/view/dbab2adc
  1.  public class SqlHelper
  2.     {
  3.         //数据库连接词
  4.         private static string constr = System.Configuration.ConfigurationManager.ConnectionStrings["constr"].ToString();
  5.  
  6.         /// <summary>
  7.         /// SQL语句 无参查询
  8.         /// </summary>
  9.         /// <param name="sql">select 语句</param>
  10.         /// <returns>返回SqlDataReader</returns>
  11.         public static SqlDataReader Query(string sql)
  12.         {
  13.             SqlConnection conn = new SqlConnection(constr);
  14.             try
  15.             {
  16.                 if (conn.State != ConnectionState.Open)
  17.                     conn.Open();
  18.                 SqlCommand cmd = new SqlCommand(sql, conn);
  19.                 return cmd.ExecuteReader(CommandBehavior.CloseConnection);
  20.             }
  21.             catch
  22.             {
  23.                 if(conn.State==ConnectionState.Open)
  24.                 {
  25.                     conn.Close();
  26.                 }
  27.                 throw;
  28.             }
  29.         }
  30.  
  31.         /// <summary>
  32.         /// SQL语句 有参查询
  33.         /// </summary>
  34.         /// <param name="sql">select 语句</param>
  35.         /// <param name="para">SQL参数</param>
  36.         /// <returns>返回SqlDataReader</returns>
  37.         public static SqlDataReader Query(string sql, SqlParameter[] para)
  38.         {
  39.             SqlConnection conn = new SqlConnection(constr);
  40.             try
  41.             {
  42.                 if (conn.State != ConnectionState.Open)
  43.                     conn.Open();
  44.                 SqlCommand cmd = new SqlCommand(sql, conn);
  45.                 cmd.Parameters.AddRange(para);
  46.                 return cmd.ExecuteReader(CommandBehavior.CloseConnection);
  47.             }
  48.             catch
  49.             {
  50.                 if(conn.State==ConnectionState.Open)
  51.                 {
  52.                     conn.Close();
  53.                 }
  54.                 throw;
  55.             }
  56.         }
  57.  
  58.         /// <summary>
  59.         /// SQL语句 单一结果的无参查询
  60.         /// </summary>
  61.         /// <param name="sql">select 语句</param>
  62.         /// <returns>返回 object</returns>
  63.         public static object QueryScalar(string sql)
  64.         {
  65.             using (SqlConnection conn = new SqlConnection(constr))
  66.             {
  67.                 if (conn.State != ConnectionState.Open)
  68.                     conn.Open();
  69.                 SqlCommand cmd = new SqlCommand(sql, conn);
  70.                 return cmd.ExecuteScalar();
  71.             }
  72.         }
  73.  
  74.         /// <summary>
  75.         /// SQL语句 单一结果的有参查询
  76.         /// </summary>
  77.         /// <param name="sql">select 语句</param>
  78.         /// <param name="para">SQL参数</param>
  79.         /// <returns>返回 object</returns>
  80.         public static object QueryScalar(string sql,SqlParameter[] para)
  81.         {
  82.             using (SqlConnection conn = new SqlConnection(constr))
  83.             {
  84.                 if (conn.State != ConnectionState.Open)
  85.                     conn.Open();
  86.                 SqlCommand cmd = new SqlCommand(sql, conn);
  87.                 cmd.Parameters.AddRange(para);
  88.                 return cmd.ExecuteScalar();
  89.             }
  90.         }
  91.  
  92.         /// <summary>
  93.         /// SQL语句 无参增，删，改
  94.         /// </summary>
  95.         /// <param name="sql">insert,update,delete语句</param>
  96.         /// <returns>返回影响的行数</returns>
  97.         public static int NonQuery(string sql)
  98.         {
  99.             SqlConnection conn = new SqlConnection(constr);
  100.             SqlTransaction tran = null;
  101.             try
  102.             {
  103.                 conn.Open();
  104.                 tran = conn.BeginTransaction();
  105.                 SqlCommand cmd = new SqlCommand(sql, conn);
  106.                 cmd.Transaction = tran;
  107.                 int i = cmd.ExecuteNonQuery();
  108.                 tran.Commit();
  109.                 return i;
  110.             }
  111.             catch
  112.             {
  113.                 if (tran != null)
  114.                     tran.Rollback();
  115.                 throw;
  116.             }
  117.             finally
  118.             {
  119.                 if (conn.State == ConnectionState.Open)
  120.                     conn.Close();
  121.             }
  122.         }
  123.  
  124.         /// <summary>
  125.         /// SQL语句 有参增，删，改
  126.         /// </summary>
  127.         /// <param name="sql">insert,update,delete语句</param>
  128.         /// <param name="para">SQL参数</param>
  129.         /// <returns>返回影响的行数</returns>
  130.         public static int NonQuery(string sql,SqlParameter[] para)
  131.         {
  132.             SqlConnection conn = new SqlConnection(constr);
  133.             SqlTransaction tran = null;
  134.             try
  135.             {
  136.                 conn.Open();
  137.                 tran = conn.BeginTransaction();
  138.                 SqlCommand cmd = new SqlCommand(sql, conn);
  139.                 cmd.Parameters.AddRange(para);
  140.                 cmd.Transaction = tran;
  141.                 int i = cmd.ExecuteNonQuery();
  142.                 tran.Commit();
  143.                 return i;
  144.             }
  145.             catch (Exception e)
  146.             {
  147.                 if (tran != null)
  148.                     tran.Rollback();
  149.                 throw;
  150.             }
  151.             finally
  152.             {
  153.                 if (conn.State == ConnectionState.Open)
  154.                     conn.Close();
  155.             }
  156.         }
  157.     }

Reply to "Connect to the database, add, delete, modify and query the database"

Here you can reply to the paste above

captcha

https://burned.cc - Burn After Reading Website
Powered by Pastebin.vip paste tool since 2022!