Microsoft Word - ADO技术.doc

Transcription

1 ADO 技术介绍 ADO(ActiveX Data Objects) 是为 Microsoft 最新和最强大的数据访问接口 OLE DB 而设计的, 是一个便于使用的应用程序层 OLE DB 为任何数据源都提供了高性能的访问, 这些数据源包括关系和非关系型数据库 电子邮件 文件系统 文本和图形以及自定义业务对象等 ADO 在关键的 Internet 方案中使用最少的网络流量, 并且在前端和数据源之间使用最少的层数, 所有这些都是为了提供轻量 高性能的接口 1. ADO 的历史回顾 ADO 共发布了 和 2.0 三个版本 第一个版本是 RDO 的一个功能子集, 他的目标是为了帮助开发人员在 IIS (Internet Information Server) 上建立 ASP 应用 第二个版本 1.5 是随 IIS4.0 和 Internet Exploer 4.0 一起发布的 它也被包含在 MDAC(Microsoft Data Access Compemts) 里 从这个版本开始,ADO 开始成为了在功能和运做效率上都高出 RDO 和 DAO 一筹的数据库界面 最新版本 2.0 加入了别的数据库客户技术从来没有过的新技术 ADO2.0 实际上是基于 MSADO15.DLL 这个动态链接库的, 这个库的名字虽然跟 ADO1.5 一样, 但是它实现了更新的接口 ADO 里的新技术有 : 异步操作和事件模型 数据集的持续性 层次化的数据运输 2.ADO 的特点概述 ` 第一, 易于使用, 可以说这是 ADO 的最重要的特点之一 由于 ADO 是高层数据库访问技术, 所以相对于 ODBC 来说, 具有面向对象的特点 同时, 在 ADO 对象结构中, 对象与对象之间的层次结构不是非常明显, 这会给编写数据库程序带来很多的便利, 比如在应用程序中如果要使用记录集对象, 就不一定要先建立连接 会话对象, 如果需要接可以直接构造记录集对象 总之, 已经没有必要去关心对象的构造层次和构造顺序了 第二, 可以访问多种数据源 这一点跟 OLE DB 是一样的, 这样使程序更具灵活性和通用性 第三, 访问数据源效率高 这是由于 ADO 本身就基于 OLE DB 的接口, 自然有 OLE DB 的特点 第四, 方便的 WEB 应用 ADO 可以以 ActiveX 控件的形式出现, 这就大大方便了 WEB 应用程序的编制 第五, 技术编程接口丰富 ADO 支持 Visual C++ Visual Basic Visual J++ 以及

2 VBScript 和 JavaScript 等脚本语言 3.ADO 的对象介绍 ADO 包含 : 连接对象 (Connection) 命令对象(Command) 记录集对象(Recordset) 字段对象 (Filed) 参数对象(Parameter) 错误对象(Error) 属性对象(Property) 和集合与事件等 <1> 连接 (Connection) 用于表示和数据源的连接, 以及处理一些命令和事务 通过它可以从应用程序访问数 据源, 是交换数据所必需的环境 <2> 命令 (Command) 用于执行某些命令来进行诸如查询 修改数据库结构的操作 <3> 记录集 (Recordset) 用于处理数据源的表格集, 它是在表中修改 检索数据的最重要方法 <4> 字段 (Filed) 用于描述数据集中的列信息 <5> 参数 (Parameter) 用于对传递给数据源的命令赋参数值 <6> 错误 (Error) 用于承载所产生错误的详细信息 <7> 属性 (Property) 通过属性, 每个 ADO 对象借此来让用户描述和控制自身的行为 <8> 集合 (Set) 集合是一种可方便包含其他特殊类型对象的对象模型 ADO 提供 4 种类型的集合 : Connection 对象具有 Error 集合 Command 对象具有 Parameter 集合 Recordset 对象具有 Filed 集合 Connection Command Recordset Filed 对象都具有 Properties 集合 <9> 事件 (Event) 事件模型是异步操作的基础 这是 ADO2.0 引进的新特性

3 4. ADO 在 Visual C++ 中的使用 <1> 为在 Visual C++ 中使用 ADO, 需要在头文件中加入下面几行代码 : #improt msado15.dll no_namespace rename ( eof, adoeof ) #include <adoid.h> #include <adoint.h> #include icrsint.h 第一行的 #improt 语句告诉编译器把此指令中的动态链接库文件导入程序中, 并从库中抽取出其中的对象的类的信息, 并产生出 2 个头文件包含在工程中 其中的 no_namespace 用来对动态链接库的名称域进行隔离 最后的 rename, 把 ADO 中的 EOF 重新命名, 避免和其他地方定义的 EOF 产生冲突 第二 第三行引入的头文件定义了 ADO 2.0 的类和接口标志 第四行引入了 ADO2.0 数据绑定扩展 注意 : 在我们的完整应用中的程序 Import 的是一个绝对路径如上图, 尽量避免这种做法 因为当操作系统装在不同的盘的时候, 程序将不能运行 <2> 数据源的连接 Connection 对象用来实现和数据源的连接 创建一个 Connection 对象非常简单, 只需 声明一个 _ConnectionPtr 型的指针, 调用它的 CreateInstance 方法即可 (_Connectionptr 是所 谓的智能指针, 封装了一个 Connection 接口指针, 具体技术细节可以参考有关的 COM 书籍 ) _ConectionPtr pconn = NULL; try // 创建 Connection 对象实例 pconn.createinstance(_uuidof(connection)); _bstr_t conn = DSN = SomeDS; UID = sa ; PWD = 123 ;

4 // 打开连接 pconn->open(conn,,, -1); // 执行一条 SQL 命令 _bstr_t sql = DELETE *FROM some_table WHERE id = 111 ; // 关闭连接 pconn->close(); catch(_com_error& e) AfxMessageBox(e.ErrorMessage()); 程 上边的代码演示了用 Connection 对象建立连接, 执行一条 SQL 语句后关闭连接的全过 Open 函数的原型如下 : HRESULT Open( _bstr_t _bstr_t _bstr_t long ConnectionString, UID, PSWD, option); 各个参数的意义如下 : ConnectionString : 包含连接信息的字符串 UID : 访问数据库的用户名 PSWD: 访问数据库的口令 Option: 可选参数 在用 Open 函数建立连接之前, 还可以先设置一些 Connection 对象的属性 其中经常用到的有 ConnectionTimeout 属性和 Mode 属性 前者用来设置建立连接时的等待时间, 后来用来设置数据库的打开模式 打开模式可以是下列值的组合 : admoderead admodewrite admodereadwrite admodesharedenynone admodesharedenyread admodesharedenywrite admodesharedenyexclusive admodeunknown 读模式写模式读写模式防止用户用任何权限打开防止用户以读权限打开防止用户以写权限打开防止其他用户打开连接未知模式

5 <3> 记录集的使用 记录集是 ADO 中最常用的对象, 所以下面将详细的介绍它的功能 首先是 Recordset 对象的创建函数 Open, 他的原型如下 : HRESULT Open (const _variant_t & source, const _variant_t & connection, enum CursorTypeEnum cursortype, enum LocktypeEnum locktype, long options ); 各个参数意义如下 : source : 是一个变体类型, 它可以是一个 Command 对象 一个 SQL 语句 一个表名或一 个存储过程, 甚至可以是一个 URL 一个文件名 一个流对象等 connection : 也是一个变体类型, 它可以是一个 Connection 对象, 也可以是一个指明连接目标 的字符串 cursortype: 指明了数据集游标的类型 它可以是下列几个值 :adopendynamic, adopenforwardonly, adopenkeyset, adopenstatic, adopenunspecified locktype: 也可以是下列几个值之一 :adlockbatchoptimistic, adlockoptimistic, adlockpessimistic, adlockreadonly, adlockunspecified options : 指明了第一个参数 source 的类型, 其值可以是 adcmdunspecified, adcmdtext, adcmdtable, adcmdstoredproc, adcmdunknown, adcmdfile, adcmdtabledirect Recordset 最常用的 3 个方法涉及到数据库的新增 更改 删除操作 下面的代码 解释了它的用法 (1). 删除函数 Delete: HRESULT hr; _bstr_t bstrquery( SELECT * FROM Products WHERE PartNumber = 8TRACK-003 ); _variant_t vnull;

6 vnull.vt = VT_ERROR; vnull.scode = DISP_E_PARAMNOTFOUND; try hr = precordset.createinstance(_uuidof(recordset)); if(succeeded(hr)) // 这里假设 Connection 对象 pconnection 已经初始化 precordset->putrefactiveconnection(pconnection); hr = precordset->open(_variant_t(bstrquery), vnull, adopenforwardonly, adlockoptimistic, adcmdtext ); if(!precordset->getadoeof() ) // 删除当前游标所指的位置 precordset->delete( adaffectcurrent ); precordset->close(); catch(_com_error &e) AfxMessageBox(e.ErrorMessage()); (2) AddNew 函数 HRESULT hr; _bbstr_t bstrquery( SELECT *FROM Products WHERE PartNumber IS NULL ); _variant_t vnull; vnull.vt = VT_ERROR; vnull.scode = DISP_E_PARAMNOTFOUND; try hr = precordset.createinstance(_uuidof(recordset)); if(succeeded(hr))

7 precordset->putrefactiveconnection(pdoc->m_pconnection); hr = precordset->open(_variant_t(bstrquery), vnull, adopenforwardonly, adlockoptimistic, adcmdtext); if(succeeded(hr)) // 创建一个记录字段信息数组 COleSafeArray vafieldlist; VaFieldlist.CreateOneDim(VT_VARIANT, 3); long larrayindex[1]; larrayindex[0] = 0; vafieldlist.putelement( larrayindex, &(_variant_t( OpartNumber ))); larrayindex[0] = 1; vafieldlist.putelement(larrayindex, &(_variant_t( ProductName ))); larrayindex[0] = 2; vafieldlist.putelement( larrayindex, &(_variant_t( Price ))); // 创建一个保存字段值的数组 ColeSafArray vavaluelist; vavaluelist.createonedim( VT_VARIANT, 3 ); larrayindex[0] = 0; vavaluelist.putelement( larrayindex, &(_variant_t( 8TRACK-003 ))); larrayindex[0] = 1; vavaluelist.putelement( larrayindex, &(_variant_t( Bell Bottom Hits ))); larrayindex[0] = 2; vavaluelist.putelement( larrayindex, &(_variant_t((float)19.95))); // 执行添加操作 precordset->addnew(vafieldlist, vavaluelist); precordset->close();

8 catch(_com_error &e) AfxMessageBox(e.ErrorMessage()); 从上面的示例代码看出,AddNew 和 Update 方法的参数都是两个变体类型的数组 这种参数在编程的时候比较麻烦, 需要编写从 VARIANT 类型到 C++ 类型的转换代码 而且, 使用 VARIANT 类型检索 C/C++ 数据的过程也有损性能 <4>. 命令的使用 象 在 ADO 中, 可以用 Connection 对象的 Execute() 方法执行命令, 也可以用 Command 对 (1). 第一个方法相对简单 Execute 函数的原型如下 : _RecordsetPtr Execute( _bstr_t cmd, VARIANT * rcds, long optn); 第一个参数 cmd 用一个字符串作为参数, 第三个参数说明了 cmd 的类型 : adcmdtext: cmd 是一个 SQL 命令 adcmdtable: cmd 指明了一个表名 adcmdstoredproc cmd 指明了一个存储过程 Execute 返回的结果是一个 Recordset 指针 下面是一段 Execute 的简单例子 : _bstr_t sql = SELECT id FROM tb1 WHERE id = TOM AND pswd = 111 ; _RecordsetPtr prst; prst = pdbcnt->execute(sql, NULL, adcmdtext); if(!prst->adoeof) MessageBox( 登陆成功! ); (2). 第二个方法使用 Command 对象相对复杂, 需要设置很多属性和参数, 因而功能也 更为强大 这里通过一段示例程序来解释它的用法 HRESULT hr = S_OK; // 定义字符串常量

9 _bstr_t strsqlchanges( UPDATE Titles SET Type = self_help WHERE Type = psychology ); _bstr_t strsqlrestore( UPDATE Titles SET Type = psychology WHERE Type = self_help ); _bstr_t strcnn( Provider = sqloledb; Data Source = MyServer ; Initial Catalog = pubs ; User Id = sa ; Password =; ); // 定义 ADO 对象 _ConnectionPtr pconnection = NULL; _CommandPtr pcmdchange = NULL; _RecordsetPtr prsttitles = NULL; try // 建立连接 TESTHR(pConnection.CreateInstance( uuidof(connection))); pconnection->open(strcnn,,, adconnectunspecified); // 创建命令对象 TESTHR(pCmdChange.CreateInstance( uuidof(command))); pcmdchange->activeconnection = pconnection; pcmdchange->commandtext = strsqlchange; // 打开 titles 表 TESTHR(pRstTitles.CreateInstance( uuidof(command))); PRstTitles->Open( Titles, _variant_t((idispatch *) pconnection, true), adopenstatic, adlockoptimistic, adcmdtable); // 清除原有的错误记录 pconnection->errors->clear(); // 执行命令 pcmdchanges->execute(null, NULL, adcmdtext); prsttitles->requery(adcmdunknown); // 结束程序, 释放对象 prsttitles->close(); pconnection->close(); catch(_com_error & e) AfxMessageBox(e.ErrorMessage());

10 <5>. 事务的使用 在数据库中, 事务的概念可以把多个操作作为单一的最基本的活动来进行 例如, 在一个银行的数据库中, 需要从一个帐户取钱汇入到另外一个帐户中 这里涉及了至少 2 个操作 : 减少 A 帐户的资金, 增加 B 帐户的资金, 如果第一个操作顺利完成, 而第二个操作不幸失败的话, 数据库的完成性将受到破坏 操作前后银行里的资金的总数变少了, 所以这里就要用到 ADO 中事务处理的概念 在所有操作之前调用 Connection 对象的 BeginTrans 方法来开始一个事务 : pdbcnt->begintrans(); 在所有操作成功之后, 调用 Connection 对象的 CommitTrans 方法提交此事务, 这时数据库的内容才做了实质的改变 : pdbcnt->committrans(); 如果操作中出现了异常, 则在异常处理使用 RollBackTrans 取消这次事务, 数据库将回到 BeginTrans 之前的状态 catch(_com_error & e) AfxMessageBox(e.ErrorMessage()); pdbcnt->rollbacktrans(); <6> 事件的使用 ADO 从 2.0 版本开始加入了对事件的支持 ADO 事件是由某些操作在开始之前或者结束之后发生的通知 : 所谓通知实质上是对预定义的事件处理回调函数的调用 ADO 事件分 2 类 :ConnecitionEvent 和 RecordsetEvent 前者出现在连接(Connection) 打开 切断, 事务 (Transaction) 开始 提交或命令被执行等与 Connection 对象有关的操作处 ; 后者出现在与记录集 (Recordset) 对象有关的操作处, 如在记录集中定位 修改字段 删除记录集等 若按时间性质来分,ADO 事件又可分为 Will 事件 Complete 事件和其他事件 3 类 顾名思义,Will 事件发生在某个操作之前,Complete 事件发生在某个操作完成之后 表 1 和表 2 中是一些典型的 ADO 事件 : 表 1: ConnectionEvent 连接事件 (ConnectionEvent) BeginTransComplete CommitTransComplete RollbackTransComplete WillConnect ConnectComplete Disconnect WillExecute ExecuteComplete InfoMessage 说明事务相关的事件连接相关的事件命令相关的事件关于当前操作有附加信息的通知

11 表 2: RecordsetEvent 记录集事件 (RecordsetEvent) FetchProgress FetchComplete WillChangeField FieldChangeComplete WillMove MoveComplete EndOfRecordset WillChangeRecord RecordChangeComplete WillChangeRecordset RecordsetChangeComplete 说明数据检索相关的事件字段更改相关的事件定位操作相关的事件行更改相关事件数据集更改相关的事件 下面结合一个例程的片段来说明如何在应用程序中使用 ADO 事件 : // 从 ConnectionEvents 派生一个连接事件的类 class CConnEvent : public ConnectionEventsVt private: // 接口引用计数 ULONG m_cref; public: CConnEvent() m_cref = 0; ~CConEvent(); // 实现 Iunknown 的三个标准方法 STDMETHODIMP QueryInterface(REFIID riid, void ** ppv); STDMETHODIMP_(ULONG) AddRef(void); STDMETHODIMP_(ULONG) Release(void); // 处理 InfoMessage 事件的回调函数 STDMETHODIMP raw_infomessage( struct Error *perror, EventStatusEnum *adstatus, struct _Connection *pconnection); // 处理 BeginTransComplete 事件的回调函数 STDMETHODIMP raw_begintranscomplete( LONG TransactionLevel, struct Error *perror, EventStatusEnum *adstatus, struct _Connection *pconnection);

12 ; // 处理 CommitTransComplete 事件的回调函数 STDMETHODIMP raw_committranscomplete( struct Error *perror, EventStatusEnum *padstatus, struct _Connection *pconnection); 上面定义的这个类继承了 ConnectionEventVt 接口, 实现了 Connection 事件类所有的回调函数 大家可以仿照它的定义出自己的 RecordsetEvent 事件类 这 2 个类是所谓的 COM 组件类, 所以它必须实现 IUnknown 的三个标准方法 :QueryInterface, AddRef, 和 Release 大家可以使用最合适的工具例如 ATL 来简化这部分工作, 这里只给出和事件对象关系最大的几个回调函数的代码 //CConnEvent 类的实现 STDMETHODIMP CConnEvent::raw_InfoMessage( struct Error *perror, EventStatusEnum *adstatus, struct _Connection *pconnection) *adstatus = adstatusunwantedevent; return S_OK; STDMETHODIMP CConnEvent::raw_BeginTransComplete( LONG TransactionLevel, struct Error *perror, EventStatusEnum *adstatus, struct _Connection *pconnection) *adstatus = adstatusunwantedevent; return S_OK; STDMETHODIMP CConnEvent::raw_CommitTransComplete( struct Error* perror, EventStatusEnum *adstatus, struct _Connection *pconnection) *adstatus = adstatusunwantedevent; return S_OK; 由于是演示, 这个几个函数没有做任何实际的事情 需要注意每个函数的第一句, 在这 里把 adstatus 的值设为 adstatusunwantedevent, 这样这个函数在第一次被调用之后将不会再

13 被调用 如果用户需要这个事件处理函数的工作就必须去掉第一句 下面的代码演示了怎样在程序中使用上面定义的 ADO 事件类 int main(int argc, char* argv[]) HRESULT hr; DWORD dwconnevt; DWORD dwrstevt; IConnectionPointContainer *pcpc = NULL; IConnectionPoint *pcp = NULL; IUnknown *punk = NULL; CRstEvent *prstevent = NULL; CConnEvent *pconnevent = NULL; int rc = 0; _RecordsetPtr prst; _ConnectionPtr pconn; ::CoInitialize(NULL); hr = pconn.createinstance( uuidof(connection)); if(failed(hr)) return rc; hr = prst.createinterface( uuidof(recordset)); // 开始使用 Connection 事件 hr = pconn->queryinterface( uuidof(iconnectionpointcontainer), (void**)&pcpc ); hr = pcpc->findconnectionpoint( uuidof(connectionevents), &pcp); pcpc->release(); // 开始使用 Recordset 事件 hr = prst->queryinterface( uuidof(iconnectionpointcontainer), (void**)&pcpc); hr = pcpc->findconectionpoint( uuidof(recordsetevents), &pcp); pcpc->release();

14 prstevent = new CRstEvent(); hr = prstevent->queryinterface( uuidof(iunknown), (void**)&punk); hr = pcp->advise(punk, &dwrstevent); pcp->release(); // 进行一些数据库操作 pconn->open( dsn = Pubs;, sa,,adconnectionunspecified); prst->open( SELECT *FROM authors, (IDispath *) pconn, adopenstatic, adlockreadonly, adcmdtext); prst->movefirst(); while(prst->endoffile == FALSE) wprintf(l Name = %s \n, (wchar_t*) ((_bstr_t)prst->field->getitem( au_iname )->Value)); prst->movenext(); prst->close(); pconn->colse(); // 停止使用 Connection 事件类 hr = pconn->queryinterface( uuidof(iconnectionpointcontainer), (void**)&pcpc); hr = pcpc->findconnectionpoint( uuidof(recordsetevents), &pcp); pcpc->release(); hr = pcp->unadvise(dwrstevt); pcp->release(); CoUninitialize(); return 1;