用C++封装的ADO类

我会带着你远行 2022-06-18 01:09 290阅读 0赞

**用C++封装的ADO类**

作者：刘振海

.H文件

// ADO.h: interface for the CADO class.  
//  
//

\#if !defined(AFX\_ADO\_H\_\_5A466E67\_5E04\_445D\_9CB0\_C64650B9AC68\_\_INCLUDED\_)  
\#define AFX\_ADO\_H\_\_5A466E67\_5E04\_445D\_9CB0\_C64650B9AC68\_\_INCLUDED\_

\#if \_MSC\_VER > 1000  
\#pragma once  
\#endif // \_MSC\_VER > 1000

\#include <comdef.h>  
\#include "msado15.tlh"

class CADO  
\{  
public:  
\_RecordsetPtr m\_pRecordset;  
public:  
CADO();  
virtual ~CADO();  
BOOL openDB(CString m\_strPathName, CString m\_strName, CString m\_strPassword, CString m\_strProvider);  
void close();  
\_RecordsetPtr search(const CString m\_strSql);  
BOOL dbDelete(const CString m\_strSql);  
BOOL update(const CString m\_strSql);  
BOOL insert(const CString m\_strSql);  
private:  
void initConnection();  
void initRecordSet();  
void initCommand();  
BOOL CommandIsValid();  
BOOL RecordSetIsValid();  
BOOL ConnectionIsValid();  
private:  
\_CommandPtr m\_pCommand;  
\_ConnectionPtr m\_pConnection;

\};

\#endif // !defined(AFX\_ADO\_H\_\_5A466E67\_5E04\_445D\_9CB0\_C64650B9AC68\_\_INCLUDED\_)

.CPP文件

// ADO.cpp: implementation of the CADO class.  
//  
//

\#include "stdafx.h"  
\#include "YXRM.h"  
\#include "ADO.h"

\#ifdef \_DEBUG  
\#undef THIS\_FILE  
static char THIS\_FILE\[\]=\_\_FILE\_\_;  
\#define new DEBUG\_NEW  
\#endif

//  
// Construction/Destruction  
//

CADO::CADO()  
\{  
  
\}

CADO::~CADO()  
\{  
  
\}

BOOL CADO::ConnectionIsValid()  
\{  
if (m\_pConnection == NULL)  
return FALSE;  
else  
return TRUE;  
\}

BOOL CADO::RecordSetIsValid()  
\{  
if (m\_pRecordset == NULL)  
return FALSE;  
else  
return TRUE;  
\}

BOOL CADO::CommandIsValid()  
\{  
if (m\_pCommand == NULL)  
return FALSE;  
else  
return TRUE;  
\}

void CADO::initConnection()  
\{  
if (!ConnectionIsValid())  
m\_pConnection.CreateInstance( \_\_uuidof(Connection));  
\}

void CADO::initRecordSet()  
\{  
if (!RecordSetIsValid())  
m\_pRecordset.CreateInstance(\_\_uuidof(Recordset));  
\}

void CADO::initCommand()  
\{  
if (!CommandIsValid())  
m\_pCommand.CreateInstance(\_\_uuidof(Command));  
\}

BOOL CADO::openDB(CString m\_strPathName, CString m\_strName, CString m\_strPassword, CString m\_strProvider)  
\{  
initConnection();  
initRecordSet();  
initCommand();  
m\_pConnection->Provider = \_bstr\_t(m\_strProvider);  
if(S\_OK == m\_pConnection->Open(\_bstr\_t(m\_strPathName), \_bstr\_t(m\_strName), \_bstr\_t(m\_strPassword), adModeUnknown))  
return TRUE;  
else  
return FALSE;  
\}

void CADO::close()  
\{  
if (RecordSetIsValid())  
\{  
if( m\_pRecordset->State == adStateOpen)  
m\_pRecordset->Close();  
\}  
if (ConnectionIsValid() || m\_pConnection->State == adStateOpen)  
\{  
m\_pConnection->Close();  
\}  
\}

BOOL CADO::insert(const CString m\_strSql)  
\{  
try  
\{  
if (!ConnectionIsValid() || m\_pConnection->State == adStateClosed)  
\{  
AfxMessageBox("DB closed");  
//RAConnect(m\_ConnectionString);  
return FALSE;  
\}  
  
if(!CommandIsValid())  
\{  
initCommand();  
\}  
  
m\_pCommand->ActiveConnection = m\_pConnection;  
m\_pCommand->CommandType = adCmdText;  
m\_pCommand->CommandText = \_bstr\_t(m\_strSql);  
  
\_variant\_t vNull;  
vNull.vt = VT\_ERROR;  
vNull.scode = DISP\_E\_PARAMNOTFOUND;  
  
m\_pCommand->Execute(&vNull, &vNull, adCmdText);//m\_pConnection->Execute(........)也可以  
  
return TRUE;  
\}  
catch(\_com\_error &e)  
\{  
AfxMessageBox(e.Description());  
return FALSE;  
\}  
\}

BOOL CADO::update(const CString m\_strSql)  
\{  
try  
\{  
if (!ConnectionIsValid() || m\_pConnection->State == adStateClosed)  
\{  
AfxMessageBox("DB closed");  
//RAConnect(m\_ConnectionString);  
return FALSE;  
\}

if(!CommandIsValid())  
\{  
initCommand();  
\}  
  
m\_pCommand->ActiveConnection = m\_pConnection;  
m\_pCommand->CommandType = adCmdText;  
m\_pCommand->CommandText = \_bstr\_t(m\_strSql);  
  
\_variant\_t vNull;  
vNull.vt = VT\_ERROR;  
vNull.scode = DISP\_E\_PARAMNOTFOUND;  
  
m\_pCommand->Execute(&vNull, &vNull, adCmdText);  
  
return TRUE;  
\}  
catch(\_com\_error &e)  
\{  
AfxMessageBox(e.Description());  
return FALSE;  
\}  
\}

BOOL CADO::dbDelete(const CString m\_strSql)  
\{  
try  
\{  
if (!ConnectionIsValid() || m\_pConnection->State == adStateClosed)  
\{  
AfxMessageBox("DB closed");  
//RAConnect(m\_ConnectionString);  
return FALSE;  
\}

\_RecordsetPtr CADO::search(const CString m\_strSql)  
\{  
try  
\{  
if (!ConnectionIsValid() || m\_pConnection->State == adStateClosed)  
\{  
AfxMessageBox("DB closed");  
//RAConnect(m\_ConnectionString);  
return NULL;  
\}  
else  
\{  
if (RecordSetIsValid())  
\{  
if (m\_pRecordset->State == adStateOpen)  
m\_pRecordset->Close();  
\}  
else  
\{  
initRecordSet();  
\}  
  
if(!CommandIsValid())  
\{  
initCommand();  
\}

m\_pCommand->ActiveConnection = m\_pConnection;  
m\_pCommand->CommandType = adCmdText;  
m\_pCommand->CommandText = \_bstr\_t(m\_strSql);  
  
\_variant\_t vNull;  
vNull.vt = VT\_ERROR;  
vNull.scode = DISP\_E\_PARAMNOTFOUND;  
  
m\_pRecordset = m\_pCommand->Execute(&vNull, &vNull, adCmdText);  
return m\_pRecordset.Detach();  
\}  
\}  
catch(\_com\_error &e)  
\{  
AfxMessageBox(e.Description());  
return NULL;  
\}  
\}  
调用/

if(!(classAdo.openDB("db1.mdb","","","Microsoft.JET.OLEDB.4.0")))  
return FALSE;