分享
 
 
 

一个功能增强型用ADO访问数据库的类

王朝vc·作者佚名  2006-01-08
窄屏简体版  字體: |||超大  

大家好,前段时间本菜鸟发表了一篇用ADO访问数据库文章,得到许多VC高手的指点,我看了后,感触颇深,对原来的类继续完善,使用起来更加好用,这个类或许还存在

一些不足的地方,但愿VC高手不吝赐教.下面给出类的头文件,实现文件

-------头文件:-------------------------------------------------------------------

#ifndef _ADOEX_H_

#define _ADOEX_H_

#include "stdafx.h"

/* 注 stdafx.h 里要有下面两行 */

/* #include <comdef.h> */

/* #import "c:\program files\common files\system\ado\msado15.dll" no_namespace rename("EOF","adoEOF") */

/* AfxOleInit() ; ADO 初始化 */

#define MAX_FIELD_NUM 500 /*一个表里最大的字段数*/

class CAdoEx

{

public:

CAdoEx();

virtual ~CAdoEx();

/*打开 Ado 数据库*/

BOOL OpenAdo(LPCTSTR lpDSN ,LPCTSTR lpTable,LPCTSTR lpUID ,LPCTSTR lpPWD);

/*------------------------------------------*/

/* ADO 通用查询函数 */

/* 调用参数: 正确的SQL 查询语句. */

/* 可以对一个表查询,也可以对多个表查询 */

/* 返回一个纪录集 */

/* 特别强调可以调用存储过程,调用方法为: ProcedureName Param1,param2 */

/* 例如:调用的字符串为 "TestAdo 'luoshizhen1','1999-05-06'"

/* 如果成功返回一个非空的纪录集 */

/* 如果失败则返回一个NULL的纪录集 */

_RecordsetPtr Query(LPCTSTR lpQuery);

/*--------------------------------------------*/

/*--------------------------------------------*/

/*关闭数据库 */

BOOL CloseAdo();

/*--------------------------------------------*/

/*--------------------------------------------*/

/* ADO 通用SQL语句执行函数 */

/* 调用参数: 正确的SQL 查询语句. */

/* 可以对一个表插入 修改 删除 操作 */

/* 可以调用存储过程,调用方法为: ProcedureName Param1,param2 */

/* 例如:调用的字符串为 "TestAdo 'luoshizhen1','1999-05-06'" */

/* 如果成功返回真 */

/* 如果失败返回假 */

BOOL Execute(LPCTSTR lpExcute);

/*--------------------------------------------*/

public:

/*该函数对绑定的表进行插入一条纪录,调用方法: */

/*1 先调用OpenAdo() 成功 */

/*2 设置该类的成员变量 m_sFields --绑定表的字段总数 */

/*3 设置成员变量数组 m_sFieldName ,m_sFieldNumeric */

/* m_sFieldPrimary */

/* 最后把新纪录填充到 m_sFieldValue 数组调用AddReocrd() */

BOOL AddRecord();

/*该函数对绑定的表进行插入一条纪录,调用方法: */

/* 如果设置过 成员变量m_sFields,m_sFieldName */

/* m_sFieldPrimary,m_sFieldNumeric */

/* 把要修改的数据填充到 m_sFieldValue 数组,调用UpdateReocrd() */

BOOL UpdateRecord();

/*填充m_sFieldValue 数组,然后调用该函数即可 */

BOOL DeleteRecord();

/*调用参数 Where后面的条件即可 */

/*如果有符合条件的纪录则返回 TRUE */

/*没有符合条件的纪录或则发生异常都返回 FALSE */

BOOL SelectMatchRecord(CString& sWhere);

/*移动到符合条件的纪录的下一个纪录 */

/*移动成功返回 TRUE ,到达纪录尾则返回 FALSE */

BOOL SelectNextRecord();

int m_nFields ; /* 绑定表的字段总数 */

CString m_sFieldName[MAX_FIELD_NUM] ; /*字段名字数组 */

CString m_sFieldValue[MAX_FIELD_NUM] ; /*字段数值数组 */

BOOL m_bFieldNumeric[MAX_FIELD_NUM] ; /*该字段是否为数值类型*/

BOOL m_bFieldPrimary[MAX_FIELD_NUM] ; /*该字段是否为主键 */

protected:

BOOL GetFieldName();

_RecordsetPtr retRecordsetPtr;

_RecordsetPtr m_pFindRecord;

_ConnectionPtr m_pConnection;

CString ReplaceString(CString& sText);

CString m_sTable ; /* 要绑定表的名字*/

char lpBuff[500];

HRESULT hResult;

BOOL m_bOpen;

};

#endif

------- 实现文件:-------------------------------------------------------------------

/* 说明: 这是一个 Ado 类,可以实现用ADO对数据库操作 */

/* 1. 连接数据库 */

/* 2. 查询数据库的一个或关联表 */

/* 3. 执行SQL 语句插入 修改 删除 操作 */

/* 4. 关闭数据库 */

#include "stdafx.h"

#include "AdoEx.h"

#ifdef _DEBUG

#undef THIS_FILE

static char THIS_FILE[]=__FILE__;

#define new DEBUG_NEW

#endif

CAdoEx::CAdoEx()

{

m_bOpen = FALSE ;

/*初始化连接的实例*/

m_pConnection.CreateInstance(_uuidof(Connection)) ;

m_pFindRecord.CreateInstance(_uuidof(Recordset)) ;

m_nFields = 0 ;

}

CAdoEx::~CAdoEx()

{

if(retRecordsetPtr !=NULL)

retRecordsetPtr->Close() ;

retRecordsetPtr = NULL ;

CloseAdo() ;

m_bOpen = FALSE ;

}

/*打开 Ado 数据库*/

BOOL CAdoEx::OpenAdo(LPCTSTR lpDSN,LPCTSTR lpTable,LPCTSTR lpUID ,LPCTSTR lpPWD )

{

BOOL bRet = FALSE ;

if(m_bOpen) return TRUE ;

try

{

hResult = m_pConnection->Open(lpDSN,lpUID,lpPWD,0) ;

if (SUCCEEDED(hResult))

{

TRACE0("Open ADO Database Succeeded !\n") ;

m_bOpen = TRUE ;

bRet = TRUE ;

m_sTable = lpTable ;

}

else

{

m_bOpen = FALSE ;

bRet = FALSE ;

}

} /*end of try*/

catch(_com_error e )

{

memset(lpBuff,0x00,500) ;

sprintf(lpBuff,"打开数据库时发生异常 \n:%s",e.ErrorMessage());

AfxMessageBox(lpBuff) ;

}

return bRet ;

}

/* ADO 通用查询函数 */

/* 调用参数: 正确的SQL 查询语句. */

/* 可以对一个表查询,也可以对多个表查询 */

/* 返回一个纪录集 */

/* 可以调用存储过程,调用方法为: ProcedureName Param1,param2 */

/* 例如:调用的字符串为 "TestAdo 'luoshizhen1','1999-05-06'"

/* 如果成功返回一个非空的纪录集 */

/* 如果失败则返回一个NULL的纪录集 */

_RecordsetPtr CAdoEx::Query(LPCTSTR lpQuery)

{

retRecordsetPtr = NULL ;

_variant_t vRecsAffected ;

if(!m_bOpen) return NULL ;

try

{

retRecordsetPtr = m_pConnection->Execute(lpQuery,

&vRecsAffected,

adOptionUnspecified) ;

}

catch(_com_error e)

{

memset(lpBuff,0x00,500) ;

sprintf(lpBuff,"查询数据库表时发生异常 \n:%s",e.ErrorMessage());

AfxMessageBox(lpBuff) ;

}

return retRecordsetPtr ;

}

/* ADO 通用SQL语句执行函数 */

/* 调用参数: 正确的SQL 查询语句. */

/* 可以对一个表插入 修改 删除 操作 */

/* 可以调用存储过程,调用方法为: ProcedureName Param1,param2 */

/* 例如:调用的字符串为 "TestAdo 'luoshizhen1','1999-05-06'" */

/* 如果成功返回真 */

/* 如果失败返回假 */

BOOL CAdoEx::Execute(LPCTSTR lpExcute)

{

BOOL bRet = FALSE ;

_variant_t vRecsAffected ;

if(!m_bOpen) return FALSE ;

try

{

m_pConnection->Execute(lpExcute,

&vRecsAffected,

adOptionUnspecified) ;

bRet = TRUE ;

}

catch(_com_error e)

{

bRet = FALSE ;

memset(lpBuff,0x00,500) ;

sprintf(lpBuff,"更改数据库表时发生异常 \n:%s",e.ErrorMessage());

AfxMessageBox(lpBuff) ;

}

return bRet ;

}

BOOL CAdoEx::CloseAdo()

{

if (m_bOpen)

{

m_pConnection->Close() ;

TRACE0("Close ADO Connection !\n") ;

}

return TRUE ;

}

/*删除绑定表的一条纪录*/

/*填充m_sFieldValue 数组,然后调用该函数即可 */

BOOL CAdoEx::DeleteRecord()

{

CString lpDelete,Temp ;

_variant_t RecordAffect ;

if (m_sTable=="")

{

AfxMessageBox("表名为空,删除失败!") ;

return FALSE ;

}

if (m_sTable==0)

{

AfxMessageBox("绑定表的字段总数为0,删除失败!") ;

return FALSE ;

}

if(!m_bOpen)

{

AfxMessageBox("还没有连接数据库,删除失败!") ;

return FALSE ;

}

lpDelete.Format("Delete From %s Where ",m_sTable) ;

int ff = 0 ;

for(int i = 0 ;i<m_nFields;i++)

{

if(m_bFieldPrimary[i])

{

if(ff > 0)

lpDelete +=" AND " ;

ff ++ ;

if(m_bFieldNumeric[i])

Temp.Format("%s=%s",m_sFieldName[i],m_sFieldValue[i]) ;

else

Temp.Format("%s=%s",m_sFieldName[i],ReplaceString(m_sFieldValue[i])) ;

lpDelete += Temp ;

}

}

/*进行删除*/

try

{

m_pConnection->Execute((LPCTSTR)lpDelete,

&RecordAffect,

adOptionUnspecified) ;

}

catch (_com_error e)

{

memset(lpBuff,0x00,500) ;

sprintf(lpBuff,"删除绑定表时发生异常 \n:%s",e.ErrorMessage());

AfxMessageBox(lpBuff) ;

return FALSE ;

}

return TRUE ;

}

CString CAdoEx::ReplaceString(CString& sText)

{

CString sRet ;

CString cChar ;

for (int i = 0 ;i<sText.GetLength();i++)

{

cChar = sText.Mid(i,1) ;

if(cChar=="'")

cChar="''" ;

sRet += cChar ;

}

return CString("'" + sRet +"'") ;

}

/*向绑定的表增加一条纪录*/

/*该函数对绑定的表进行插入一条纪录,调用方法: */

/*1 先调用OpenAdo() 成功 */

/*2 设置该类的成员变量 m_sFields --绑定表的字段总数 */

/*3 设置成员变量数组 m_sFieldName ,m_sFieldNumeric */

/* m_sFieldPrimary */

/* 最后把新纪录填充到 m_sFieldValue 数组调用AddReocrd() */

BOOL CAdoEx::AddRecord()

{

CString lpInsert ,sTemp ;

_variant_t RecordAffect ;

if(!m_bOpen)

{

::MessageBox(NULL,"还没有连接数据库!\n插入失败!","提示",MB_ICONEXCLAMATION|MB_OK) ;

return FALSE ;

}

if(m_nFields == 0)

{

::MessageBox(NULL,"绑定表的字段总数没有设置!\n插入失败!","提示",MB_ICONEXCLAMATION|MB_OK) ;

return FALSE ;

}

lpInsert.Format("Insert Into %s(",m_sTable) ;

int ff = 0 ;

for(int i=0 ;i < m_nFields ;i++)

{

if(ff>0)

lpInsert += "," ;

ff ++ ;

lpInsert += m_sFieldName[i] ;

}

lpInsert +=") values(" ;

ff = 0 ;

for(i= 0 ;i<m_nFields ;i++)

{

if(ff>0)

lpInsert += "," ;

ff++ ;

if(m_bFieldNumeric[i])

sTemp.Format("%s",m_sFieldValue[i]) ;

else

sTemp.Format("%s",ReplaceString(m_sFieldValue[i])) ;

lpInsert += sTemp ;

}

lpInsert +=")" ;

/*向绑定的表插入一条纪录*/

try

{

m_pConnection->Execute((LPCTSTR)lpInsert,

&RecordAffect,

adOptionUnspecified ) ;

}

catch(_com_error e)

{

memset(lpBuff,0x00,500) ;

sprintf(lpBuff,"向绑定的表插入一条纪录时发生异常! 插入失败 \n:%s",e.ErrorMessage());

AfxMessageBox(lpBuff) ;

return FALSE ;

}

return TRUE ;

}

/*更新绑定的表一条纪录*/

BOOL CAdoEx::UpdateRecord()

{

CString lpUpdate,sTemp ;

_variant_t RecordAffect ;

if(!m_bOpen)

{

::MessageBox(NULL,"还没有连接数据库,修改失败!","提示",MB_ICONEXCLAMATION|MB_OK) ;

return FALSE ;

}

if(m_nFields == 0)

{

::MessageBox(NULL,"没有设定绑定表的字段总数,修改失败!","提示",MB_ICONEXCLAMATION|MB_OK) ;

return FALSE ;

}

lpUpdate.Format("Update %s Set ",m_sTable) ;

int ff= 0 ;

for(int i=0 ;i<m_nFields;i++)

{

if(!m_bFieldPrimary[i])

{

if(ff>0)

lpUpdate += "," ;

ff++ ;

if(m_bFieldNumeric[i])

sTemp.Format("%s=%s",m_sFieldName[i],m_sFieldValue[i]) ;

else

sTemp.Format("%s=%s",m_sFieldName[i],ReplaceString(m_sFieldValue[i])) ;

lpUpdate += sTemp ;

}

}

lpUpdate +=" Where " ;

ff = 0 ;

for( i=0 ;i<m_nFields ;i++)

{

if(m_bFieldPrimary[i])

{

if (ff>0)

lpUpdate += " AND " ;

ff++ ;

if(m_bFieldNumeric[i])

sTemp.Format("%s=%s",m_sFieldName[i],m_sFieldValue[i]) ;

else

sTemp.Format("%s=%s",m_sFieldName[i],ReplaceString(m_sFieldValue[i])) ;

lpUpdate +=sTemp ;

}

}

AfxMessageBox(lpUpdate) ;

/*进行更新绑定表的一条纪录*/

try

{

m_pConnection->Execute((LPCTSTR)lpUpdate,

&RecordAffect,

adOptionUnspecified) ;

}

catch(_com_error e)

{

memset(lpBuff,0x00,500) ;

sprintf(lpBuff,"更新定的表的一条纪录时发生异常! 更新失败 \n:%s",e.ErrorMessage());

AfxMessageBox(lpBuff) ;

return FALSE ;

}

return TRUE ;

}

/*查找绑定表符合条件的纪录 */

/*如果查询到纪录时,返回真 */

/*查询没有出错,但是没有符合条件的纪录,返回假*/

/*进行查询时出现异常,返回假 */

BOOL CAdoEx::SelectMatchRecord(CString &sWhere)

{

CString lpSelect , sTemp ;

_variant_t RecordAffect ;

_variant_t FindValue ;

if(!m_bOpen)

{

::MessageBox(NULL,"还没有连接数据库,查找失败!","提示",MB_ICONEXCLAMATION|MB_OK) ;

return FALSE ;

}

if(m_nFields==0)

{

::MessageBox(NULL,"没有指定绑定表字段的总数,查找失败!","提示",MB_ICONEXCLAMATION|MB_OK) ;

return FALSE ;

}

if(sWhere=="")

lpSelect.Format("Select * From %s",m_sTable) ;

else

lpSelect.Format("Select * From %s Where %s",m_sTable,sWhere) ;

AfxMessageBox(lpSelect) ;

/*进行查找纪录*/

try

{

m_pFindRecord = m_pConnection->Execute((LPCTSTR)lpSelect,

&RecordAffect ,

adOptionUnspecified ) ;

if(!m_pFindRecord->GetadoEOF())

{

for(int i =0 ;i<m_nFields;i++)

{

FindValue = m_pFindRecord->GetCollect(_variant_t(m_sFieldName[i])) ;

if(FindValue.vt != VT_NULL)

m_sFieldValue[i] = (char*)_bstr_t(FindValue) ;

else

m_sFieldValue[i] = "" ;

}

return TRUE ;

}

else /*纪录集没有数据*/

return FALSE ;

}

catch(_com_error e)

{

memset(lpBuff,0x00,500) ;

sprintf(lpBuff,"进行查找绑定表的一条纪录时发生异常! 进行查找失败 \n:%s",e.ErrorMessage());

AfxMessageBox(lpBuff) ;

return FALSE ;

}

}

/*查找下一个纪录,这函数必须调用SelectMatchRecord()函数之后调用 */

/* 返回真时,查找到一个符合条件的纪录 */

/* 返回假时,往往是纪录尾部了 */

BOOL CAdoEx::SelectNextRecord()

{

HRESULT hMoveNext ;

_variant_t NextValue ;

hMoveNext = m_pFindRecord->MoveNext() ;

if(SUCCEEDED(hMoveNext))

{

if(!m_pFindRecord->GetadoEOF())

{

for(int i=0 ; i<m_nFields ; i++)

{

NextValue = m_pFindRecord->GetCollect(_variant_t(m_sFieldName[i])) ;

if(NextValue.vt != VT_NULL)

m_sFieldValue[i] =(char*)_bstr_t(NextValue) ;

else

m_sFieldValue[i] = "" ;

}

return TRUE ;

}

else

return FALSE ;

}

else

return FALSE ;

}

/*表的所有字段*/

BOOL CAdoEx::GetFieldName()

{

_variant_t RecordAffect ;

LPSTR lpSelect ;

_RecordsetPtr m_Recordset ;

FieldPtr m_FieldPtr ;

if(!m_bOpen)

return FALSE ;

lpSelect = new char[100] ;

memset((char*)lpSelect,0x00,100) ;

sprintf(lpSelect,"Select * From %s",m_sTable) ;

m_Recordset = m_pConnection->Execute(lpSelect,

&RecordAffect,

adOptionUnspecified) ;

m_FieldPtr = m_Recordset->GetFields() ;

delete lpSelect ;

return TRUE ;

}

 
 
 
免责声明:本文为网络用户发布,其观点仅代表作者个人观点,与本站无关,本站仅提供信息存储服务。文中陈述内容未经本站证实,其真实性、完整性、及时性本站不作任何保证或承诺,请读者仅作参考,并请自行核实相关内容。
2023年上半年GDP全球前十五强
 百态   2023-10-24
美众议院议长启动对拜登的弹劾调查
 百态   2023-09-13
上海、济南、武汉等多地出现不明坠落物
 探索   2023-09-06
印度或要将国名改为“巴拉特”
 百态   2023-09-06
男子为女友送行,买票不登机被捕
 百态   2023-08-20
手机地震预警功能怎么开?
 干货   2023-08-06
女子4年卖2套房花700多万做美容:不但没变美脸,面部还出现变形
 百态   2023-08-04
住户一楼被水淹 还冲来8头猪
 百态   2023-07-31
女子体内爬出大量瓜子状活虫
 百态   2023-07-25
地球连续35年收到神秘规律性信号,网友:不要回答!
 探索   2023-07-21
全球镓价格本周大涨27%
 探索   2023-07-09
钱都流向了那些不缺钱的人,苦都留给了能吃苦的人
 探索   2023-07-02
倩女手游刀客魅者强控制(强混乱强眩晕强睡眠)和对应控制抗性的关系
 百态   2020-08-20
美国5月9日最新疫情:美国确诊人数突破131万
 百态   2020-05-09
荷兰政府宣布将集体辞职
 干货   2020-04-30
倩女幽魂手游师徒任务情义春秋猜成语答案逍遥观:鹏程万里
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案神机营:射石饮羽
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案昆仑山:拔刀相助
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案天工阁:鬼斧神工
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案丝路古道:单枪匹马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:与虎谋皮
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:李代桃僵
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案镇郊荒野:指鹿为马
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:小鸟依人
 干货   2019-11-12
倩女幽魂手游师徒任务情义春秋猜成语答案金陵:千金买邻
 干货   2019-11-12
 
推荐阅读
 
 
 
>>返回首頁<<
 
靜靜地坐在廢墟上,四周的荒凉一望無際,忽然覺得,淒涼也很美
© 2005- 王朝網路 版權所有