adoconnect.cpp

快递管理系统 设计一个可以发送文件、接受文件的快递管理系统。

// AdoConnect.cpp: implementation of the CAdoConnect class.
//
//////////////////////////////////////////////////////////////////////

#include "stdafx.h"
#include "cdw.h"
#include "AdoConnect.h"

#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif

//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////

CAdoConnect::CAdoConnect()
{

}

CAdoConnect::~CAdoConnect()
{

}

BOOL CAdoConnect::OnInitDBConnect()
{
::CoInitialize(NULL);        //初始化OLE/COM环境
	HRESULT hr;
	try
	{
		hr = m_pConnection.CreateInstance("ADODB.Connection");      //创建Connection对象
		if(SUCCEEDED(hr))
		{
			_bstr_t strConnect;
			strConnect="Provider=Microsoft.Jet.OLEDB.4.0;Data Source=userinfo.mdb;Persist Security Info=False;Jet OLEDB:Database Password=";
			m_pConnection->ConnectionTimeout =30;                      //设置超时时间为5秒
			hr = m_pConnection->Open(strConnect,"","",adModeUnknown);
		}
	}
	catch(_com_error e)         //捕捉异常
	{
		CString errormessage;
		errormessage.Format("连接数据库失败!\r\n错误信息:%s",e.ErrorMessage());
		AfxMessageBox(errormessage);
		return false;
	}

	return true;
}
void CAdoConnect::ExitConnect()
{
	//关闭记录集和连接
    if(m_pRecordset!=NULL)
		m_pRecordset->Close();
	m_pConnection->Close();
}
BOOL CAdoConnect::ExecuteSQL(_bstr_t bstrSQL)//执行参数bstrSQL所指定的SQL语句
{
	_variant_t RecordsAffected;
	try
	{
		if(m_pConnection==NULL)
			OnInitDBConnect();
		m_pConnection->Execute(bstrSQL,&RecordsAffected,adCmdText);
		return true;
	}
	catch(_com_error e)
	{
		CString errormessage;
		errormessage.Format("执行语句失败!\r\n错误信息:%s",e.ErrorMessage());
		AfxMessageBox(errormessage);
		return false;
	}	
}
_RecordsetPtr& CAdoConnect::GetRecordSet(_bstr_t bstrSQL)//从数据库中获得记录
{
	try
	{
		if(m_pConnection==NULL)      //连接数据库，如果Connection对象为空，则重新连接数据库
			OnInitDBConnect();
		m_pRecordset.CreateInstance("ADODB.Recordset");   

		m_pRecordset->Open(bstrSQL,_variant_t((IDispatch *)m_pConnection,true),adOpenDynamic,adLockOptimistic,adCmdText);      //取得表中的记录
	}
	catch(_com_error e)       //捕捉异常
	{
		CString errormessage;
		errormessage.Format("获取数据库记录失败!\r\n错误信息:%s",e.ErrorMessage());
		AfxMessageBox(errormessage);    
	}
	return m_pRecordset;       //返回结果集
}