OLEDB不使用SQL语句直接打开数据表

一般来说获取数据库表的方法是采用类似

1
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函数原型如下:

1
2
3
4
5
6
7
8
HRESULT OpenRowset(
IUnknown *pUnkOuter,
DBID *pTableID, //打开表时使用该结构
DBID *pIndexID, //打开索引时使用这个参数
REFIID riid, //返回对象的GUID
ULONG cPropertySets, //给对应返回对象设置的属性集的个数
DBPROPSET rgPropertySets[], //给对应对象设置的属性集
IUnknown **ppRowset); // 返回的接口

从函数定义上来,这种方式还可以用来打开索引

使用实例

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
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);
}

详细的代码请参考: 完整代码