?? operateaccess.cpp
字號:
// OperateAccess.cpp: implementation of the COperateAccess class.
//
//////////////////////////////////////////////////////////////////////
#include "stdafx.h"
#include "Access.h"
#include "OperateAccess.h"
#ifdef _DEBUG
#undef THIS_FILE
static char THIS_FILE[]=__FILE__;
#define new DEBUG_NEW
#endif
//////////////////////////////////////////////////////////////////////
// Construction/Destruction
//////////////////////////////////////////////////////////////////////
COperateAccess::COperateAccess()
{
}
COperateAccess::~COperateAccess()
{
}
BOOL COperateAccess::ConnectDataBase(CString dbName,CString userID,CString password)
{
AfxOleInit();
HRESULT hr;
try
{
hr = m_pConnection.CreateInstance("ADODB.Connection");///創建Connection對象
if(SUCCEEDED(hr))
{
CString connectString;
connectString.Format("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=%s",dbName);
// m_pConnection->ConnectionString="DRIVER={Microsoft Access Driver (file.mdb)}";
hr = m_pConnection->Open((_bstr_t)connectString,
(_bstr_t)userID,(_bstr_t)password,adModeUnknown);///連接數據庫
//上面一句中連接字串中的Provider是針對ACCESS2000環境的,對于ACCESS97,
//需要改為:Provider=Microsoft.Jet.OLEDB.3.51;
}
}
catch(_com_error e)///捕捉異常
{
CString errormessage;
errormessage.Format("連接數據庫失敗!\r\n錯誤信息:%s",e.ErrorMessage());
AfxMessageBox(errormessage); //顯示錯誤信息
return FALSE;
}
// AfxMessageBox("connect success");
return TRUE;
}
extern CAccessApp theApp;
_RecordsetPtr COperateAccess::ReadDataBase(CString SQLStatement)
{
_RecordsetPtr m_pRecordset;
try
{
m_pRecordset.CreateInstance("ADODB.Recordset");
m_pRecordset->Open((_bstr_t)SQLStatement,\
_variant_t((IDispatch *)theApp.connectAccess.m_pConnection,true),adOpenDynamic,\
adLockOptimistic,adCmdText);
if(m_pRecordset->adoEOF)
{
AfxMessageBox("當前沒有記錄存在!");
return NULL;
}
return m_pRecordset;
}
catch(_com_error e)
{
CString errormessage;
errormessage.Format("操作失敗!\r\n錯誤信息:%s",e.ErrorMessage());
AfxMessageBox(errormessage); //顯示錯誤信息
AfxMessageBox(e.Source());
AfxMessageBox(e.Description());
return NULL;
}
}
BOOL COperateAccess::OperateRecord(CString SQLStatement)
{
_variant_t RecordsAffected;
HRESULT hr;
try
{
hr=theApp.connectAccess.m_pConnection->Execute((_bstr_t)SQLStatement,&RecordsAffected,adCmdText);
if(SUCCEEDED(hr))
{
return TRUE;
}
else
return FALSE;
}
catch(_com_error e)
{
CString errormessage;
errormessage.Format("操作失敗!\r\n錯誤信息:%s",e.ErrorMessage());
AfxMessageBox(errormessage); //顯示錯誤信息
AfxMessageBox(e.Source());
AfxMessageBox(e.Description());
return FALSE;
}
return TRUE;
}
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -