怎么在VC++中用ADO创建数据库

VC++中使用ADO方式 *** 作ACCESS数据库是Microsoft数据库应用程序开发的新接口，是建立在OLEDB之上的高层数据库访问技术，即使你对OLEDB，COM不了解也能轻松对付ADO，因为它非常简单易用，甚至比你以往所接触的ODBCAPI、DAO、RDO都要容易使用，并不失灵活性。本文详细地介绍在VisualC++开发环境下如何使用ADO来进行数据库应用程序开发，并给出示例代码。为了使读者朋友都能测试本例提供的代码，我们采用Access数据库，您可以直接在我们提供的示例代码中找到这个test。mdb。程序编译运行后的效果一所示：

一、实现方法

万事开头难，任何一种新技术对于初学者来说最重要的还是"入门"，掌握其要点。让我们来看看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：缺省。当前的许可权未设置

用Dao就可以：

包含头文件#include"afxdao.h"

然后用如下代码：

CDaoDatabase m_DaoDB

try

{

m_DaoDB.Create(_T("MsgInfo.mdb"))//创建mdb文件

}

catch(CDaoException* e)

{

CString strMsg

strMsg.Format(_T(" 创建数据库失败！ 原因：%s (%d)\n\n"),

(LPCTSTR)e->m_pErrorInfo->m_strDescription,

e->m_pErrorInfo->m_lErrorCode)

AfxMessageBox(strMsg,MB_OK|MB_ICONSTOP)

return false

}

CDaoTableDef m_DaoDef(&m_DaoDB)

m_DaoDef.Create(_T("工资信息"))//在刚刚创建的mdb文件中创建一个数据表

//创建字段

m_DaoDef.CreateField(_T("工号"),dbText,36,dbVariableField)

m_DaoDef.CreateField(_T("姓名"),dbText,38,dbVariableField)

m_DaoDef.CreateField(_T("工资"),dbBoolean,1,dbUpdatableField)

m_DaoDef.Append()

m_DaoDef.Close()

m_DaoDB.Close()

1）打开VC6.0 工具栏Tools菜单下的Options选项，在Directories的标签页中右边的“Show directories for:”下拉列表中选中“Includefiles”，然后在中间列表框中添加你本地安装MySQL的include目录路径。（我的是D:\Program Files\MySQL\MySQL Server 5.0\include）。 （2）在上面说到的“Show directories for:”下拉列表中选中“Library files”，然后添加你本地安装MySQL的Lib目录路径。Lib目录下还有debug和opt两个目录，建议选debug。（我的是D:\Program Files\MySQL\MySQL Server 5.0\lib\debug）。（3）在“Project settings->Link:Object/library modules”里面添加“libmysql.lib”。（4）在stdafx.h里面添加如下的内容：#include "mysql.h"

#include "winsock.h" // 如果编译出错,则把该行放到#include "mysql.h"之前

#pragma comment(lib,"libmySQL.lib") // 如果在附加依赖项里已增加,则就不要添加了 （5）建议将“libmySQL.lib、libmySQL.dll”拷到你所建的工程的目录下。 MYSQL mysql//数据库连接句柄

mysql_init (&mysql)

if(!mysql_real_connect(&mysql,"localhost","root",NULL,"mydb",3306,NULL,0)) {//mydb为你所创建的数据库，3306为端口号，可自行设定

AfxMessageBox("数据库连接失败")

return FALSE

} （1）实现添加 功能CString strUsername,strList,strRemark,strSQL

strSQL.Format("insert into mytable(username,visitelist,remark) values(\'%s\',\'%s\',\'%s\')", strUsername,strList,strRemark)//注意一定要写在一行，而且必须要有\'\'

if(mysql_real_query(&mysql,(char*)(LPCTSTR)strSQL,(UINT)strSQL.GetLength())!=0){

AfxMessageBox("增添失败")

}

（2）实现修改功能 CString strUsername,strList,strRemark,strSQL,str_PreName//str_PreName用于记录想要修改的行，详情请看源代码

strSQL.Format("update mytable set username=\'%s\',visitelist=\'%s\', remark=\'%s\' where username=\'%s\'",strUsername,strList,strRemark,str_PreName)

if(mysql_real_query(&mysql,(char*)(LPCTSTR)strSQL,(UINT)strSQL.GetLength())!=0){

AfxMessageBox("修改失败")

} （3）实现删除功能CString strSQL

strSQL.Format("delete from mytable where username=\'%s\'",str_PreName)//必须要有\'\'

if(mysql_real_query(&mysql,(char*)(LPCTSTR)strSQL,(UINT)strSQL.GetLength())!=0){

AfxMessageBox("删除失败")

} （4）读取表格内容到CListCtrl控件m_listm_list.DeleteAllItems()

char *ch_query

ch_query="select * from mytable"

if(mysql_real_query(&mysql,ch_query,(UINT)strlen(ch_query))!=0){

AfxMessageBox("数据库中表格出错")

}

CString str

MYSQL_RES *result

MYSQL_ROW row

if(!(result=mysql_use_result(&mysql))){

AfxMessageBox("读取数据集失败")

}

int i=0

while(row=mysql_fetch_row(result)){

str.Format("%s",row[0])

m_list.InsertItem(i,str)

str.Format("%s",row[1])

m_list.SetItemText(i,1,str)

str.Format("%s",row[2])

m_list.SetItemText(i,2,str)

i++

}

mysql_free_result(result)（5）关闭数据库mysql_close(&mysql)//最好写到OnDestroy()函数中

---