在 SQL Server Native Client 中執行異步操作

文章
07/18/2024

適用於： SQL Server Azure SQL 資料庫 Azure SQL 受控執行個體 Azure Synapse Analytics Analytics Platform System (PDW)

重要

SQL Server 2022 (16.x) 及更新版本
SQL Server Management Studio 19 和更新版本

不建議使用 SQL Server Native Client （SQLNCLI 或 SQLNCLI11）和舊版 Microsoft OLE DB Provider for SQL Server （SQLOLEDB）進行新的應用程式開發。

針對新專案，請使用下列其中一個驅動程式：

針對 SQL Server 資料庫引擎 (2012 到 2019 版) 的隨附元件 SQLNCLI，請參閱支援生命週期例外狀況。

SQL Server 允許應用程式執行非同步資料庫作業。非同步處理可讓方法立即執行，而不會在呼叫的執行緒上封鎖。這樣可允許多執行緒的許多功能與彈性，而不需要開發人員明確建立執行緒或處理同步。當初始化資料庫連接或初始化執行命令的結果時，應用程式會要求非同步處理。

開啟及關閉資料庫連接

使用 SQL Server Native Client OLE DB 提供者時，設計來初始化數據源物件的應用程式可以在呼叫 IDBInitialize：：Initialize 之前，先在 DBPROP_INIT_ASYNCH 屬性中設定DBPROPVAL_ASYNCH_INITIALIZE位。設定此屬性時，如果作業已經立即完成，提供者會使用 S_OK 立即從 Initialize 的呼叫傳回；如果初始化是以非同步方式繼續，則會使用 DB_S_ASYNCHRONOUS 從此呼叫傳回。應用程式可以在數據源對象上查詢 IDBAsynchStatus 或 ISSAsynchStatus 介面，然後呼叫 IDBAsynchStatus：：GetStatus 或ISSAsynchStatus：：WaitForAsynchCompletion 以取得初始化的狀態。

此外，SSPROP_ISSAsynchStatus 屬性已加入到 DBPROPSET_SQLSERVERROWSET 屬性集。支援 ISSAsynchStatus 介面的提供者必須使用 VARIANT_TRUE 的值實作此屬性。

呼叫 IDBAsynchStatus::Abort 或 ISSAsynchStatus::Abort 可以取消非同步的 Initialize 呼叫。取用者必須明確地要求非同步資料來源初始化。否則，要等到資料來源物件完全初始化之後，IDBInitialize::Initialize 才會傳回。

注意

用於連接共享的數據源對象無法呼叫 SQL Server Native Client OLE DB 提供者中的 ISSAsynchStatus 介面。 ISSAsynchStatus 介面不會針對集區資料來源物件公開。

如果應用程式明確地強制使用資料指標引擎，IOpenRowset::OpenRowset 和 IMultipleResults::GetResult 將不支援非同步處理。

此外，遠端 Proxy/存根 dll （在 MDAC 2.8 中）無法呼叫 SQL Server Native Client 中的 ISSAsynchStatus 介面。 ISSAsynchStatus 介面不會透過遠端公開。

服務元件不支援 ISSAsynchStatus。

執行和資料列集初始化

設計為非同步開啟執行命令結果的應用程式可以在 DBPROP_ROWSET_ASYNCH 屬性中設定 DBPROPVAL_ASYNCH_INITIALIZE 位元。呼叫 IDBInitialize::Initialize、ICommand::Execute、IOpenRowset::OpenRowset 或 IMultipleResults::GetResult 之前設定此位元時，必須將 riid 引數設定為 IID_IDBAsynchStatus、IID_ISSAsynchStatus 或 IID_Iunknown。

如果資料列集初始化立即完成，此方法會使用 S_OK 立即傳回；如果資料列集在 ppRowset 設定為資料列集上要求的介面時，繼續以非同步方式初始化，則會使用 DB_S_ASYNCHRONOUS 傳回此方法。針對 SQL Server Native Client OLE DB 提供者，此介面只能是 IDBAsynchStatus 或 ISSAsynchStatus。在資料列集完全初始化之前，此介面的行為如同處於已暫停狀態，而且針對 IID_IDBAsynchStatus 或 IID_ISSAsynchStatus 之外的介面呼叫 QueryInterface 可能會傳回 E_NOINTERFACE。除非取用者明確地要求非同步處理，否則資料列集會以同步的方式進行初始化。如果 IDBAsynchStaus::GetStatus 或 ISSAsynchStatus::WaitForAsynchCompletion 傳回時，指出非同步作業已完成，則可使用所有要求的介面。這不一定表示資料列集已完全擴展，但是該資料列集是完整的，而且完全可以運作。

如果執行的命令並未傳回資料列集，它仍然會使用支援 IDBAsynchStatus 的物件立即傳回。

如果您需要從非同步命令執行取得多個結果，您應該：

在執行命令之前，設定 DBPROP_ROWSET_ASYNCH 屬性的 DBPROPVAL_ASYNCH_INITIALIZE 位元。
呼叫 ICommand::Execute，並要求 IMultipleResults。

接著，使用 QueryInterface 來查詢多個結果介面，藉此取得 IDBAsynchStatus 和 ISSAsynchStatus 介面。

當命令執行完成時，除非同步案例的一個例外，否則可以如常使用 IMultipleResults：可以傳回 DB_S_ASYNCHRONOUS，在此情況下，IDBAsynchStatus 或 ISSAsynchStatus 可用於判斷作業完成的時間。

