前言 上一次資料庫災備和性能優化後,資料庫專家建議,在不擴容的情況下,客戶端不能再頻繁的掃描資料庫了!一句驚醒夢中人,因為我也發現資料庫越來越卡了,自從上個項目上線後,就出現了這個情況。後來分析其原因,發現客戶端每3秒中掃描一次資料庫,一共5000+客戶端,可想而知,頻繁掃描嚴重影響到資料庫性能。所 ...
前言
上一次資料庫災備和性能優化後,資料庫專家建議,在不擴容的情況下,客戶端不能再頻繁的掃描資料庫了!一句驚醒夢中人,因為我也發現資料庫越來越卡了,自從上個項目上線後,就出現了這個情況。後來分析其原因,發現客戶端每3秒中掃描一次資料庫,一共5000+客戶端,可想而知,頻繁掃描嚴重影響到資料庫性能。所以,我這邊準備採用三層架構來解決這個問題,將現有的業務邏輯全部移植到WebService伺服器上,客戶端通過WebService服務,進而實現對資料庫的操作。
此篇只是記錄一下,便於後續的學習,不足之處請指正。
創建WebService服務
- 新建ASP.NET Web解決方案,命名為WebServiceTest,框架選擇.NET Framework 4,如下圖;
- 添加一個Web服務,命名為WebServiceOracleTest,如下圖;
- 開始寫一些基礎Helper類;
1 using System; 2 using System.Collections.Generic; 3 using System.Linq; 4 using System.Web; 5 using System.Data; 6 using System.Configuration; 7 using Oracle.ManagedDataAccess.Client; 8 using System.Text; 9 using System.IO; 10 11 namespace WebServiceTest 12 { 13 public class OracleHelper 14 { 15 //連接字元串 16 public static string oraConnStr = "Data Source=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=XXX)(PORT=1521))(CONNECT_DATA=(SERVICE_NAME=XXX)));Persist Security Info=True;User ID=XXX;Password=XXX"; 17 18 #region Oracle資料庫操作通用方法 19 /// <summary> 20 /// 測試資料庫連接是否正常 21 /// </summary> 22 /// <param name="strConn"></param> 23 /// <returns></returns> 24 public static bool CheckOracleConnect() 25 { 26 try 27 { 28 OracleConnection conn = new OracleConnection(); 29 conn.ConnectionString = oraConnStr; 30 conn.Open(); 31 return true; 32 } 33 catch 34 { 35 return false; 36 } 37 } 38 39 /// <summary> 40 /// 執行資料庫非查詢操作,返回受影響的行數 41 /// </summary> 42 /// <param name="connectionString">資料庫連接字元串</param> 43 /// <param name="cmdType">命令的類型</param> 44 /// <param name="cmdText">Oracle存儲過程名稱或PL/SQL命令</param> 45 /// <param name="cmdParms">命令參數集合</param> 46 /// <returns>當前查詢操作影響的數據行數</returns> 47 public static int ExecuteNonQuery(string connectionString, CommandType cmdType, string cmdText, params OracleParameter[] cmdParms) 48 { 49 OracleCommand cmd = new OracleCommand(); 50 using (OracleConnection conn = new OracleConnection(connectionString)) 51 { 52 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms); 53 int val = cmd.ExecuteNonQuery(); 54 cmd.Parameters.Clear(); 55 return val; 56 } 57 } 58 59 /// <summary> 60 /// 執行資料庫事務非查詢操作,返回受影響的行數 61 /// </summary> 62 /// <param name="transaction">資料庫事務對象</param> 63 /// <param name="cmdType">Command類型</param> 64 /// <param name="cmdText">Oracle存儲過程名稱或PL/SQL命令</param> 65 /// <param name="cmdParms">命令參數集合</param> 66 /// <returns>當前事務查詢操作影響的數據行數</returns> 67 public static int ExecuteNonQuery(OracleTransaction trans, CommandType cmdType, string cmdText, params OracleParameter[] cmdParms) 68 { 69 OracleCommand cmd = new OracleCommand(); 70 PrepareCommand(cmd, trans.Connection, trans, cmdType, cmdText, cmdParms); 71 int val = cmd.ExecuteNonQuery(); 72 cmd.Parameters.Clear(); 73 return val; 74 } 75 76 /// <summary> 77 /// 執行資料庫非查詢操作,返回受影響的行數 78 /// </summary> 79 /// <param name="connection">Oracle資料庫連接對象</param> 80 /// <param name="cmdType">Command類型</param> 81 /// <param name="cmdText">Oracle存儲過程名稱或PL/SQL命令</param> 82 /// <param name="cmdParms">命令參數集合</param> 83 /// <returns>當前查詢操作影響的數據行數</returns> 84 public static int ExecuteNonQuery(OracleConnection connection, CommandType cmdType, string cmdText, params OracleParameter[] cmdParms) 85 { 86 if (connection == null) 87 throw new ArgumentNullException("當前資料庫連接不存在"); 88 OracleCommand cmd = new OracleCommand(); 89 PrepareCommand(cmd, connection, null, cmdType, cmdText, cmdParms); 90 int val = cmd.ExecuteNonQuery(); 91 cmd.Parameters.Clear(); 92 return val; 93 } 94 95 /// <summary> 96 /// 執行資料庫查詢操作,返回OracleDataReader類型的記憶體結果集 97 /// </summary> 98 /// <param name="connectionString">資料庫連接字元串</param> 99 /// <param name="cmdType">命令的類型</param> 100 /// <param name="cmdText">Oracle存儲過程名稱或PL/SQL命令</param> 101 /// <param name="cmdParms">命令參數集合</param> 102 /// <returns>當前查詢操作返回的OracleDataReader類型的記憶體結果集</returns> 103 public static OracleDataReader ExecuteReader(string connectionString, CommandType cmdType, string cmdText, params OracleParameter[] cmdParms) 104 { 105 OracleCommand cmd = new OracleCommand(); 106 OracleConnection conn = new OracleConnection(connectionString); 107 try 108 { 109 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms); 110 OracleDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection); 111 cmd.Parameters.Clear(); 112 return reader; 113 } 114 catch 115 { 116 cmd.Dispose(); 117 conn.Close(); 118 throw; 119 } 120 } 121 122 /// <summary> 123 /// 執行資料庫查詢操作,返回DataSet類型的結果集 124 /// </summary> 125 /// <param name="connectionString">資料庫連接字元串</param> 126 /// <param name="cmdType">命令的類型</param> 127 /// <param name="cmdText">Oracle存儲過程名稱或PL/SQL命令</param> 128 /// <param name="cmdParms">命令參數集合</param> 129 /// <returns>當前查詢操作返回的DataSet類型的結果集</returns> 130 public static DataSet ExecuteDataSet(string connectionString, CommandType cmdType, string cmdText, params OracleParameter[] cmdParms) 131 { 132 OracleCommand cmd = new OracleCommand(); 133 OracleConnection conn = new OracleConnection(connectionString); 134 DataSet ds = null; 135 try 136 { 137 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms); 138 OracleDataAdapter adapter = new OracleDataAdapter(); 139 adapter.SelectCommand = cmd; 140 ds = new DataSet(); 141 adapter.Fill(ds); 142 cmd.Parameters.Clear(); 143 } 144 catch 145 { 146 throw; 147 } 148 finally 149 { 150 cmd.Dispose(); 151 conn.Close(); 152 conn.Dispose(); 153 } 154 155 return ds; 156 } 157 158 /// <summary> 159 /// 執行資料庫查詢操作,返回DataTable類型的結果集 160 /// </summary> 161 /// <param name="connectionString">資料庫連接字元串</param> 162 /// <param name="cmdType">命令的類型</param> 163 /// <param name="cmdText">Oracle存儲過程名稱或PL/SQL命令</param> 164 /// <param name="cmdParms">命令參數集合</param> 165 /// <returns>當前查詢操作返回的DataTable類型的結果集</returns> 166 public static DataTable ExecuteDataTable(string connectionString, CommandType cmdType, string cmdText, params OracleParameter[] cmdParms) 167 { 168 OracleCommand cmd = new OracleCommand(); 169 OracleConnection conn = new OracleConnection(connectionString); 170 DataTable dt = null; 171 172 try 173 { 174 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms); 175 OracleDataAdapter adapter = new OracleDataAdapter(); 176 adapter.SelectCommand = cmd; 177 dt = new DataTable(); 178 adapter.Fill(dt); 179 cmd.Parameters.Clear(); 180 } 181 catch 182 { 183 throw; 184 } 185 finally 186 { 187 cmd.Dispose(); 188 conn.Close(); 189 conn.Dispose(); 190 } 191 192 return dt; 193 } 194 195 /// <summary> 196 /// 執行資料庫查詢操作,返回結果集中位於第一行第一列的Object類型的值 197 /// </summary> 198 /// <param name="connectionString">資料庫連接字元串</param> 199 /// <param name="cmdType">命令的類型</param> 200 /// <param name="cmdText">Oracle存儲過程名稱或PL/SQL命令</param> 201 /// <param name="cmdParms">命令參數集合</param> 202 /// <returns>當前查詢操作返回的結果集中位於第一行第一列的Object類型的值</returns> 203 public static object ExecuteScalar(string connectionString, CommandType cmdType, string cmdText, params OracleParameter[] cmdParms) 204 { 205 OracleCommand cmd = new OracleCommand(); 206 OracleConnection conn = new OracleConnection(connectionString); 207 object result = null; 208 try 209 { 210 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms); 211 result = cmd.ExecuteScalar(); 212 cmd.Parameters.Clear(); 213 } 214 catch 215 { 216 throw; 217 } 218 finally 219 { 220 cmd.Dispose(); 221 conn.Close(); 222 conn.Dispose(); 223 } 224 225 return result; 226 } 227 228 /// <summary> 229 /// 執行資料庫事務查詢操作,返回結果集中位於第一行第一列的Object類型的值 230 /// </summary> 231 /// <param name="trans">一個已存在的資料庫事務對象</param> 232 /// <param name="commandType">命令類型</param> 233 /// <param name="commandText">Oracle存儲過程名稱或PL/SQL命令</param> 234 /// <param name="cmdParms">命令參數集合</param> 235 /// <returns>當前事務查詢操作返回的結果集中位於第一行第一列的Object類型的值</returns> 236 public static object ExecuteScalar(OracleTransaction trans, CommandType cmdType, string cmdText, params OracleParameter[] cmdParms) 237 { 238 if (trans == null) 239 throw new ArgumentNullException("當前資料庫事務不存在"); 240 OracleConnection conn = trans.Connection; 241 if (conn == null) 242 throw new ArgumentException("當前事務所在的資料庫連接不存在"); 243 244 OracleCommand cmd = new OracleCommand(); 245 object result = null; 246 247 try 248 { 249 PrepareCommand(cmd, conn, trans, cmdType, cmdText, cmdParms); 250 result = cmd.ExecuteScalar(); 251 cmd.Parameters.Clear(); 252 } 253 catch 254 { 255 throw; 256 } 257 finally 258 { 259 trans.Dispose(); 260 cmd.Dispose(); 261 conn.Close(); 262 conn.Dispose(); 263 } 264 265 return result; 266 } 267 268 /// <summary> 269 /// 執行資料庫查詢操作,返回結果集中位於第一行第一列的Object類型的值 270 /// </summary> 271 /// <param name="conn">資料庫連接對象</param> 272 /// <param name="cmdType">Command類型</param> 273 /// <param name="cmdText">Oracle存儲過程名稱或PL/SQL命令</param> 274 /// <param name="cmdParms">命令參數集合</param> 275 /// <returns>當前查詢操作返回的結果集中位於第一行第一列的Object類型的值</returns> 276 public static object ExecuteScalar(OracleConnection conn, CommandType cmdType, string cmdText, params OracleParameter[] cmdParms) 277 { 278 if (conn == null) throw new ArgumentException("當前資料庫連接不存在"); 279 OracleCommand cmd = new OracleCommand(); 280 object result = null; 281 282 try 283 { 284 PrepareCommand(cmd, conn, null, cmdType, cmdText, cmdParms); 285 result = cmd.ExecuteScalar(); 286 cmd.Parameters.Clear(); 287 } 288 catch 289 { 290 throw; 291 } 292 finally 293 { 294 cmd.Dispose(); 295 conn.Close(); 296 conn.Dispose(); 297 } 298 299 return result; 300 } 301 302 /// <summary> 303 /// 執行資料庫命令前的準備工作 304 /// </summary> 305 /// <param name="cmd">Command對象</param> 306 /// <param name="conn">資料庫連接對象</param> 307 /// <param name="trans">事務對象</param> 308 /// <param name="cmdType">Command類型</param> 309 /// <param name="cmdText">Oracle存儲過程名稱或PL/SQL命令</param> 310 /// <param name="cmdParms">命令參數集合</param> 311 private static void PrepareCommand(OracleCommand cmd, OracleConnection conn, OracleTransaction trans, CommandType cmdType, string cmdText, OracleParameter[] cmdParms) 312 { 313 if (conn.State != ConnectionState.Open) 314 conn.Open(); 315 316 cmd.Connection = conn; 317 cmd.CommandText = cmdText; 318 319 if (trans != null) 320 cmd.Transaction = trans; 321 322 cmd.CommandType = cmdType; 323 324 if (cmdParms != null) 325 { 326 foreach (OracleParameter parm in cmdParms) 327 cmd.Parameters.Add(parm); 328 } 329 } 330 331 /// <summary> 332 /// 將.NET日期時間類型轉化為Oracle相容的日期時間格式字元串 333 /// </summary> 334 /// <param name="date">.NET日期時間類型對象</param> 335 /// <returns>Oracle相容的日期時間格式字元串(如該字元串:TO_DATE('2007-12-1','YYYY-MM-DD'))</returns> 336 public static string GetOracleDateFormat(DateTime date) 337 { 338 return "TO_DATE('" + date.ToString("yyyy-M-dd") + "','YYYY-MM-DD')"; 339 } 340 341 /// <summary> 342 /// 將.NET日期時間類型轉化為Oracle相容的日期格式字元串 343 /// </summary> 344 /// <param name="date">.NET日期時間類型對象</param> 345 /// <param name="format">Oracle日期時間類型格式化限定符</param> 346 /// <returns>Oracle相容的日期時間格式字元串(如該字元串:TO_DATE('2007-12-1','YYYY-MM-DD'))</returns> 347 public static string GetOracleDateFormat(DateTime date, string format) 348 { 349 if (format == null || format.Trim() == "") format = "YYYY-MM-DD"; 350 return "TO_DATE('" + date.ToString("yyyy-M-dd") + "','" + format + "')"; 351 } 352 353 /// <summary> 354 /// 將指定的關鍵字處理為模糊查詢時的合法參數值 355 /// </summary> 356 /// <param name="source">待處理的查詢關鍵字</param> 357 /// <returns>過濾後的查詢關鍵字</returns> 358 public static string HandleLikeKey(string source) 359 { 360 if (source == null || source.Trim() == "") return null; 361 362 source = source.Replace("[", "[]]"); 363 source = source.Replace("_", "[_]"); 364 source = source.Replace("%", "[%]"); 365 366 return ("%" + source + "%"); 367 } 368 #endregion 369 } 370 }View Code
- 寫幾個和Oracle交互的函數;
1 [WebMethod(Description = "測試資料庫連接,無輸入參數,返回bool類型true或者false")] 2 public bool CheckOraConnect() 3 { 4 return OracleHelper.CheckOracleConnect(); 5 } 6 7 [WebMethod(Description = "輸入日期型參數,返回string類型周別")] 8 public string GetWeek(string sDate) 9 { 10 try 11 { 12 // 創建參數對象 13 OracleParameter[] param = new OracleParameter[] { new OracleParameter(