一、实现方法
万事开头难,任何一种新技术对于初学者来说最重要的还是"入门",掌握其要点。让我们来看看ADO数据库开发的基本流程吧!它的基本步骤如下:
(1)初始化COM库,引入ADO库定义文件
(2)用Connection对象连接数据库
(3)利用建立好的连接,通过Connection、Command对象执行SQL命令,或利用Recordset对象取得结果记录集进行查询、处理。
(4)使用完毕后关闭连接释放对象。
下面我们将详细介绍上述步骤并给出相关代码。
1、COM库的初始化
我们可以使用AfxOleInit()来初始化COM库,这项工作通常在CWinApp::InitInstance()的重载函数中完成,请看如下代码:
BOOLCADOTest1App::InitInstance()
{
AfxOleInit();
。。。。。。
}
2、用#import指令引入ADO类型库
为了引入ADO类型库,需要在项目的stdafx。h文件中加入如下语句:
#import"c:\programfiles\commonfiles\system\ado\msado15。dll"
no_namespacerename("EOF","adoEOF")
这一语句有何作用呢?其最终作用同我们已经十分熟悉的#include类似,编译的时候系统会为我们生成msado15。tlh,ado15。tli两个C++头文件来定义ADO库。
需要读者朋友注意的是:您的开发环境中msado15。dll不一定在这个目录下,请按实际情况修改;在编译的时候可能会出现如下警告,对此微软在MSDN中作了说明,并建议我们不要理会这个警告:msado15。tlh(405):warningC4146:unaryminusoperatorappliedtounsignedtype,resultstillunsigned。
3、创建Connection对象并连接数据库
为了首先我们需要添加一个指向Connection对象的指针_ConnectionPtrm_pConnection,下面的代码演示了如何创建Connection对象实例及如何连接数据库并进行异常捕捉:
BOOLCADOTest1Dlg::OnInitDialog()
{
CDialog::OnInitDialog();
HRESULThr;
try
{
hr=m_pConnection。CreateInstance("ADODB。Connection");///创建Connection对象
if(SUCCEEDED(hr))
{
hr=m_pConnection->Open("Provider=Microsoft。Jet。OLEDB。4。0;
DataSource=test。mdb","","",adModeUnknown);///连接数据库
//上面一句中连接字串中的Provider是针对ACCESS2000环境的,对于ACCESS97,
//需要改为:Provider=Microsoft。Jet。OLEDB。3。51;
}
}
catch(_com_errore)///捕捉异常
{
CStringerrormessage;
errormessage。Format("连接数据库失败!\r\n错误信息:%s",e。ErrorMessage());
AfxMessageBox(errormessage);///显示错误信息
}
在这段代码中我们是通过Connection对象的Open方法来进行连接数据库的,下面是该方法的原型:
HRESULTConnection15::Open(_bstr_tConnectionString,_bstr_tUserID,_bstr_tPassword,longOptions);
上述函数中参数ConnectionString为连接字串;参数UserID是用户名;参数Password是登陆密码;参数Options是连接选项,用于指定Connection对象对数据的更新许可权,一般情况下Options可以是如下几个常量:
adModeUnknown:缺省。当前的许可权未设置
以下VC++6.0下调试通过//获取主程序所在路径,存在sPath中
CString sPath
GetModuleFileName(NULL,sPath.GetBufferSetLength (MAX_PATH+1),MAX_PATH)
sPath.ReleaseBuffer ()
int nPos
nPos=sPath.ReverseFind ( '\\ ')
sPath=sPath.Left (nPos)
//默认创建数据名:
CString lpszFile = sPath + "\\PID_y.mdb "
CFileFind fFind
BOOL bSuccess
bSuccess=fFind.FindFile(lpszFile)
fFind.Close ()
//是否已有创建好的PID_y.mdb文件,没有则创建它
if(!bSuccess)
{
db.Create(lpszFile)
//创建PasswordTable 表存储唯一值的表
CString SqlCmd = "CREATE TABLE PasswordTable(Password VARCHAR(20),K VARCHAR(10),T VARCHAR(10),D VARCHAR(10),Tim VARCHAR(10),Matier VARCHAR(10),WaterSpeed VARCHAR(10),InWater VARCHAR(10),OutWater VARCHAR(10),cctim VARCHAR(10),b_setwatar VARCHAR(10),b_matier VARCHAR(10),b_waterspeed VARCHAR(10))"
db.Execute(SqlCmd)
//创建WaterSetTable
SqlCmd= "CREATE TABLE Main(DT VARCHAR(20),Matier VARCHAR(20),WaterSet VARCHAR(20),WaterSpeed VARCHAR(20))"
db.Execute(SqlCmd)
SqlCmd= "CREATE TABLE Warning(Matier_up VARCHAR(20),Matier_down VARCHAR(20),WaterSet_percent VARCHAR(20),WaterSpeed_up VARCHAR(20),WaterSpeed_down VARCHAR(20))"
db.Execute(SqlCmd)
//打开已创建的数据表
RecSet.Open(AFX_DAO_USE_DEFAULT_TYPE,
"SELECT * FROM PasswordTable ", 0)
//加入第一个记录,用SQL语句
db.Execute( "INSERT INTO PasswordTable (Password,K,T,D,Tim,Matier,WaterSpeed,InWater,OutWater,cctim,b_setwatar,b_matier,b_waterspeed) VALUES ( 'yyy ',26,10,1,1,10,10,1,1,10,0,0,0) ")
RecSet.Close()
RecSet.Open(AFX_DAO_USE_DEFAULT_TYPE,
"SELECT * FROM Warning ", 0)
//加入第一个记录,用SQL语句
db.Execute( "INSERT INTO Warning (Matier_up,Matier_down,WaterSet_percent,WaterSpeed_up,WaterSpeed_down) VALUES (10,10,50,10,10) ")
//关闭记录集及库
RecSet.Close()
db.Close()
AfxMessageBox( "数据库创建成功、初始化密码为yyy! ")
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)