中文字幕免费精品_亚洲视频自拍_亚洲综合国产激情另类一区_色综合咪咪久久

引言

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

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

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

背景

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

使用

這個庫由兩個類組成：

BLL (Business Logic Layer) 提供訪問MS-SQL數據庫、執行命令和查詢并將結果返回給調用者的方法和屬性。你不能直接調用這個類的對象，它只供其他類繼承.

DAL (Data Access Layer) 你需要自己編寫執行SQL存儲過程和查詢的函數，并且對于不同的表你可能需要不同的DAL類。

首先，你需要像這樣創建 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類維護著處理異步查詢的線程，你需要提供必要的數據來拼接連接字符串。千萬別忘了調用`Stop`函數，否則析構函數會強制調用它。

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

為了調用存儲過程，你應該在DAL中編寫這種函數:

public int MyStoreProcedure(int param1, string param2)

{

// 根據存儲過程的返回類型創建用戶數據

StoredProcedureCallbackResult userData = new StoredProcedureCallbackResult(eRequestType.Scalar);

// 在此定義傳入存儲過程的參數，如果沒有參數可以省略 <span style="line-height:1.5;font-size:9pt;">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");

// 等待執行完成...

// 等待時長為 <userdata.tswaitforresult>

// 執行未完成返回 <timeout>

if (WaitSqlCompletes(userData) != eWaitForSQLResult.Success)

throw new Exception("Execution failed");

// Get the result...

return userData.ScalarValue;

}

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

}

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

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