異步的SQL數(shù)據(jù)庫的封裝過程

本篇內(nèi)容主要講解“異步的SQL數(shù)據(jù)庫的封裝過程”，感興趣的朋友不妨來看看。本文介紹的方法操作簡單快捷，實用性強。下面就讓小編來帶大家學(xué)習(xí)“異步的SQL數(shù)據(jù)庫的封裝過程”吧!

引言

我一直在尋找一種簡單有效的庫，它能在簡化數(shù)據(jù)庫相關(guān)的編程的同時提供一種異步的方法來預(yù)防死鎖。

我找到的大部分庫要么太繁瑣，要么靈活性不足，所以我決定自己寫個。

使用這個庫，你可以輕松地連接到任何 SQL-Server 數(shù)據(jù)庫，執(zhí)行任何存儲過程或 T-SQL 查詢，并異步地接收查詢結(jié)果。這個庫采用 C# 開發(fā)，沒有其他外部依賴。

背景

你可能需要一些事件驅(qū)動編程的背景知識，但這不是必需的。

使用

這個庫由兩個類組成：

1、BLL (Business Logic Layer) 提供訪問MS-SQL數(shù)據(jù)庫、執(zhí)行命令和查詢并將結(jié)果返回給調(diào)用者的方法和屬性。你不能直接調(diào)用這個類的對象，它只供其他類繼承.2、DAL (Data Access Layer) 你需要自己編寫執(zhí)行SQL存儲過程和查詢的函數(shù)，并且對于不同的表你可能需要不同的DAL類。首先，你需要像這樣創(chuàng)建 DAL 類：

