C++ ADO Database

 

2 ADO对象模型组成

　　与微软的其它数据访问模型DAO和RDO相比，ADO对象模型非常精炼，仅由三个主要对象Connection、Command、Recordset和几个辅助对象组成，其相互关系如图所示。Connection对象提供OLE DB数据源和对话对象之间的关联，它通过用户名称和口令来处理用户身份的鉴别，并提供事务处理的支持；它还提供执行方法，从而简化数据源的连接和数据检索的进程。Command对象封装了数据源可以解释的命令，该命令可以是SQL命令、存储过程或底层数据源可以理解的任何内容。Record set用于表示从数据源中返回的表格数据，它封装了记录集合的导航、记录更新、记录删除和新记录的添加等方法，还提供了批量更新记录的能力。其它辅助对象则分别提供封装ADO错误、封装命令参数和封装记录集合的列。

 

3 VC 调用ADO基本方法

 

1、 用import导入ADO 的 COM 文件msado15.dll

　　例如：

#import "C:\Program Files\Common Files\System\ADO\msado15.dll"\no_namespace

　　2、COM 使用时初始化

HRESULT ComInit() { 　HRESULT hr = S_OK; // 默认返回值 　if FAILED(CoInitialize(NULL)) // COM 初始化调用 　{ 　　CoUninitialize(); 　　hr = E_UNEXPECTED; 　} 　return hr; }

　　3、建立数据库连接

HRESULT ConnectToDB( LPSTR pUserId , // 用户名 　LPSTR pConnString, // 连接字串 　LPSTR pUserPassword , // 用户密码 　ConnectOptionEnum ConnectOption) // 连接参数 　{ 　　HRESULT hr = S_OK; // 默认返回值 　　_ConnectionPtr ptrConn; // 定义Connection对象 　　try 　　{ 　　　// 创建一个连接实体 　　　hr = ptrConn.CreateInstance(__uuidof(Connection)); 　　　// 设定连接等待的最大秒数，默认是15秒 　　　ptrConn->ConnectionTimeout = 20 　　　// 打开连接 　　　hr = ptrConn->Open(pConnString, 　　　pUserId, 　　　pUserPassword, 　　　ConnectOption); 　　　return hr; 　　} 　　catch(_com_error &pComError) 　　{ 　　　…… // 错误处理 　　　return E_UNEXPECTED; 　　} 　}

 

关闭一个库连接 如果连接状态有效，则用Close方法关闭它并赋于它空值。代码如下所示：

if(m_pConnection->State) m_pConnection->Close(); m_pConnection= NULL;

　　4．执行一个SQL 查询，得到数据集（recordset）

_RecordsetPtr GetRecordSet(LPSTR strSql, _ConnectionPtr ptrConn) { 　try 　{ 　　RecordsetPtr ptrRS； // recordset 对象 　　// 创建recordset 对象实体 　　ptrRS.CreateInstance(__uuidof(Recordset)); 　　ptrRS->Open( strSql, 　　　ptrConn.GetInterfacePtr(), 　　　adOpenForwardOnly, 　　　adLockUnspecified, 　　　adCmdText); 　或者 　　ptrRS = ptrConn ->Execute(m_ strSql,NULL, adCmdText); 　　return ptrRS; 　} 　catch(_com_error &a_pComError) 　{ 　　….// 错误处理 　　return NULL; 　} }

　　5．通过数据集（recordset）得到列的名称

HRESULT GetColumnNames( 　_RecordsetPtr ptrRs, // recordset 对象 　char strColNames[][255], 　DataTypeEnum iColTypes[]) 　{ 　　try 　　{ // 参数变量 　　　_variant_t l_vaIndex; 　　　l_vaIndex.vt = VT_I2; 　　　// COLUMNS总数 　　　long lColCount; 　　　lColCount = ptrRs ->Fields->Count; 　　　// 循环取得列的属性和名称 　　　for(int iIndex = 0 ; iIndex < lColCount; iIndex++) 　　　{ 　　　　l_vaIndex.iVal = iIndex; // 设置循环索引 　　　　// 取得字段名称 　　　　sprintf(strColNames[iIndex], "%s",(LPSTR)ptrRs ->Fields->GetItem(l_vaIndex)->Name); 　　　　// 取得字段属性 　　　　iColTypes = ptrRs ->Fields->GetItem(l_vaIndex)->Type; 　　　} 　　} 　　return S_OK; 　} 　catch(_com_error &a_pComError) 　{ 　　…. // 错误处理 　　return E_UNEXPECTED; 　} 　catch(...) 　{ 　　…. // 错误处理 　　return E_UNEXPECTED; 　} }

　　6．通过数据集（recordset）得到当前行记录

HRESULT getOneRecord( 　_RecordsetPtr ptrRs, 　const long lNoOfColumns, 　_variant_t varValue[]) 　{ 　　try 　　{ 　　　// 参数变量 　　　_variant_t l_vaIndex; 　　　l_vaIndex.vt = VT_I2; 　　　// 循环取得列的值 　　　for(long lIndex = 0; lIndex < lNoOfColumns; lIndex ++) 　　　{ 　　　　l_vaIndex.iVal = lIndex; 　　　　// 取得字段值 　　　　varValue[lIndex]= ptrRs->Fields->GetItem(l_vaIndex)->Value; 　　　} 　　　return S_OK; 　　} 　　catch(_com_error &a_pComError) 　　{ 　　　…. // 错误处理 　　　return E_UNEXPECTED; 　　} 　　catch(...) 　　{ 　　　…. // 错误处理 　　　return E_UNEXPECTED; 　　} 　}

　　7．出错情况下错误信息的取得

void ErrorFunc(_com_error &pComError, _ConnectionPtr ptrConn); { 　// COM 错误取得 　// 当执行COM功能的时候，如果出错，可以捕捉到_com_error的异常 　char lpComErrorStr512]; 　sprintf(lpComErrorStr512,"ErrorCode = %08lx \ 　　Error Message = %s \ 　　Source = %s \ 　　Description = %s ", 　　pComError.Error(), // 错误编号 　　pComError.ErrorMessage(),// 错误信息 　　(LPCSTR) pComError.Source(),// 错误源 　　(LPCSTR) pComError.Description());// 错误描述 　　// 通过上面的代码我们可以看出，_com_error对象中可以得到COM所有出错的信息 　　// ADO错误取得 　　ErrorPtr pErr = NULL; 　　if( (ptrConn ->Errors->Count) > 0) 　　{ 　　　long nCount = ptrConn ->Errors->Count; 　　　for(long i = 0; i < nCount; i++) 　　　{ 　　　　pErr = a_pConnPtr->Errors->GetItem(i); 　　　　char l_pchErrorString[512]; 　　　　sprintf(l_pchErrorString,"Error:\n Error number: %x\t%s", 　　　　　pErr->Number, // 错误编号 　　　　　pErr->Description); // 错误描述 　　　} 　　} 　　// ADO 处理出错的情况下, 在connection对象里面都有记录，可以通过访问 　　// connection 对象取得错误编号和错误信息。

插入记录 可以先用AddNew()方法新增一个空记录，再用PutCollect(字段名,值)输入每个字段的值，最后再Update()更新到库中数据既可。其中变量m_Name和m_Age分别为姓名及年龄编辑框的成员变量名。代码所下所示：

try { // 写入各字段值 m_pRecordset->AddNew(); m_pRecordset->PutCollect("Name", _variant_t(m_Name)); m_pRecordset->PutCollect("Age", atol(m_Age)); m_pRecordset->Update(); AfxMessageBox("插入成功!"); } catch(_com_error *e) { AfxMessageBox(e->ErrorMessage()); }

　　 移动记录指针 移动记录指针可以通过MoveFirst()方法移动到第一条记录、MoveLast()方法移动到最后一条记录、MovePrevious()方法移动到当前记录的前一条记录、MoveNext()方法移动到当前记录的下一条记录。但我们有时经常需要随意移动记录指针到任意记录位置时，可以使用Move(记录号)方法来实现，注意: Move()方法是相对于当前记录来移动指针位置的，正值向后移动、负值向前移动，如：Move(3)，当前记录是3时，它将从记录3开始往后再移动3条记录位置。代码如下所示：

try { int curSel = m_AccessList.GetCurSel(); // 先将指针移向第一条记录，然后就可以相对第一条记录来随意移动记录指针 m_pRecordset->MoveFirst(); m_pRecordset->Move(long(curSel)); } catch(_com_error *e) { AfxMessageBox(e->ErrorMessage()); }

　　改记录中字段值 可以将记录指针移动到要修改记录的位置处，直接用PutCollect(字段名，值)将新值写入并Update()更新数据库既可。可以用上面方法移动记录指针，修改字段值代码如下所示：

try { // 假设对第二条记录进行修改 m_pRecordset->MoveFirst(); m_pRecordset->Move(1); // 从0开始 m_pRecordset->PutCollect("Name", _variant_t(m_Name)); m_pRecordset->PutCollect("Age", atol(m_Age)); m_pRecordset->Update(); } catch(_com_error *e) { AfxMessageBox(e->ErrorMessage()); }

　　 删除记录 删除记录和上面修改记录的操作类似，先将记录指针移动到要修改记录的位置，直接用Delete()方法删除它并用Update()来更新数据库既可。代码如下所示：

try { // 假设删除第二条记录 m_pRecordset->MoveFirst(); m_pRecordset->Move(1); // 从0开始 m_pRecordset->Delete(adAffectCurrent); // 参数adAffectCurrent为删除当前记录 m_pRecordset->Update(); } catch(_com_error *e) { AfxMessageBox(e->ErrorMessage()); }

　　 关闭记录集 直接用Close方法关闭记录集并赋于其空值。代码如下所示：

m_pRecordset->Close(); m_pRecordset = NULL;

　　3. CommandPtr智能指针，可以使用_ConnectionPtr或_RecordsetPtr来执行任务，定义输出参数，执行存储过程或SQL语句。

　　 执行SQL语句 先创建一个_CommandPtr实例指针，再将库连接和SQL语句做为参数，执行Execute()方法既可。代码如下所示：

_CommandPtr m_pCommand; m_pCommand.CreateInstance(__uuidof(Command)); m_pCommand->ActiveConnection = m_pConnection; // 将库连接赋于它 m_pCommand->CommandText = "SELECT * FROM DemoTable"; // SQL语句 m_pRecordset = m_pCommand->Execute(NULL, NULL,adCmdText); // 执行SQL语句，返回记录集

　　 执行存储过程 执行存储过程的操作和上面执行SQL语句类似，不同点仅是CommandText参数中不再是SQL语句，而是存储过程的名字，如Demo。另一个不同点就是在Execute()中参数由adCmdText(执行SQL语句)，改为adCmdStoredProc来执行存储过程。如果存储过程中存在输入、输出参数的话，需要使用到另一个智能指针_ParameterPtr来逐次设置要输入、输出的参数信息，并将其赋于_CommandPtr中Parameters参数来传递信息，有兴趣的读者可以自行查找相关书籍或MSDN。执行存储过程的代码如下所示：

_CommandPtr m_pCommand; m_pCommand.CreateInstance(__uuidof(Command)); m_pCommand->ActiveConnection = m_pConnection; // 将库连接赋于它 m_pCommand->CommandText = "Demo"; m_pCommand->Execute(NULL,NULL, adCmdStoredProc);