C# sqlhelper 2
阿新 • • 發佈：2018-08-18
狀態 i++ 存儲過程 修改 ram 集合 manager 信息 exe
001 using System; 002 using System.Data; 003 using System.Configuration; 004 using System.Web; 005 using System.Web.Security; 006 using System.Collections; 007 using System.Data.SqlClient; 008 009 /// <summary> 010 /// 數據庫的通用訪問代碼 011 /// 此類為抽象類，不允許實例化，在應用時直接調用即可 012 /// </summary> 013public abstract class SqlHelper 014 { 015 //獲取數據庫連接字符串，其屬於靜態變量且只讀，項目中所有文檔可以直接使用，但不能修改 016 public static readonly string ConnectionStringLocalTransaction = ConfigurationManager.ConnectionStrings["pubsConnectionString"].ConnectionString; 017 018 // 哈希表用來存儲緩存的參數信息，哈希表可以存儲任意類型的參數。019 private static Hashtable parmCache = Hashtable.Synchronized(new Hashtable()); 020 021 /// <summary> 022 ///執行一個不需要返回值的SqlCommand命令，通過指定專用的連接字符串。 023 /// 使用參數數組形式提供參數列表 024 /// </summary> 025 /// <remarks> 026 /// 使用示例： 027 /// int result = ExecuteNonQuery(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24));028 /// </remarks> 029 /// <param name="connectionString">一個有效的數據庫連接字符串</param> 030 /// <param name="commandType">SqlCommand命令類型 (存儲過程， T-SQL語句， 等等。)</param> 031 /// <param name="commandText">存儲過程的名字或者 T-SQL 語句</param> 032 /// <param name="commandParameters">以數組形式提供SqlCommand命令中用到的參數列表</param> 033 /// <returns>返回一個數值表示此SqlCommand命令執行後影響的行數</returns> 034 public static int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters) 035 { 036 037 SqlCommand cmd = new SqlCommand(); 038 039 using (SqlConnection conn = new SqlConnection(connectionString)) 040 { 041 //通過PrePareCommand方法將參數逐個加入到SqlCommand的參數集合中 042 PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters); 043 int val = cmd.ExecuteNonQuery(); 044 045 //清空SqlCommand中的參數列表 046 cmd.Parameters.Clear(); 047 return val; 048 } 049 } 050 051 /// <summary> 052 ///執行一條不返回結果的SqlCommand，通過一個已經存在的數據庫連接 053 /// 使用參數數組提供參數 054 /// </summary> 055 /// <remarks> 056 /// 使用示例： 057 /// int result = ExecuteNonQuery(conn, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24)); 058 /// </remarks> 059 /// <param name="conn">一個現有的數據庫連接</param> 060 /// <param name="commandType">SqlCommand命令類型 (存儲過程， T-SQL語句， 等等。)</param> 061 /// <param name="commandText">存儲過程的名字或者 T-SQL 語句</param> 062 /// <param name="commandParameters">以數組形式提供SqlCommand命令中用到的參數列表</param> 063 /// <returns>返回一個數值表示此SqlCommand命令執行後影響的行數</returns> 064 public static int ExecuteNonQuery(SqlConnection connection, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters) 065 { 066 067 SqlCommand cmd = new SqlCommand(); 068 069 PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters); 070 int val = cmd.ExecuteNonQuery(); 071 cmd.Parameters.Clear(); 072 return val; 073 } 074 075 /// <summary> 076 /// 執行一條不返回結果的SqlCommand，通過一個已經存在的數據庫事物處理 077 /// 使用參數數組提供參數 078 /// </summary> 079 /// <remarks> 080 /// 使用示例： 081 /// int result = ExecuteNonQuery(trans, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24)); 082 /// </remarks> 083 /// <param name="trans">一個存在的 sql 事物處理</param> 084 /// <param name="commandType">SqlCommand命令類型 (存儲過程， T-SQL語句， 等等。)</param> 085 /// <param name="commandText">存儲過程的名字或者 T-SQL 語句</param> 086 /// <param name="commandParameters">以數組形式提供SqlCommand命令中用到的參數列表</param> 087 /// <returns>返回一個數值表示此SqlCommand命令執行後影響的行數</returns> 088 public static int ExecuteNonQuery(SqlTransaction trans, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters) 089 { 090 SqlCommand cmd = new SqlCommand(); 091 PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, commandParameters); 092 int val = cmd.ExecuteNonQuery(); 093 cmd.Parameters.Clear(); 094 return val; 095 } 096 097 /// <summary> 098 /// 執行一條返回結果集的SqlCommand命令，通過專用的連接字符串。 099 /// 使用參數數組提供參數 100 /// </summary> 101 /// <remarks> 102 /// 使用示例： 103 /// SqlDataReader r = ExecuteReader(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24)); 104 /// </remarks> 105 /// <param name="connectionString">一個有效的數據庫連接字符串</param> 106 /// <param name="commandType">SqlCommand命令類型 (存儲過程， T-SQL語句， 等等。)</param> 107 /// <param name="commandText">存儲過程的名字或者 T-SQL 語句</param> 108 /// <param name="commandParameters">以數組形式提供SqlCommand命令中用到的參數列表</param> 109 /// <returns>返回一個包含結果的SqlDataReader</returns> 110 public static SqlDataReader ExecuteReader(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters) 111 { 112 SqlCommand cmd = new SqlCommand(); 113 SqlConnection conn = new SqlConnection(connectionString); 114 115 // 在這裏使用try/catch處理是因為如果方法出現異常，則SqlDataReader就不存在， 116 //CommandBehavior.CloseConnection的語句就不會執行，觸發的異常由catch捕獲。 117 //關閉數據庫連接，並通過throw再次引發捕捉到的異常。 118 try 119 { 120 PrepareCommand(cmd, conn, null, cmdType, cmdText, commandParameters); 121 SqlDataReader rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection); 122 cmd.Parameters.Clear(); 123 return rdr; 124 } 125 catch 126 { 127 conn.Close(); 128 throw; 129 } 130 } 131 132 /// <summary> 133 /// 執行一條返回第一條記錄第一列的SqlCommand命令，通過專用的連接字符串。 134 /// 使用參數數組提供參數 135 /// </summary> 136 /// <remarks> 137 /// 使用示例： 138 /// Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24)); 139 /// </remarks> 140 /// <param name="connectionString">一個有效的數據庫連接字符串</param> 141 /// <param name="commandType">SqlCommand命令類型 (存儲過程， T-SQL語句， 等等。)</param> 142 /// <param name="commandText">存儲過程的名字或者 T-SQL 語句</param> 143 /// <param name="commandParameters">以數組形式提供SqlCommand命令中用到的參數列表</param> 144 /// <returns>返回一個object類型的數據，可以通過 Convert.To{Type}方法轉換類型</returns> 145 public static object ExecuteScalar(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters) 146 { 147 SqlCommand cmd = new SqlCommand(); 148 149 using (SqlConnection connection = new SqlConnection(connectionString)) 150 { 151 PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters); 152 object val = cmd.ExecuteScalar(); 153 cmd.Parameters.Clear(); 154 return val; 155 } 156 } 157 158 /// <summary> 159 /// 執行一條返回第一條記錄第一列的SqlCommand命令，通過已經存在的數據庫連接。 160 /// 使用參數數組提供參數 161 /// </summary> 162 /// <remarks> 163 /// 使用示例： 164 /// Object obj = ExecuteScalar(connString, CommandType.StoredProcedure, "PublishOrders", new SqlParameter("@prodid", 24)); 165 /// </remarks> 166 /// <param name="conn">一個已經存在的數據庫連接</param> 167 /// <param name="commandType">SqlCommand命令類型 (存儲過程， T-SQL語句， 等等。)</param> 168 /// <param name="commandText">存儲過程的名字或者 T-SQL 語句</param> 169 /// <param name="commandParameters">以數組形式提供SqlCommand命令中用到的參數列表</param> 170 /// <returns>返回一個object類型的數據，可以通過 Convert.To{Type}方法轉換類型</returns> 171 public static object ExecuteScalar(SqlConnection connection, CommandType cmdType, string cmdText, params SqlParameter[] commandParameters) 172 { 173 174 SqlCommand cmd = new SqlCommand(); 175 176 PrepareCommand(cmd, connection, null, cmdType, cmdText, commandParameters); 177 object val = cmd.ExecuteScalar(); 178 cmd.Parameters.Clear(); 179 return val; 180 } 181 182 /// <summary> 183 /// 緩存參數數組 184 /// </summary> 185 /// <param name="cacheKey">參數緩存的鍵值</param> 186 /// <param name="cmdParms">被緩存的參數列表</param> 187 public static void CacheParameters(string cacheKey, params SqlParameter[] commandParameters) 188 { 189 parmCache[cacheKey] = commandParameters; 190 } 191 192 /// <summary> 193 /// 獲取被緩存的參數 194 /// </summary> 195 /// <param name="cacheKey">用於查找參數的KEY值</param> 196 /// <returns>返回緩存的參數數組</returns> 197 public static SqlParameter[] GetCachedParameters(string cacheKey) 198 { 199 SqlParameter[] cachedParms = (SqlParameter[])parmCache[cacheKey]; 200 201 if (cachedParms == null) 202 return null; 203 204 //新建一個參數的克隆列表 205 SqlParameter[] clonedParms = new SqlParameter[cachedParms.Length]; 206 207 //通過循環為克隆參數列表賦值 208 for (int i = 0, j = cachedParms.Length; i < j; i++) 209 //使用clone方法復制參數列表中的參數 210 clonedParms[i] = (SqlParameter)((ICloneable)cachedParms[i]).Clone(); 211 212 return clonedParms; 213 } 214 215 /// <summary> 216 /// 為執行命令準備參數 217 /// </summary> 218 /// <param name="cmd">SqlCommand 命令</param> 219 /// <param name="conn">已經存在的數據庫連接</param> 220 /// <param name="trans">數據庫事物處理</param> 221 /// <param name="cmdType">SqlCommand命令類型 (存儲過程， T-SQL語句， 等等。)</param> 222 /// <param name="cmdText">Command text，T-SQL語句 例如 Select * from Products</param> 223 /// <param name="cmdParms">返回帶參數的命令</param> 224 private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, CommandType cmdType, string cmdText, SqlParameter[] cmdParms) 225 { 226 227 //判斷數據庫連接狀態 228 if (conn.State != ConnectionState.Open) 229 conn.Open(); 230 231 cmd.Connection = conn; 232 cmd.CommandText = cmdText; 233 234 //判斷是否需要事物處理 235 if (trans != null) 236 cmd.Transaction = trans; 237 238 cmd.CommandType = cmdType; 239 240 if (cmdParms != null) 241 { 242 foreach (SqlParameter parm in cmdParms) 243 cmd.Parameters.Add(parm); 244 } 245 } 246 }
C# sqlhelper 2