範例

在下列範例中，應用程式會呼叫非封鎖的方法、進行其他某些處理，然後返回處理結果。 ISSAsynchStatus::WaitForAsynchCompletion 會等候內部事件物件，直到非同步執行作業完成，或是過了 dwMilisecTimeOut 所指定的時間為止。

// Set the DBPROPVAL_ASYNCH_INITIALIZE bit in the   
// DBPROP_ROWSET_ASYNCH property before calling Execute().  
  
DBPROPSET CmdPropset[1];  
DBPROP CmdProperties[1];  
  
CmdPropset[0].rgProperties = CmdProperties;  
CmdPropset[0].cProperties = 1;  
CmdPropset[0].guidPropertySet = DBPROPSET_ROWSET;  
  
// Set asynch mode for command.  
CmdProperties[0].dwPropertyID = DBPROP_ROWSET_ASYNCH;  
CmdProperties[0].vValue.vt = VT_I4;  
CmdProperties[0].vValue.lVal = DBPROPVAL_ASYNCH_INITIALIZE;  
CmdProperties[0].dwOptions = DBPROPOPTIONS_REQUIRED;  
  
hr = pICommandProps->SetProperties(1, CmdPropset);  
  
hr = pICommand->Execute(  
   pUnkOuter,  
   IID_ISSAsynchStatus,  
   pParams,  
   pcRowsAffected,  
   (IUnknown**)&pISSAsynchStatus);  
  
if (hr == DB_S_ASYNCHRONOUS)  
{  
   // Do some work here...  
  
   hr = pISSAsynchStatus->WaitForAsynchCompletion(dwMilisecTimeOut);  
   if ( hr == S_OK)  
   {  
      hr = pISSAsynchStatus->QueryInterface(IID_IRowset, (void**)&pRowset);  
      pISSAsynchStatus->Release();  
   }  
}

ISSAsynchStatus::WaitForAsynchCompletion 會等候內部事件物件，直到非同步執行作業完成，或是過了 dwMilisecTimeOut 值為止。

下列範例會示範利用多個結果集的非同步處理：

DBPROP CmdProperties[1];  
  
// Set asynch mode for command.  
CmdProperties[0].dwPropertyID = DBPROP_ROWSET_ASYNCH;  
CmdProperties[0].vValue.vt = VT_I4;  
CmdProperties[0].vValue.lVal = DBPROPVAL_ASYNCH_INITIALIZE;  
  
hr = pICommand->Execute(  
   pUnkOuter,  
   IID_IMultipleResults,  
   pParams,  
   pcRowsAffected,  
   (IUnknown**)&pIMultipleResults);  
  
// Use GetResults for ISSAsynchStatus.  
hr = pIMultipleResults->GetResult(IID_ISSAsynchStatus, (void **) &pISSAsynchStatus);  
  
if (hr == DB_S_ASYNCHRONOUS)  
{  
   // Do some work here...  
  
   hr = pISSAsynchStatus->WaitForAsynchCompletion(dwMilisecTimeOut);  
   if (hr == S_OK)  
   {  
      hr = pISSAsynchStatus->QueryInterface(IID_IRowset, (void**)&pRowset);  
      pISSAsynchStatus->Release();  
   }  
}

若要防止封鎖，用戶端可以檢查執行中非同步作業的狀態，如下列範例所示：

// Set the DBPROPVAL_ASYNCH_INITIALIZE bit in the   
// DBPROP_ROWSET_ASYNCH property before calling Execute().  
hr = pICommand->Execute(  
   pUnkOuter,  
   IID_ISSAsynchStatus,  
   pParams,  
   pcRowsAffected,  
   (IUnknown**)&pISSAsynchStatus);   
  
if (hr == DB_S_ASYNCHRONOUS)  
{  
   do{  
      // Do some work...  
      hr = pISSAsynchStatus->GetStatus(DB_NULL_HCHAPTER, DBASYNCHOP_OPEN, NULL, NULL, &ulAsynchPhase, NULL);  
   }while (DBASYNCHPHASE_COMPLETE != ulAsynchPhase)  
   if SUCCEEDED(hr)  
   {  
      hr = pISSAsynchStatus->QueryInterface(IID_IRowset, (void**)&pRowset);  
   }  
   pIDBAsynchStatus->Release();  
}

下列範例會示範如何取消目前執行中的非同步作業：

// Set the DBPROPVAL_ASYNCH_INITIALIZE bit in the   
// DBPROP_ROWSET_ASYNCH property before calling Execute().  
hr = pICommand->Execute(  
   pUnkOuter,  
   IID_ISSAsynchStatus,  
   pParams,  
   pcRowsAffected,  
   (IUnknown**)&pISSAsynchStatus);  
  
if (hr == DB_S_ASYNCHRONOUS)  
{  
   // Do some work...  
   hr = pISSAsynchStatus->Abort(DB_NULL_HCHAPTER, DBASYNCHOP_OPEN);  
}

另請參閱

SQL Server Native Client 功能
 資料列集屬性和行為
 ISSAsynchStatus (OLE DB)

分享方式：

在 SQL Server Native Client 中執行異步操作

開啟及關閉資料庫連接

執行和資料列集初始化

範例

另請參閱

意見反映

更多資源