ADO 方法访问数据库的封装接口（01）

        数据库访问是软件开发过程中经常用到的，ADO方法访问数据库是现在Windows平台开发软件经常用到的方法，但是在ADO组件中，使用COM调用的时候，经常会出现各种异常，异常处理在开发过程中如果处理不当，经常会导致程序无法正常工作甚至崩溃。本人在开发软件过程中，对ADO方法进行了封装，把COM异常吸收在类的内部，这样引用的时候就不必考虑异常处理，使开发过程简单化。本次封装，没有支持全部的方法，只是把最基本的数据库访问方法进行了封装，能够满足一般的开发应用。使用封装类的一个好处是，如果系统需要扩展数据库，比如支持其他的数据库访问方法，只需要修改实现就可以了，不需要调整接口，也增强了软件的可扩展性。
1. DBConnectionImpl.h
#pragma once

typedef _ConnectionPtr CADOConnectionPtr;

class CDBConnectionImpl
{
 //构造函数和析构函数
public:
 CDBConnectionImpl(void);
 virtual ~CDBConnectionImpl(void);

 //copy 采用复制的方式，复制后两个连接是相同，复制后的任何一个副本关闭连接后，
 //所有副本的连接都会关闭，需要注意
   
 //copy constructor
 CDBConnectionImpl(const CDBConnectionImpl& rConnectionImpl) ;

 //operator =
 CDBConnectionImpl& operator= (const CDBConnectionImpl& rConnectionImpl) ;

 //接口函数
public:

 //返回数据库连接
 CADOConnectionPtr& GetConnection(void);

 /*
  * 判断当前连接是否已经创建对象
  */
 BOOL isValid(void) ;

 void SetErrorMessage(LPCTSTR szErrMsg,const char* szSourceFile=NULL,int nLine=0) ;

 const CString& GetErrorMessage(void) ;

 //是否自动关闭连接
 BOOL GetAutoClose(void) ;

protected:
 //数据库连接
 CADOConnectionPtr m_pConnectionPtr;
 //error message
 CString m_strErrMsg ;
 //是否自动关闭连接
 BOOL m_bAutoClose ;
};

inline CADOConnectionPtr& CDBConnectionImpl::GetConnection(void)
{
 return m_pConnectionPtr ;
};

inline BOOL CDBConnectionImpl::isValid(void)
{
 return (m_pConnectionPtr != NULL) ;
};

inline const CString& CDBConnectionImpl::GetErrorMessage(void)
{
 return m_strErrMsg;
}

inline BOOL CDBConnectionImpl::GetAutoClose(void)
{
 return m_bAutoClose ;
}

2. DBConnectionImpl.cpp
#include "StdAfx.h"
#include ".\dbconnectionimpl.h"
#include "DBErrorMsgDefs.h"
#include "ErrorHandler\Win32ErrorMsg.h"

CDBConnectionImpl::CDBConnectionImpl(void):
 m_bAutoClose(TRUE)
{
 HRESULT hr = S_OK ;
 try
 {
  hr = m_pConnectionPtr.CreateInstance(__uuidof(Connection));
  if (FAILED(hr))
  {
   CString strErrMsg = CWin32ErrorMsg::GetHResultErrorDescription(hr) ;
   SetErrorMessage((LPCTSTR)strErrMsg,__FILE__,__LINE__) ;
  }
 }
 catch (_com_error &e)
 {
  SetErrorMessage((LPCTSTR)e.Description(),__FILE__,__LINE__) ;
 }
 catch (...)
 {
  SetErrorMessage(EXCEPTION_UNKNOWN,__FILE__,__LINE__) ;
 }
}

//copy constructor
CDBConnectionImpl::CDBConnectionImpl(const CDBConnectionImpl& rConnectionImpl):
 m_pConnectionPtr(NULL),
 m_bAutoClose(FALSE)
{
 
 *this = rConnectionImpl ;
}

//operator =
CDBConnectionImpl& CDBConnectionImpl::operator= (const CDBConnectionImpl& rConnectionImpl)
{
 if(this == &rConnectionImpl)
 {
  return *this ;
 }

 //错误信息不复制 
 try
 {  
  m_strErrMsg = _T("");
  //关闭连接，并释放对象
  if (m_pConnectionPtr != NULL)
  {
   if((m_pConnectionPtr->GetState() != adStateClosed) && (m_bAutoClose) )
   {
    m_pConnectionPtr->Close() ;
    m_pConnectionPtr = NULL ;
   }  
  }

  //clone it from destination
  if(rConnectionImpl.m_pConnectionPtr != NULL)
  {
   m_pConnectionPtr = rConnectionImpl.m_pConnectionPtr ;
  } 
  m_bAutoClose = FALSE ;
 }
 catch (_com_error &e)
 {
  SetErrorMessage((LPCTSTR)e.Description(),__FILE__,__LINE__) ;
 }
 catch (...)
 {
  SetErrorMessage(EXCEPTION_UNKNOWN,__FILE__,__LINE__) ;
 }
 return *this ;
}

CDBConnectionImpl::~CDBConnectionImpl(void)
{
 try
 {
  //关闭连接，并释放对象
  if (m_pConnectionPtr != NULL)
  {
   if( (m_pConnectionPtr->GetState() != adStateClosed) && (m_bAutoClose) )
   {
    m_pConnectionPtr->Close() ;
   }
   m_pConnectionPtr = NULL ;
  }
 }
 catch (_com_error &e)
 {
  SetErrorMessage((LPCTSTR)e.Description(),__FILE__,__LINE__) ;
 }
 catch (...)
 {
  SetErrorMessage(EXCEPTION_UNKNOWN,__FILE__,__LINE__) ;
 }
}

void CDBConnectionImpl::SetErrorMessage(LPCTSTR szErrMsg,const char* szSourceFile,int nLine)
{
 m_strErrMsg = szErrMsg ;
}

//end of this file DBConnectionImpl.cpp

本文地址：http://com.8s8s.com/it/it493.htm