用C++封装的ADO类

用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;
   }  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;
  }
 }_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;