天天看點

OLEDB不使用SQL語句直接打開資料表

一般來說擷取資料庫表的方法是采用類似

select * from table_name      

這樣的sql語句。SQL語句必然伴随着資料庫的解釋執行,一般來說效率比較低下,而且使用SQL語句時需要資料庫支援ICommandText對象,但是在OLEDB中它是一個可選接口,也就是有的資料庫可能不支援,這個時候OLEDB給我們提供了一種方法讓我們能夠在不使用SQL的情況下操作資料庫表對象。

直接打開表對象需要使用IOpenRowset接口。該接口屬于Session對象。

打開資料庫表的一般步驟

  1. 聲明一個DBID結構對象
  2. 為結構對象的ekind(對象種類)字段指派DBKIND_NAME值
  3. 為結構對象的uName.pwszName字段指派為表名
  4. 調用IOpenRowset接口的OpenRowset方法,将DBID結構的指針傳入,并讓函數傳回結果集對象

IOpenRowset接口屬于Session,可以在使用CreateSession時讓其直接打開這個接口,而且該接口是必須實作的接口,是以不用擔心擷取不到的情況,得到這個接口後就可以直接使用接口的OpenRowset方法。

OpenRowset函數原型如下:

HRESULT OpenRowset(
   IUnknown    *pUnkOuter,
   DBID        *pTableID, //打開表時使用該結構
   DBID        *pIndexID, //打開索引時使用這個參數
   REFIID       riid, //傳回對象的GUID
   ULONG        cPropertySets, //給對應傳回對象設定的屬性集的個數
   DBPROPSET    rgPropertySets[], //給對應對象設定的屬性集
   IUnknown   **ppRowset); // 傳回的接口      

使用執行個體

BOOL OpenTable(IOpenRowset *pIOpenRowset, IRowset* &pIRowset)
{
  DBID dbId = {0};
  dbId.eKind = DBKIND_NAME;
  dbId.uName.pwszName = OLESTR("aa26");

  DBPROP dbRowsetProp[4] = {0};
  DBPROPSET dbRowsetPropset[1] = {0};

  //運作直接使用對應接口函數對資料庫進行增删改操作
  dbRowsetProp[0].colid = DB_NULLID;
  dbRowsetProp[0].dwOptions = DBPROPOPTIONS_REQUIRED;
  dbRowsetProp[0].dwPropertyID = DBPROP_UPDATABILITY;
  dbRowsetProp[0].vValue.vt = VT_I4;
  dbRowsetProp[0].vValue.intVal = DBPROPVAL_UP_CHANGE | DBPROPVAL_UP_DELETE | DBPROPVAL_UP_DELETE;
  //運作在删改的同時插入資料
  dbRowsetProp[1].colid = DB_NULLID;
  dbRowsetProp[1].dwOptions = DBPROPOPTIONS_REQUIRED;
  dbRowsetProp[1].dwPropertyID = DBPROP_CANHOLDROWS;
  dbRowsetProp[1].vValue.vt = VT_BOOL;
  dbRowsetProp[1].vValue.boolVal = VARIANT_TRUE;
  //打開IRowsetUpdate接口,實作延遲更新
  dbRowsetProp[2].colid = DB_NULLID;
  dbRowsetProp[2].dwOptions = DBPROPOPTIONS_REQUIRED;
  dbRowsetProp[2].dwPropertyID = DBPROP_IRowsetUpdate;
  dbRowsetProp[2].vValue.vt = VT_BOOL;
  dbRowsetProp[2].vValue.boolVal = VARIANT_TRUE;

  dbRowsetPropset[0].cProperties = 3;
  dbRowsetPropset[0].guidPropertySet = DBPROPSET_ROWSET;
  dbRowsetPropset[0].rgProperties = dbRowsetProp;

  HRESULT hRes = pIOpenRowset->OpenRowset(NULL, &dbId, NULL, IID_IRowset, 1, dbRowsetPropset, (IUnknown**)&pIRowset);
  return SUCCEEDED(hRes);
}