namespace SQLWrapper {  public class DAL : BLL  {   public DAL(string server, string db, string user, string pass)   {    base.Start(server, db, user, pass);   }    ~DAL()   {    base.Stop(eStopType.ForceStopAll);   }    ///////////////////////////////////////////////////////////   // TODO: Here you can add your code here...  } }

由于BLL類維護著處理異步查詢的線程，你需要提供必要的數(shù)據(jù)來拼接連接字符串。千萬別忘了調(diào)用`Stop`函數(shù)，否則析構(gòu)函數(shù)會強制調(diào)用它。

NOTE：如果需要連接其他非MS-SQL數(shù)據(jù)庫，你可以通過修改BLL類中的`CreateConnectionString`函數(shù)來生成合適的連接字符串。

為了調(diào)用存儲過程，你應(yīng)該在DAL中編寫這種函數(shù):

public int MyStoreProcedure(int param1, string param2) {   // 根據(jù)存儲過程的返回類型創(chuàng)建用戶數(shù)據(jù)   StoredProcedureCallbackResult userData = new StoredProcedureCallbackResult(eRequestType.Scalar);      // 在此定義傳入存儲過程的參數(shù)，如果沒有參數(shù)可以省略 <span >userData.Parameters = new System.Data.SqlClient.SqlParameter[] { </span>      new System.Data.SqlClient.SqlParameter("@param1", param1),     new System.Data.SqlClient.SqlParameter("@param2", param2),   };      // Execute procedure...   if (!ExecuteStoredProcedure("usp_MyStoreProcedure", userData))     throw new Exception("Execution failed");        // 等待執(zhí)行完成...   // 等待時長為 <userdata.tswaitforresult>   // 執(zhí)行未完成返回 <timeout>   if (WaitSqlCompletes(userData) != eWaitForSQLResult.Success)     throw new Exception("Execution failed");        // Get the result...   return userData.ScalarValue; }

正如你所看到的，存儲過程的返回值類型可以是`Scalar`,`Reader`和`NonQuery`。對于 `Scalar`，`userData`的`ScalarValue`參數(shù)有意義(即返回結(jié)果)；對于`NonQuery`，`userData`的 `AffectedRows`參數(shù)就是受影響的行數(shù)；對于`Reader`類型，`ReturnValue`就是函數(shù)的返回值，另外你可以通過 `userData`的`resultDataReader`參數(shù)訪問recordset。

再看看這個示例:

public bool MySQLQuery(int param1, string param2) {   // Create user data according to return type of store procedure in SQL(這個注釋沒有更新,說明《注釋是魔鬼》有點道理)   ReaderQueryCallbackResult userData = new ReaderQueryCallbackResult();      string sqlCommand = string.Format("SELECT TOP(1) * FROM tbl1    WHERE code = {0} AND name LIKE &apos;%{1}%&apos;", param1, param2);      // Execute procedure...   if (!ExecuteSQLStatement(sqlCommand, userData))     return false;        // Wait until it finishes...   // Note, it will wait (userData.tsWaitForResult)   // for the command to be completed otherwise returns <timeout>   if (WaitSqlCompletes(userData) != eWaitForSQLResult.Success)     return false;        // Get the result...   if(userData.resultDataReader.HasRows && userData.resultDataReader.Read())   {     // Do whatever you want....     int field1 = GetIntValueOfDBField(userData.resultDataReader["Field1"], -1);     string field2 = GetStringValueOfDBField(userData.resultDataReader["Field2"], null);     Nullable<datetime> field3 = GetDateValueOfDBField(userData.resultDataReader["Field3"], null);     float field4 = GetFloatValueOfDBField(userData.resultDataReader["Field4"], 0);     long field5 = GetLongValueOfDBField(userData.resultDataReader["Field5"], -1);   }   userData.resultDataReader.Dispose();      return true; }

在這個例子中，我們調(diào)用 `ExecuteSQLStatement` 直接執(zhí)行了一個SQL查詢，但思想跟 `ExecuteStoredProcedure` 是一樣的。

我們使用 `resultDataReader` 的 `.Read()` 方法來迭代處理返回的結(jié)果集。另外提供了一些helper方法來避免疊代中由于NULL字段、GetIntValueOfDBField 等引起的異常。

如果你要執(zhí)行 SQL 命令而不是存儲過程，需要傳入 ExecuteSQLStatement 的 userData 有三類：

1、ReaderQueryCallbackResult userData：適用于有返回recordset的語句，可以通過userData.resultDataReader獲得對返回的recordset的訪問。2、NonQueryCallbackResult userData：適用于像UPDATE這種沒有返回內(nèi)容的語句，可以使用userData.AffectedRows檢查執(zhí)行的結(jié)果。3、ScalarQueryCallbackResult userData：用于查詢語句只返回一個標量值的情況，例如`SELECT code FROM tbl WHEN ID=10`，通過userData.ScalarValue 取得返回的結(jié)果。對于存儲過程，只有一種需要傳入 ExecuteStoredProcedure 的數(shù)據(jù)類型。但在聲明變量時你需要指明存儲過程的返回值類型：

StoredProcedureCallbackResult userData(eRequestType)：除了聲明不同外，其他操作與上面相同。異步地使用代碼

假使你不希望調(diào)用線程被查詢阻塞，你需要周期性地調(diào)用 `WaitSqlCompletes` 來檢查查詢是否完成，執(zhí)行是否失敗。

/// <summary> /// 你需要周期性地調(diào)用WaitSqlCompletes(userData, 10) /// 來查看結(jié)果是否可用! /// </summary> public StoredProcedureCallbackResult MyStoreProcedureASYNC(int param1, string param2) {   // Create user data according to return type of store procedure in SQL   StoredProcedureCallbackResult userData = new StoredProcedureCallbackResult(eRequestType.Reader);      // If your store procedure accepts some parameters, define them here,   // or you can omit it incase there is no parameter definition   userData.Parameters = new System.Data.SqlClient.SqlParameter[] {     new System.Data.SqlClient.SqlParameter("@param1", param1),     new System.Data.SqlClient.SqlParameter("@param2", param2),   };      // Execute procedure...   if (!ExecuteStoredProcedure("usp_MyStoreProcedure", userData))     throw new Exception("Execution failed");        return userData; }

在調(diào)用線程中你需要這樣做:

... DAL.StoredProcedureCallbackResult userData = myDal.MyStoreProcedureASYNC(10,"hello"); ... // each time we wait 10 milliseconds to see the result... switch(myDal.WaitSqlCompletes(userData, 10)) { case eWaitForSQLResult.Waiting:  goto WAIT_MORE; case eWaitForSQLResult.Success:  goto GET_THE_RESULT; default:  goto EXECUTION_FAILED; } ...

數(shù)據(jù)庫狀態(tài)

在 BLL 中只有一個異步地提供數(shù)據(jù)庫狀態(tài)的事件。如果數(shù)據(jù)庫連接被斷開了(通常是由于網(wǎng)絡(luò)問題)，OnDatabaseStatusChanged 事件就會被掛起。

另外，如果連接恢復(fù)了，這個事件會被再次掛起來通知你新的數(shù)據(jù)庫狀態(tài)。

有趣的地方

在我開發(fā)代碼的時候，我明白了連接字符串中的連接時限（connection timeout）和SQL命令對象的執(zhí)行時限（execution timeout）同樣重要。

首先，你必須意識到最大容許時限是在連接字符串中定義的，并可以給出一些執(zhí)行指令比連接字符串中的超時時間更長的時間。

其次，每一個命令都有著它們自己的執(zhí)行時限，在這里的代碼中默認為30秒。你可以很容易地修改它，使它適用于所有類型的命令，就像這樣：

userData.tsWaitForResult = TimeSpan.FromSeconds(15);

到此，相信大家對“異步的SQL數(shù)據(jù)庫的封裝過程”有了更深的了解，不妨來實際操作一番吧！這里是億速云網(wǎng)站，更多相關(guān)內(nèi)容可以進入相關(guān)頻道進行查詢，關(guān)注我們，繼續(xù)學(xué)習(xí)！