通过OLEDB读取SQLSERVER数据库的使用经验

通过OLEDB读取SQLSERVER数据库的使用经验

最近在写一个用OLEDB从SQLSERVER数据库读取数据的VC程序
特将使用的经验总结一下方便未知使用之者

1、首先建立数据库连接问题：
你可以使用以前的CoCreateInstance 建立数据库初始化对象，如下：
CoCreateInstance(_clsid, NULL, CLSCTX_INPROC_SERVER,
IID_IDBInitialize, (void**)&_pDBInit);
但这是一种过时的打开方法，在此基础上建立的数据库连接对象会有很多数据库属性都不会被支持的
微软建议的做法是应该使用IDataInitialize 或者 IDBPromptInitialize 打开 ,如下
hr = CoCreateInstance(CLSID_MSDAINITIALIZE, NULL, CLSCTX_INPROC_SERVER, IID_IDataInitialize, (void**)&_pIDataInitialize);
hr = _pIDataInitialize->CreateDBInstance(_clsid, NULL, CLSCTX_INPROC_SERVER, NULL, IID_IDBInitialize, (IUnknown**)&_pDBInit);
这样的方法建立的数据实例不仅可以利用一些比较新的属性，并且还支持数据连接池

2、数据连接池的问题：
如果你用以前的那种方法打开的数据库连接是需要自己实现连接池的，而后者是自动支持数据连接池，但主要如下事项：
1、要释放所有的接口指针，要记得随时随地release,不然它会认为你还存在引用，就不会自动服用连接了，如下：
_pICT ->SetCommandText(DBGUID_DBSQL, t);
。。。。
if(_pICT) _pICT->Release();
2、在释放数据库连接对象时不要调用 Uninitialize 方法，如果调用该方法，数据库连接池会物理上把连接释放，这样造成连接不能复用，如下
int C_DB::CloseDB(){
if( _pDBInit ){
/*
为了连接池复用，不要调用Uninitialize()方法
*/
//_pDBInit->Uninitialize()
_pDBInit->Release();
}
return 0;
}

3、连接复用问题：
要想知道连接是否被复用，可以通过SQLSERVER后台启用SQL监视器，查看日志信息，如果出现reset conection, 则表示复用连接成功了

4、数据快速读取问题：
由于程序是实现一次性把所有数据读取到本地，故在打开记录集时，要设置从客户端游标，如果时非客户端游标，读取速度会受到限制
通过SQLSERVER后台的监视器就可以看到，如果时服务器游标，每次通过API读取数据时都会和服务器通讯，产生不必要的开销
想知道是否已经设置从客户端游标，只要从监视器没有看到FETCH语句存在就表示OK了
可以通过设置记录集 DBPROP_CLIENTCURSOR 属性实现以客户端游标方式打开记录集，如下
_p[1].dwPropertyID = DBPROP_CLIENTCURSOR;
_p[1].dwOptions = DBPROPOPTIONS_REQUIRED;
_p[1].dwStatus = 0;
VariantInit (&_p[1].vValue);
_p[1].vValue.vt = VT_BOOL;
_p[1].vValue.boolVal = VARIANT_TRUE;

5、一次性获得N条记录问题：
默认情况下，打开记录集时只允许一条一条记录的获取，如果想一次获得N条记录，需要在打开记录集时设置DBPROP_MAXOPENROWS属性：
_p[0].dwPropertyID = DBPROP_MAXOPENROWS;
_p[0].dwOptions = DBPROPOPTIONS_REQUIRED;
_p[0].dwStatus = 0;
VariantInit (&_p[0].vValue);
_p[0].vValue.vt = VT_I4;
_p[0].vValue.intVal=0;
上面代码设置DBPROP_MAXOPENROWS属性为0，表示没有限制，当前并不代码实际应用上你使用上没有限制，比如你一下子获取几十万条记录，这样资源本身就会限制你，所以在调用API获得记录时要记得检查结果

6、数据连续获取问题：
在通过API获得记录时，如果没有释放记录集，再次获取记录的时候会报错，如下代码
hr=pIRS->GetNextRows( NULL, 0, PER_RECORD_NUM, & tmpRows, &parrRows );
....
hr=pIRS->GetNextRows( NULL, 0, PER_RECORD_NUM, & tmpRows, &parrRows );
这样会报错，所以需要在打开记录集时设置DBPROP_CANHOLDROWS,如下
_p[1].dwPropertyID = DBPROP_CANHOLDROWS;
_p[1].dwOptions = DBPROPOPTIONS_REQUIRED;
_p[1].dwStatus = 0;
VariantInit (&_p[1].vValue);
_p[1].vValue.vt = VT_BOOL;
_p[1].vValue.boolVal = VARIANT_TRUE;

不然你只能实在的获得记录，然后在释放记录了，如下
hr=pIRS->GetNextRows( NULL, 0, PER_RECORD_NUM, & tmpRows, &parrRows );
....
pIRS -> ReleaseRows(tmpRows, arrRows, NULL, NULL, NULL);
...
hr=pIRS->GetNextRows( NULL, 0, PER_RECORD_NUM, & tmpRows, &parrRows );

7、再随便写上第7条把
在CoCreateInstance(_clsid...）语句中需要提供clsid,下面我举2个例子来说明获得SQLSERVER和ACCESS的CLSID
CLSIDFromProgID(L"SQLOLEDB", &_clsid);
CLSIDFromProgID(L"Microsoft.Jet.OLEDB.4.0", &_clsid);

好了，写完了，希望能对你有所帮助