CREATE TABLE LockTable(ResourceId CHAR(10));
INSERT INTO LockTable VALUES('INDEX 1');
INSERT INTO LockTable VALUES('INDEX 2');
上面的示例演示如何在鎖表中填充兩個全文索引資源。每個索引不能由一個以上的應用程序使用。這意味著,應用程序 1 可能使用索引 1,同時應用程序 2 使用索引 2,但是不答應兩個應用程序中同時使用索引 1 。 使用鎖定/解鎖協議訪問資源 引入一個由兩個函數 lock(ResourceId) 和 unlock() 組成的協議,所有應用程序都需要遵守這個協議。具體的接口依靠于實現語言,在這里無關緊要。要害的一點是,所有應用程序在訪問會話鎖控制的資源 之前,必須調用 lock(resourceId)。當不再需要這個資源時,它們應該調用 unlock()?! 崿F lock() 函數 lock() 函數的實現必須確保調用者能夠立即得到請求的結果(授予鎖還是不授予鎖)。另外,授予的鎖必須不受應用程序中 DB2 事務的影響。因此,lock() 的實現必須在一個單獨的線程中打開額外的 DB2 連接。所以,lock() 函數的實現由以下步驟組成: 上一頁123下一頁 啟動一個對鎖請求進行處理的子線程。 等待子線程發出表示鎖請求處理完成的信號,這時結果已經可用了。 在子線程中,打開新的 DB2 連接,在鎖表中獲取具有所請求的資源 ID 的一行。在這里,使用 SKIP LOCKED DATA 特性只獲得未被 DB2 鎖定的行(例如,假如另一個應用程序持有這個資源上的會話鎖,就不能獲得這一行)。DB2 并不在獲取操作中等待。見 清單 2 中的示例代碼?,F在,請求的結果必須在主線程中可用。子線程等待主線程的終止信號。假如授予了會話鎖,它就持有鎖表中一行上的 DB2 更新鎖,直到發生以下情況為止: 調用 unlock() 或者 應用程序終止?! ock() 函數主線程從子線程獲得結果。假如授予了鎖,那么 lock() 函數返回調用者。否則子線程被終止?! ∏鍐?2. 在子線程中實現 lock() 的 SQL 代碼
DECLARE C1 CURSOR FOR
SELECT ResourceId FROM LockTable WHERE ResourceId=:resourceId
FOR UPDATE WITH CS SKIP LOCKED DATA;
OPEN C1;
FETCH C1;
if (sqlca.sqlcode==NO_DATA_FOUND) {
result=indexAlreadyLocked;
} else {
result=lockGranted;
}
實現 unlock() 函數 提供一個 unlock() 函數,它將終止仍然持有鎖表中某一行的 DB2 更新鎖的子線程。子線程中的終止代碼關閉 SQL 游標,并使事務回滾,見 清單 3。因此,會釋放這一行的 DB2 更新鎖,清單 2 中的下一個 SQL select 語句會看到這一行?! ∏鍐?3. 在子線程中實現 unlock() 的 SQL 代碼 CLOSE C1;
ROLLBACK WORK;
控制同時訪問一個資源的應用程序數量 對以上方式做一項簡單的修改,就可以控制同時訪問一個資源集的應用程序數量: 假如鎖表中有重復的行,就可以對資源進行并發使用。鎖表中一個資源的行數決定了可以同時訪問這個資源的最大應用程序數量?! ∏鍐?4. 填充鎖表來控制同時訪問的最大應用程序數量的 SQL 示例 INSERT INTO LockTable VALUES('INDEX 1');
INSERT INTO LockTable VALUES('INDEX 1');
INSERT INTO LockTable VALUES('INDEX 2');
INSERT INTO LockTable VALUES('INDEX 2');
INSERT INTO LockTable VALUES('INDEX 2');
按照這段代碼,最多有兩個應用程序可以同時訪問 ‘INDEX 1’,最多有三個應用程序可以同時訪問 ‘INDEX 2’?! 〗Y束語 有一種簡單可靠的解決方案模式可用于在應用程序級別實現會話鎖。它依靠于 DB2 Version 9.1 for z/OS 中的新特性 SKIP LOCKED DATA,且已成功應用于一個 DB2 開發項目。 上一頁123 新聞熱點
疑難解答