/*********************************************************************/
#include "stdafx.h"
#include "ADO.h"

/*********************************************************************/
#if !defined CATCH_ERROR
#define CATCH_ERROR														\
		{																\
			CString strComError;										\
			strComError.Format("錯誤編號: %08lx\n錯誤信息: %s			\
								\n錯誤源: %s\n錯誤描述: %s",			\
								e.Error(),								\
								e.ErrorMessage(),						\
								(LPCSTR) e.Source(),					\
								(LPCSTR) e.Description());				\
			::MessageBox(NULL,strComError,"錯誤",MB_ICONEXCLAMATION);	\
		}
#endif
/*********************************************************************/

CADO::CADO()
{
	::CoInitialize(NULL);				// 初始化OLE/COM庫環境 
	try
	{
		m_pConn.CreateInstance("ADODB.Connection");	//創建Connection對象
		m_pConn->ConnectionTimeout=5;	//設置超時時間為3秒
		m_pConn->Open("DSN=eee","","",0);	
	}
	catch(_com_error e)					//捕捉異常
	{
		CATCH_ERROR;
	}
}

CADO::~CADO()
{
	if (m_pRS != NULL)				// 關閉記錄集和連接
		m_pRS->Close();
	m_pConn->Close();
	
	::CoUninitialize();				// 釋放環境
}


_RecordsetPtr&  CADO::GetRS(CString strSQL)
{
	try
	{
		m_pRS.CreateInstance(__uuidof(Recordset));
		m_pRS->Open((_bstr_t)strSQL,m_pConn.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);	// 取得表中的記錄
	}
	catch(_com_error e)
	{
		CATCH_ERROR	
	}
	return m_pRS;
}

 
BOOL CADO::Execute(CString strSQL)
{
	try
	{
		m_pConn->Execute((_bstr_t)strSQL,NULL,adCmdText);
		return true;
	}
	catch(_com_error e)
	{
		CATCH_ERROR		
		return false;
	}
}