// 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;       //返回結果集
}