本文共 13850 字,大约阅读时间需要 46 分钟。
耗费了一下午,研究了一下VC的数据库编程,写了这个测试程序。主要的功能为实现access数据库的添加与删除,同时动态的将数据库数据显示在flexgrid控件中。下面把过程记录下来,以备后用。
一。ADO简介 ADO提供了一组非常简单,将一般通用的数据访问细节进行封装的对象。由于ODBC数据源也提供了一般的OLE DB Privider,所以ADO不仅可以应用自身的OLE DB Privider,而且还可以应用所有的ODBC驱动程序。关于OLE DB和ADO的其它详细情况,读者可以自行查阅相关书籍或MSDN,这里就不一一说明了。让我们直接步入主题,如何掌握ADO这种数据库访问技术ADO的操作方法和前面讲过的DAO的操作在很多方面存在相似之处。二。主要控件的布置程序运行效果如图:1.进入工程向导,建立基于对话框的mfc应用程序。名为databasetest。加入flexgrid控件:工程--->添加到工程------->components and controls。找到Microsoft Flexgrid control,然后insert。添加几个static box 和editbox,添加两个botton,实现插入和删除的功能。2.打开access2003,建立空数据库Demo.mdb。建立表Table1。设置编号,时间,采样点数,累加次数,数据5个字段,分别为自动编号,时间/日期,数字,数字和备注类型如图:三。数据库操作过程1.用#import指令引入ADO类型库要用#import语句来引用支持ADO的组件类型库(*.tlb),其中类型库可以作为可执行程序(DLL、EXE等)的一部分被定位在其自身程序中的附属资源里,如:被定位在msado15.dll的附属资源中,只需要直接用 #import引用它既可。可以直接在Stdafx.h文件中加入下面语句来实现:#import "c:/program files/common files/system/ado/msado15.dll" /no_namespace /rename ("EOF", "adoEOF") |
// ClassWizard generated virtual function overrides //{ {AFX_VIRTUAL(CDatabasetestDlg)
4.这样就可以数据库的实际操作了。首先在主应用程序databasetext.cpp中。主对话框弹出之前添加代码,创建一个实例指针,再用Open打开一个库连接,它将返回一个IUnknown的自动化接口指针。
m_pConnection.CreateInstance(__uuidof(Connection));// 在ADO操作中建议语句中要常用try...catch()来捕获错误信息,
// 因为它有时会经常出现一些想不到的错误。jingzhou xu try { // 打开本地Access库Demo.mdb m_pConnection->Open("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=Demo.mdb","","",adModeUnknown); } catch(_com_error e) { AfxMessageBox(e.ErrorMessage()); }注:ConnectionPtr智能指针,通常用于打开、关闭一个库连接或用它的Execute方法来执行一个不返回结果的命令语句(用法和_CommandPtr中的Execute方法类似)。5.在databasetestDlg.cpp的前面加入://引用应用类extern CDatabasetestApp theApp;在::OnInitDialog()加入代码:// 使用ADO创建数据库记录集 m_pRecordset.CreateInstance(__uuidof(Recordset));
// 在ADO操作中建议语句中要常用try...catch()来捕获错误信息, // 因为它有时会经常出现一些想不到的错误。jingzhou xu try { m_pRecordset->CursorLocation = adUseClient; m_pRecordset->Open("SELECT * FROM Table1", // 查询DemoTable表中所有字段 theApp.m_pConnection.GetInterfacePtr(), // 获取库接库的IDispatch指针 adOpenDynamic, adLockOptimistic, adCmdText); } catch(_com_error *e) { AfxMessageBox(e->ErrorMessage()); }
//显示在GRID控件中 CString HeadStr = _T("编号 | 时间 | 采样点数 | 累加次数 |采样数据");//设置grid控件标题 m_DataGrid.SetFormatString(HeadStr); m_DataGrid.SetCols(5);//设置列数 long RecordNum = m_pRecordset->GetRecordCount();//得到记录数 m_DataGrid.SetRows(RecordNum + 1);//设置行数=记录数+标题行(1行)
m_DataGrid.SetCellAlignment(6);//对齐方式flexAlignRightTop CRect rect; m_DataGrid.GetWindowRect(&rect);
m_DataGrid.SetColWidth(0, rect.Width()*2); //设置列宽,开始时用除法但是实际列宽非常小。后用了乘法。为什么用乘法,我还是没弄明白 m_DataGrid.SetColWidth(1, rect.Width()*4); m_DataGrid.SetColWidth(2, rect.Width()*2); m_DataGrid.SetColWidth(3, rect.Width()*2); m_DataGrid.SetColWidth(4, rect.Width()*2);
m_pRecordset->MoveFirst()//移动记录游标到第一条记录
for(long CurRow = 1; CurRow <= RecordNum ; CurRow++)//初始化grid控件显示。本想用两重循环,但是没有找以index为形参的SetText函数。 { CString str; int CurCol = 0; _variant_t vstr; m_DataGrid.SetRow(CurRow);
m_DataGrid.SetCol(CurCol); vstr = m_pRecordset->GetCollect("编号"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);
m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("时间"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);
m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("采样点数"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);
m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("累加次数"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);/* m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("数据"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);*/ m_pRecordset->MoveNext();
}
SetTimer(1, 1000, NULL);//设置定时器,实现时间编辑框的实时显示。6.添加DestroyWindow消息函数。实现退出程序的数据库连接注销。BOOL CDatabasetestDlg::DestroyWindow() { // TODO: Add your specialized code here and/or call the base class // 关闭记录集 if(m_pRecordset->State) m_pRecordset->Close(); m_pRecordset = NULL; return CDialog::DestroyWindow();}7.加入插入按钮单击函数:UpdateData(TRUE); if((m_SamplingTime == _T("")) || (m_SamplingNum == 0) || (m_AccNum == 0)) { AfxMessageBox("请输入参数!"); } else { // 在ADO操作中建议语句中要常用try...catch()来捕获错误信息, // 因为它有时会经常出现一些想不到的错误。jingzhou xu try { // 写入各字段值// m_pRecordset->MoveLast(); m_pRecordset->AddNew(); m_pRecordset->PutCollect("时间", _variant_t(m_SamplingTime)); m_pRecordset->PutCollect("采样点数", _variant_t((long)m_SamplingNum)); m_pRecordset->PutCollect("累加次数", _variant_t((long)m_AccNum)); m_pRecordset->Update();
// AfxMessageBox("插入成功!");
} catch(_com_error *e) { AfxMessageBox(e->ErrorMessage()); }
long RecordNum = m_pRecordset->GetRecordCount(); m_DataGrid.SetRows(RecordNum + 1);//设置行数 m_pRecordset->MoveFirst();
for(long CurRow = 1; CurRow <= RecordNum ; CurRow++) { CString str; int CurCol = 0; _variant_t vstr; m_DataGrid.SetRow(CurRow);
m_DataGrid.SetCol(CurCol); vstr = m_pRecordset->GetCollect("编号"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);
m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("时间"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);
m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("采样点数"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);
m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("累加次数"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);/* m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("数据"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);*/ m_pRecordset->MoveNext();
} m_DataGrid.Refresh();
}8.加入删除按钮单击函数m_pRecordset->MoveFirst(); if(m_pRecordset->adoEOF && m_pRecordset->BOF) { AfxMessageBox("数据库中没有数据!"); } else { try { // 删除当前行记录 m_pRecordset->Delete(adAffectCurrent); m_pRecordset->Update();
} catch(_com_error *e) { AfxMessageBox(e->ErrorMessage()); } }
long RecordNum = m_pRecordset->GetRecordCount(); m_DataGrid.SetRows(RecordNum + 1);//设置行数 m_pRecordset->MoveFirst();
for(long CurRow = 1; CurRow <= RecordNum ; CurRow++) { CString str; int CurCol = 0; _variant_t vstr; m_DataGrid.SetRow(CurRow);
m_DataGrid.SetCol(CurCol); vstr = m_pRecordset->GetCollect("编号"); str = (LPCSTR)_bstr_t(vstr);//_variant_t 到cstring转化 m_DataGrid.SetText(str);
m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("时间"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);
m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("采样点数"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);
m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("累加次数"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);/* m_DataGrid.SetCol(++CurCol); vstr = m_pRecordset->GetCollect("数据"); str = (LPCSTR)_bstr_t(vstr); m_DataGrid.SetText(str);*/ m_pRecordset->MoveNext();
} m_DataGrid.Refresh(); 9.加入timer函数void CDatabasetestDlg::OnTimer(UINT nIDEvent) { // TODO: Add your message handler code here and/or call default CTime Time = CTime::GetCurrentTime();//得到系统时间 CString m_CurTime = Time.Format("%Y-%m-%d %H:%M:%S");//格式化时间格式。形如:2009-5-29 20:34:45 m_CSamplingTime.SetWindowText(m_CurTime); CDialog::OnTimer(nIDEvent);}
好了,编译一下。就可以看到实际的效果了。附:
1、_variant_t(1)、一般传给这3个指针的值都不是MFC直接支持的数据类型,而要用_variant_t转换一下_variant_t(XX)可以把大多数类型的变量转换成适合的类型传入:(2)、_variant_t var;_variant_t -> long: (long)var;_variant_t -> CString: CString strValue = (LPCSTR)_bstr_t(var);CString -> _variant_t: _variant_t(strSql);2、BSTR宽字符串与CString相互转换BSTR bstr;
CString strSql;CString -> BSTR: bstr = strSql.AllocSysString();BSTR -> CString: strSql = (LPCSTR)bstr;3、_bstr_t与CString相互转换_bstr_t bstr;
CString strSql;CString -> _bstr_t: bstr = (_bstr_t)strSql;_bstr_t -> CString: strSql = (LPCSTR)bstr;4、关于时间Access:表示时间的字符串#2004-4-5#Sql:表示时间的字符串''2004-4-5''DateField(时间字段) select * from my_table where DateField > #2004-4-10#
try
{ m_pCommand->CommandText = "INSERT INTO tTest(age) VALUES('23f2') ";m_pRecordset = m_pCommand->Execute(NULL,NULL, adCmdText); }catch(_com_error e)///捕捉异常{ CString errormessage;errormessage.Format("连接数据库失败!/r/n错误信息:%s",e.ErrorMessage());AfxMessageBox(errormessage);///显示错误信息}最后转一篇参考文献:ADO提供了一组非常简单,将一般通用的数据访问细节进行封装的对象。由于ODBC数据源也提供了一般的OLE DB Privider,所以ADO不仅可以应用自身的OLE DB Privider,而且还可以应用所有的ODBC驱动程序。关于OLE DB和ADO的其它详细情况,读者可以自行查阅相关书籍或MSDN,这里就不一一说明了。让我们直接步入主题,如何掌握ADO这种数据库访问技术ADO的操作方法和前面讲过的DAO的操作在很多方面存在相似之处,在这里,笔者为了更有效的说明它的使用方法,用VC6.0做了一个示例程序(AdoRWAccess),这个示例程序可以直接通过ADO来操作Access数据库,示例程序的运行效果如下图所示: 在示例程序中我们仍采用原库结构,数据库名Demo.mdb,库内表名DemoTable,表内字段名为Name(姓名)和Age(年龄)的两个字段,来构造示例程序操作所需的Access数据库,这也和上两篇文章的示例源码中的库结构相兼容。下面让我们看看ADO数据库访问技术使用的基本步骤及方法: 首先,要用#import语句来引用支持ADO的组件类型库(*.tlb),其中类型库可以作为可执行程序(DLL、EXE等)的一部分被定位在其自身程序中的附属资源里,如:被定位在msado15.dll的附属资源中,只需要直接用 #import引用它既可。可以直接在Stdafx.h文件中加入下面语句来实现:#import "c:/program files/common files/system/ado/msado15.dll" /no_namespace /rename ("EOF", "adoEOF") |
_ConnectionPtr m_pConnection; // 初始化COM,创建ADO连接等操作AfxOleInit();m_pConnection.CreateInstance(__uuidof(Connection));// 在ADO操作中建议语句中要常用try...catch()来捕获错误信息,// 因为它有时会经常出现一些意想不到的错误。jingzhou xutry { // 打开本地Access库Demo.mdbm_pConnection->Open("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=Demo.mdb","","",adModeUnknown);}catch(_com_error e){ AfxMessageBox("数据库连接失败,确认数据库Demo.mdb是否在当前路径下!");return FALSE;} |
if(m_pConnection->State)m_pConnection->Close();m_pConnection= NULL; |
打开数据表 打开库内表名为DemoTable的数据表,代码如下:
_RecordsetPtr m_pRecordset;m_pRecordset.CreateInstance(__uuidof(Recordset));// 在ADO操作中建议语句中要常用try...catch()来捕获错误信息,// 因为它有时会经常出现一些意想不到的错误。jingzhou xutry{ m_pRecordset->Open("SELECT * FROM DemoTable", // 查询DemoTable表中所有字段theApp.m_pConnection.GetInterfacePtr(), // 获取库接库的IDispatch指针adOpenDynamic,adLockOptimistic,adCmdText);}catch(_com_error *e){ AfxMessageBox(e->ErrorMessage());} |
try{ // 写入各字段值m_pRecordset->AddNew();m_pRecordset->PutCollect("Name", _variant_t(m_Name));m_pRecordset->PutCollect("Age", atol(m_Age));m_pRecordset->Update();AfxMessageBox("插入成功!");}catch(_com_error *e){ AfxMessageBox(e->ErrorMessage());} |
try{ int curSel = m_AccessList.GetCurSel(); // 先将指针移向第一条记录,然后就可以相对第一条记录来随意移动记录指针m_pRecordset->MoveFirst();m_pRecordset->Move(long(curSel));}catch(_com_error *e){ AfxMessageBox(e->ErrorMessage());} |
try{ // 假设对第二条记录进行修改m_pRecordset->MoveFirst();m_pRecordset->Move(1); // 从0开始m_pRecordset->PutCollect("Name", _variant_t(m_Name));m_pRecordset->PutCollect("Age", atol(m_Age));m_pRecordset->Update();}catch(_com_error *e){ AfxMessageBox(e->ErrorMessage());} |
try{ // 假设删除第二条记录m_pRecordset->MoveFirst();m_pRecordset->Move(1); // 从0开始m_pRecordset->Delete(adAffectCurrent); // 参数adAffectCurrent为删除当前记录m_pRecordset->Update();}catch(_com_error *e){ AfxMessageBox(e->ErrorMessage());} |
m_pRecordset->Close();m_pRecordset = NULL; |
_CommandPtr m_pCommand;m_pCommand.CreateInstance(__uuidof(Command));m_pCommand->ActiveConnection = m_pConnection; // 将库连接赋于它m_pCommand->CommandText = "SELECT * FROM DemoTable"; // SQL语句m_pRecordset = m_pCommand->Execute(NULL, NULL,adCmdText); // 执行SQL语句,返回记录集 |
_CommandPtr m_pCommand;m_pCommand.CreateInstance(__uuidof(Command));m_pCommand->ActiveConnection = m_pConnection; // 将库连接赋于它m_pCommand->CommandText = "Demo"; m_pCommand->Execute(NULL,NULL, adCmdStoredProc); |
转载地址:http://wdsqi.baihongyu.com/