VC ACCESS 逐条读取数据库

#include "stdafx.h"

#ifdef _DEBUG

#undef THIS_FILE

static char THIS_FILE[]=__FILE__

#define new DEBUG_NEW

#endif

//////////////////////////////////////////////////////////////////////

// Construction/Destruction

//////////////////////////////////////////////////////////////////////

ADOConn::ADOConn()

{

}

ADOConn::~ADOConn()

{

}

// 初始化—连接数据库

void ADOConn::OnInitADOConn()

{

// 初始化OLE/COM库环境

::CoInitialize(NULL)

try

{

// 创建Connection对象

m_pConnection.CreateInstance("ADODB.Connection")

// 设置连接字符串，必须是BSTR型或者_bstr_t类型

_bstr_t strConnect = "Provider=MSDASQL.1Persist Security Info=FalseUser ID=***Data Source=***"

m_pConnection->Open(strConnect,"","",adModeUnknown)

}

// 捕捉异常

catch(_com_error e)

{

// 显示错误信息

AfxMessageBox(e.Description())

}

}

// 执行查询

_RecordsetPtr& ADOConn::GetRecordSet(_bstr_t bstrSQL)

{

try

{

// 连接数据库，如果Connection对象为空，则重新连接数据库

if(m_pConnection==NULL)

OnInitADOConn()

// 创建记录集对象

m_pRecordset.CreateInstance(__uuidof(Recordset))

// 取得表中的记录

m_pRecordset->Open(bstrSQL,m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText)

}

// 捕捉异常

catch(_com_error e)

{

// 显示错误信息

AfxMessageBox(e.Description())

}

// 返回记录集

return m_pRecordset

}

// 执行SQL语句，Insert Update _variant_t

BOOL ADOConn::ExecuteSQL(_bstr_t bstrSQL)

{

//_variant_t RecordsAffected

try

{

// 是否已经连接数据库

if(m_pConnection == NULL)

OnInitADOConn()

// Connection对象的Execute方法:(_bstr_t CommandText,

// VARIANT * RecordsAffected, long Options )

// 其中CommandText是命令字串，通常是SQL命令。

// 参数RecordsAffected是 *** 作完成后所影响的行数,

// 参数Options表示CommandText的类型：adCmdText-文本命令；adCmdTable-表名

// adCmdProc-存储过程；adCmdUnknown-未知

m_pConnection->Execute(bstrSQL,NULL,adCmdText)

return true

}

catch(_com_error e)

{

AfxMessageBox(e.Description())

return false

}

}

void ADOConn::ExitConnect()

{

// 关闭记录集和连接

if (m_pRecordset != NULL)

m_pRecordset->Close()

m_pConnection->Close()

// 释放环境

::CoUninitialize()

}

一、使用ODBC接口，在这里我们使用MFC的CDatabase类，该类是对SQLConnect等ODBC的API的封装。需要包含afxdb.h

BOOL ODBCConnect(CString strDBFile)

{

CString strConnect

strConnect.Format(_T("ODBCDRIVER={MICROSOFT ACCESS DRIVER (*.mdb)}UID=saPWD=DBQ=%s"), strDBFile)

CDatabase db

if(db.Open(NULL, FALSE, FALSE, strConnect))

{

//连接数据库成功

CRecordset rs(&db)

CString strSql

strSql = _T("select * from info") //SQL语句

rs.Open(AFX_DB_USE_DEFAULT_TYPE, strSql) //执行Sql语句（可添加　删除　查询等）

if(rs.IsOpen())

{

CDBVariant variant

rs.MoveFirst()

while(!rs.IsEOF())

{

//读取记录

rs.GetFieldValue(_T("姓名"), variant)

rs.MoveNext()

}

}

db.Close()

return TRUE

}

return FALSE

}

二、使用ADO连接数据库，因为要使用COM，需要初始化(CoInitialize).然后就可以生成接口的对象 *** 作，代码如下：

#import "C:Program Files/Common Files/System/ado/msado15.dll" rename("EOF", "adoEOF")//生成C++类，改变EOF函数的名称

using namespace ADODB

BOOL ADOConnect(CString strDBFile)

{

_ConnectionPtr pConnection

if(pConnection.CreateInstance(__uuidof(Connection)) != S_OK)

{

return FALSE

}

CString strConnect

strConnect.Format(_T("Provider=Microsoft.Jet.OLEDB.4.0Data Source=%s"), strDBFile)

if(pConnection->Open(_bstr_t(strConnect), "", "", adModeUnknown) == S_OK)

{

//连接数据库成功

_RecordsetPtr pRecordset

if(pRecordset.CreateInstance(__uuidof(Recordset)) != S_OK)

{

pConnection->Close()

return FALSE

}

CString strSql

strSql = _T("select * from info")

HRESULT hr = pRecordset->Open(_bstr_t(strSql), _variant_t((IDispatch*)pConnection, TRUE), adOpenUnspecified, adLockUnspecified, adCmdUnknown)

if(hr != S_OK)

{

pConnection->Close()

return FALSE

}

_variant_t vt

pRecordset->MoveFirst()

while(!pRecordset->adoEOF)

{

vt = pRecordset->Fields->GetItem("姓名")->Value

pRecordset->MoveNext()

}

pConnection->Close()

return TRUE

}

return FALSE

}

---