执行异步操作

SQL Server 允许应用程序执行异步数据库作。 异步处理使方法能够立即返回，而不会阻止调用线程。 这允许多线程处理的大部分功能和灵活性，而无需开发人员显式创建线程或处理同步。 应用程序在初始化数据库连接时或从执行命令初始化结果时请求异步处理。

打开和关闭数据库连接

使用 SQL Server Native Client OLE DB 访问接口时，旨在异步初始化数据源对象的应用程序可以在调用 IDBInitialize：：Initialize 之前在DBPROP_INIT_ASYNCH属性中设置DBPROPVAL_ASYNCH_INITIALIZE位。 设置此属性后，如果作已立即完成，则提供程序会立即从调用 初始化 返回 S_OK，如果作已立即完成，或者如果初始化是异步的，则DB_S_ASYNCHRONOUS。 应用程序可以在数据源对象上查询 IDBAsynchStatus 或 ISSAsynchStatus接口，然后调用 IDBAsynchStatus：：GetStatus 或ISSAsynchStatus：：WaitForAsynchCompletion 以获取初始化的状态。

此外，SSPROP_ISSAsynchStatus属性已添加到DBPROPSET_SQLSERVERROWSET属性集。 支持 ISSAsynchStatus 接口的提供程序必须使用值为 VARIANT_TRUE 实现此属性。

可以调用 IDBAsynchStatus：：Abort 或 ISSAsynchStatus：：Abort 来取消异步初始化调用。 使用者必须显式请求异步数据源初始化。 否则，在完全初始化数据源对象之前， IDBInitialize：：Initialize 不会返回。

执行和行集初始化

旨在异步打开命令执行结果的应用程序可以在 DBPROP_ROWSET_ASYNCH 属性中设置DBPROPVAL_ASYNCH_INITIALIZE位。 在调用 IDBInitialize：：Initialize、 ICommand：：Execute、 IOpenRowset：：OpenRowset 或 IMultipleResults：：GetResult 之前设置此位时， riid 参数必须设置为IID_IDBAsynchStatus、IID_ISSAsynchStatus或IID_IUnknown。

如果行集初始化立即完成，或者行集继续异步初始化， 将 ppRowset 设置为行集上请求的接口，则该方法将立即返回S_OK;如果行集继续异步初始化，则返回 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）