ADO数据库如何使用？

下面是我写的一个简单ADO数据库使用的例子，欢迎大家借鉴。

为了使用方便，我封装成了一个函数。

头文件：

//////////////////////////////////////.H//////////////////////////////////////////////////////

#pragma once

class ADO

{

public:

_ConnectionPtr m_pConnection;

_RecordsetPtr m_pRecordset;

public:

ADO(void);

~ADO(void);

void OnInitADOConn(char* dataBaseName,char * dataSourceType);

_RecordsetPtr& OpenRecordset(CString sql);

void CloseRecordset(void);

void CloseConn(void);

UINT GetRecordCount(_RecordsetPtr pRecordset);

};

/////////////////////////////////////////.CPP/////////////////////////////////////////

#include "stdafx.h"

#include "ADO.h"

bool oleInit=false;

ADO::ADO(void)

{

}

ADO::~ADO(void)

{

CloseRecordset();

CloseConn();

}

void ADO::OnInitADOConn(char* dataBaseName,char * dataSourceType)

{

ASSERT(dataBaseName);

char string[200];

memset(string,0,200);

if (CString(dataSourceType)==CString("ACCESS"))

{

//access 2003

strcat(string,"Provider=Microsoft.Jet.OLEDB.4.0;Data Source=");

strcat(string,dataBaseName);

strcat(string,";Persist Security Info=False");

}

if (CString(dataSourceType)==CString("SQL"))

{

//sql server 2000

strcat(string,"Provider=SQLOLEDB.1;Password=u99sj;Persist Security Info=True;User ID=sa;Initial Catalog=DataLink;Data Source=");

strcat(string,dataBaseName);

}

::CoInitialize(NULL);

try

{

m_pConnection.CreateInstance("ADODB.Connection");

_bstr_t strConnect=string;

//_bstr_t strConnect=dataBaseName;

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

}

catch (_com_error e)

{

AfxMessageBox(e.Description());

}

}

_RecordsetPtr& ADO::OpenRecordset(CString sql)

{

ASSERT(!sql.IsEmpty());

try

{

m_pRecordset.CreateInstance(__uuidof(Recordset));

m_pRecordset->Open(_bstr_t(sql),m_pConnection.GetInterfacePtr(),

adOpenDynamic,adLockOptimistic,adCmdText);

}

catch (_com_error e)

{

AfxMessageBox(e.Description());

}

m_pRecordset->MoveFirst();

return m_pRecordset;

}

void ADO::CloseRecordset()

{

if (m_pRecordset->GetState()==adStateOpen)

{

m_pRecordset->Close();

}

}

void ADO::CloseConn()

{

m_pConnection->Close();

::CoUninitialize();

}

UINT ADO::GetRecordCount(_RecordsetPtr pRecordset)

{

int nCount=0;

try

{

pRecordset->MoveFirst();

}

catch (_com_error e)

{

AfxMessageBox(e.Description());

return 0;

}

if (pRecordset->ADOEof)

{

return 0;

}

while(!pRecordset->ADOEof)

{

pRecordset->MoveNext();

nCount++;

}

pRecordset->MoveFirst();

return nCount;

}

/***************************************stdafx.h**************************************************

//导入ADO库

#import "C:\Program Files\Common Files\System\ado\msado15.dll" no_namespace rename("EOF","ADOEof")

***************************************************************************************************/

/***************************************更改数据库**************************************************

ADO m_ado;

m_ado.OnInitADOConn("DATA_LINK.mdb","ACCESS");

CString sql=_T("select * from mp_net_port");

m_ado.m_pRecordset=m_ado.OpenRecordset(sql);

while(!m_ado.m_pRecordset->ADOEof)

{

m_ado.m_pRecordset->PutCollect("mp_port_ip","192.168.1.102");

m_ado.m_pRecordset->PutCollect("mp_port_enable",true);

m_ado.m_pRecordset->MoveNext();

}

m_ado.CloseRecordset();

***************************************************************************************************/

/***************************************读数据库**************************************************

ADO m_ado;

m_ado.OnInitADOConn("DATA_LINK.mdb","ACCESS");

CString sql=_T("select * from mp_net_port");

m_ado.m_pRecordset=m_ado.OpenRecordset(sql);

while(!m_ado.m_pRecordset->ADOEof)

{

CString str=(LPCTSTR)(_bstr_t)m_ado.m_pRecordset->GetCollect("mp_port_ip");

bool bl=(bool)m_ado.m_pRecordset->GetCollect("mp_port_enable");

m_ado.m_pRecordset->MoveNext();

}

m_ado.CloseRecordset();

***************************************************************************************************/

/***************************************添加数据库**************************************************

ADO m_ado;

m_ado.OnInitADOConn("DATA_LINK.mdb","ACCESS");

CString sql=_T("select * from mp_net_port");

m_ado.m_pRecordset=m_ado.OpenRecordset(sql);

while(!m_ado.m_pRecordset->ADOEof)

{

m_ado.m_pRecordset->AddNew();

m_ado.m_pRecordset->PutCollect("mp_port_ip","192.168.1.102");

m_ado.m_pRecordset->PutCollect("mp_port_enable",true);

m_ado.m_pRecordset->Update();

}

m_ado.CloseRecordset();

***************************************************************************************************/

/***************************************删除数据库**************************************************

ADO m_ado;

m_ado.OnInitADOConn("DATA_LINK.mdb","ACCESS");

CString sql=_T("select * from mp_net_port");

m_ado.m_pRecordset=m_ado.OpenRecordset(sql);

while(!m_ado.m_pRecordset->ADOEof)

{

m_ado.m_pRecordset->Move(0,vtMissing);

m_ado.m_pRecordset->Delete(adAffectCurrent);

m_ado.m_pRecordset->Update();

}

m_ado.CloseRecordset();

***************************************************************************************************/