ADO 是目前在Windows环境中比较流行的客户端数据库编程技术,是建立在OLE DB底层技术之上的高级编程接口,因而它兼具有强大的数据处理功能(处理各种不同类型的数据源、分布式的数据处理等等)和极其简单、易用的编程接口,因而得到了广泛的应用。而且按微软公司的意图,OLE DB和ADO将逐步取代 ODBC和DAO。 ADO编程的关键,就是熟练地运用ADO提供的各种对象(object)、方法(method)、属性(property)和容器(collection)。另外,如果是在MS SQL或Oracle等大型数据库上编程,还要能熟练使用SQL语言。ADO中最重要的对象有三个:Connection、Recordset和Command,它们分别表示连接对象、记录集对象和命令对象。使用方法如下: 1、在StdAfx.h中使用预处理指令#import引入ADO类库 #i nclude <icrsint.h> #import "c:\\program files\\common files\\system\\ado\\msado15.dll" #import "c:\\program files\\common files\\system\\ado\\msadox.dll" \ no_namespace \ rename("EOF", "adoEOF") 2、在MyApp的初始化函数BOOL CMyApp::InitInstance()中,进行环境初始化 if(!AfxOleInit()) { AfxMessageBox("初始化OLE/COM库环境失败!"); return FALSE; } 经过以上两步后,便可以使用ADO的三个智能指针:_ConnectionPtr、_RecordsetPtr、_CommandPtr。 其中icrsint.h文件包含了VC++扩展的一些预处理指令、宏等的定义,用于COM编程时使用。 在编译的时候会出现如下的警告信息:msado15.tlh(405) : warning C4146: unary minus operator applied to unsigned type, result still unsigned。MSDN建议我们不要理会。如果你实在不想看到的话可以在stdafx.h中加入一行下面的代码:#pragma warning(disable:4146),这样这个警告信息就不会再出现了。 还要注意#import预处理指令不能放在stdAfx.h文件的开头,而应该放在所有include指令的后面。否则在编译时会出错。程序在编译过程中,VC++会读出msado15.dll中的类型库信息,自动产生两个该类型库的头文件和实现文件msado15.tlh和msado15.tli(在您的Debug或Release目录下)。在这两个文件里定义了ADO的所有对象和方法,以及一些枚举型的常量等。我们的程序只要直接调用这些方法就行了,与使用MFC中的COleDispatchDriver类调用Automation对象十分类似。 Recordset对象的Open方法非常重要,它的第一个参数可以是一个SQL语句、一个表的名字或一个命令对象等等;第二个参数就是前面建立的连接对象的指针。此外,用Connection和Command对象的Execute方法也能得到记录集,但是只读的。 Fields是Recordset对象的容器,GetItem方法返回的是Field对象,而Value则是Field对象的一个属性(即该字段的值)。判断是否到达记录集的末尾,使用记录集的adoEOF属性,其值若为真即到了结尾,反之则未到。判断是否到达记录集开头,则可用BOF属性。
创建对象实例时,最好用HRESULT跟踪结果,并用try...catch...捕捉异常: _ConnectionPtr pMyConnect=NULL; HRESULT hr=pMyConnect.CreateInstance(__uuidof(Connection))); if(FAILED(hr))return;
try { } catch(_com_error e)//捕捉异常 { e.Description(); e.ErrorMessage(); e.Source(); }
判断一个记录集是否可以增加新记录的方法 if(!m_pRecordset->Supports(adAddNew)) return;
打开数据库: _ConnectionPtr m_pConnection = NULL; m_pConnection.CreateInstance(__uuidof(Connection)); CString strConn; strConn.Format("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=%s", strPathName); try { m_pConnection->Open(_bstr_t(strConn),"","", adModeUnknown); } catch(_com_error e)///捕捉异常 { CString errormessage; errormessage.Format("打开数据库失败!\r\n错误信息:%s", e.ErrorMessage()); AfxMessageBox(errormessage);///显示错误信息 return FALSE; }
遍历数据库中的所有表 HRESULT hr; _RecordsetPtr pSet; hr = pSet = pConnection->OpenSchema(adSchemaTables); if(FAILED(hr)) { AfxMessageBox("获得表集合失败!"); return NULL; }
int iMark = 0; while(!(pSet->adoEOF)) { //获取表格名称 CString strTableName; _bstr_t table_name = pSet->Fields->GetItem("TABLE_NAME")->Value;
//判断数据库中是否有名称为pipeline的表 strTableName = (LPCSTR)_bstr_t(table_name); if(strcmp(strTableName, "pipeline") == 0) { iMark = 1; break; } pSet->MoveNext(); } pSet->Close();
打开数据库中的一个表 _RecordsetPtr pRecordset = NULL; pRecordset.CreateInstance(__uuidof(Recordset)); try //打开名称为link的表 { pRecordset->Open("SELECT * FROM link",_variant_t((IDispatch *) m_pConnection,true),adOpenDynamic,adLockOptimistic,adCmdText); } catch(_com_error e) { CString errormessage; errormessage.Format("打开表失败!\r\n错误信息:%s",e.ErrorMessage()); AfxMessageBox(errormessage);///显示错误信息
return; }
遍历表中所有的记录,得到指定字段的值 _variant_t var; CString strPathName; while(VARIANT_FALSE == pRecordset->adoEOF) { var = pRecordset->GetFields()->GetItem("FilePath")->GetValue(); strPathName = (LPCSTR)_bstr_t(var); …… …… pRecordset->MoveNext(); }
遍历表中所有的字段 HRESULT hr; FieldsPtr fields = NULL; long ColCount; BSTR bstrColName; CString strColName; hr = pRecordset ->get_Fields(&fields); //得到记录集的字段集 if(SUCCEEDED(hr)) fields->get_Count(&ColCount);
//得到记录集的字段集合中的字段的总个数 for(long i=0; i<ColCount; i++) { fields->Item[i]->get_Name(&bstrColName); //得到记录集中的字段名 strColName = bstrColName; }
fields->Release();
附1:用SQL语句来创建表格时,字段类型与关键字的对照表:
文本型 TEXT 备注型 MEMO 数字型(整型、长整型、浮点型、双精度型) INTEGER、LONG、FLOAT、DOUBLE 日期/时间型 DATETIME 自动编号型 AUTOINCREMENT OLE对象型(二进制型、长二进制型) BINARY、LONGBINARY |