MFC ADO 数据库连接.doc

《MFC ADO 数据库连接.doc》由会员分享，可在线阅读，更多相关《MFC ADO 数据库连接.doc（12页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、初始化COM库民邮电出版社 明日科技 出版的Visual C+ 管理信息系统完整项目实例剖析，该书只讲了一个系统，完整剖析了该管理信息系统。在工程的App类的InitInstance ( )函数里面加上AfxOleInit ( );/MFC用法C+的常规方法是-:CoInitialize(NULL);.:CoUninitialize();3)使用记录集对象得到一个纪录集的基本步骤 /生成一个Connection对象，并连结上数据库_ConnectionPtr m_pConnection; HRESULT hr;tryhr=m_pConnection.CreateInstance(_uuidof

2、(Connection);if(SUCCEEDED(hr)m_pConnection-Open(Provider=Microsoft.Jet.OLEDB.4.0;Data Source=小学.mdb,adModeUnknown);catch(_com_error e)CString errormessage;errormessage.Format(连接数据库失败!rn错误信息:%s,e.ErrorMessage();AfxMessageBox(errormessage);/生成RecordSet对象，并得到纪录集_RecordsetPtr m_pRecordset;m_pRecordset.C

3、reateInstance(ADODB.Recordset);CString temp=SELECT * FROM +tablename;/tablename假设是一个CString类型的表名_variant_t sql;sql.SetString(temp);m_pRecordset-Open(sql, m_pConnection.GetInterfacePtr( ), adOpenDynamic,adLockOptimistic,adCmdText );4）动态查询CString tablename;tablename=_T(学籍);CString temp=_T(SELECT * FRO

4、M )+tablename+_T( WHERE NAME=)+dlg.m_name+_T();_variant_t sql;sql.SetString(temp);m_pRecordset-Open(sql,m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);5)遍历纪录集int line=0;while(!m_pRecordset-adoEOF)/遍历记录集，并将所有纪录显示在列表视图中。line+;m_pRecordset-MoveNext();其余操作都很简单，可以参见其他文章，最关键的是，不

5、要忘了关闭纪录集，因为这通常会造成异常6）使用ADO连接不同的数据库的方式：根据不同的数据提供者可以分为ODBC和OLEDB等若干种方式，ODBC兼容性更好，支持OLEDB的数据库相对少一点；连接SQL Server数据库：1） Microsoft OLE DB Provider for ODBCm_pConnection-Open(“Provider=SQLOLEDB.1;DRIVER=SQLServer;SERVER=lzhm;DATABASE=haitang”,sa,sa,adModeUnknown);2）未知方法，但是可行，注意Initial Catalog用空格分开m_pConnec

6、tion-Open(“Provider=SQLOLEDB.1;Data Source=lzhm;Initial Catalog=haitang”,sa,sa,adModeUnknown);m_pConnection-Open (Provider=SQLOLEDB;Data Source=172.20.2.97;Network Library=DBMSSOCN;Initial Catalog=haitang,”sa”,”sa”,adModeUnknown);m_pConnection-Open (Provider=SQLOLEDB;Network Address=172.20.2.97;Init

7、ial Catalog=haitang,”sa”,”sa”,adModeUnknown);m_pConnection-Open (Provider=SQLOLEDB;Network Address=172.20.2.97; Network Library=DBMSSOCN;Initial Catalog=haitang,”sa”,”sa”,adModeUnknown);3）Microsoft OLE DB Provider for SQL Serverm_pConnection-Open(“Provider=SQLOLEDB.1;Data Source=lzhm;Initial Catalog

8、=haitang”,sa,sa,adModeUnknown);4）不使用DSN进行连接m_pConnection-Open(driver=SQL Server;server=lzhm;database=haitang”,sa,sa,adModeUnknown);连接ACCESS 2000数据库的方式：m_pConnection-Open(Provider=Microsoft.Jet.OLEDB.4.0;Data Source=小学.mdb,adModeUnknown);连接ACCESS 97数据库的方式：m_pConnection-Open(Provider=Microsoft.Jet.OLE

9、DB.3.51;Data Source=小学.mdb,adModeUnknown);7)一个常用的函数，传递一句SQL语句，然后打开一个记录集，假设记录集对象m_pRecordset存在：BOOL CHaiTangView:GetRecordSet(CString sql)/如果生成的记录集不为空，就返回TRUEif(m_pRecordset-GetState()=1)/如果记录集对象已经打开，则先关闭m_pRecordset-Close();HRESULT hr;_variant_t v_sql;v_sql.SetString(sql);tryhr=m_pRecordset-Open(v_s

10、ql,m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText); if(SUCCEEDED(hr)catch(_com_error e)CString errormessage;errormessage.Format(查询数据表失败!rn错误信息:%s,e.ErrorMessage();AfxMessageBox(errormessage);return 0;m_pRecordset-MoveFirst();if(!m_pRecordset-adoEOF)/用SUCCEEDED(hr)无法判断记录集的生成

11、是否为空 /所以要用生成后的纪录集的最大纪录数是否为0来判别return TRUE; /SUCCEEDED(hr)应该是来判别异常的,纪录集为空不属于异常else MessageBox(对不起，找不到符合条件的纪录，请联系系统管理员);return FALSE;8）调用Recordset:PutCollect出现的问题：select 岸线属性表.序号,s1.NAME,岸线属性表.岸线性质,岸线属性表.起点桩号,岸线属性表.终点桩号,岸线属性表.岸线长度,岸线属性表.堤顶高程,岸线属性表.结构形式小类,岸线属性表.结构形式大类,岸线属性表.达标标准,岸线属性表.地域位置,岸线属性表.备注 fro

12、m 岸线属性表,数据字典表 AS s1 where s1.ID=岸线属性表.岸线名 ORDER BY 岸线属性表.序号select * from 海塘绿化表 ORDER BY 序号select 岸线属性表.序号,s1.NAME,s2.NAME from 岸线属性表,数据字典表 AS s1,数据字典表 AS s2 where s1.ID=岸线属性表.岸线名 AND s2.ID=岸线属性表.责任单位 ORDER BY 岸线属性表.序号在海塘开发的过程中，发现如果使用了RecordSet:Open的方法调用SQL语句打开记录集，如果SQL语句中使用了ORDER BY语句，在使用Recordset:P

13、utCollect方法将数据写入就会出错，至少这是使用VC、ADO和SQL Server7.0或者2000的情况。9）调用存储过程，在ATL里面的存储过程STDMETHODIMP CFBGET:GetDataByProc(BSTR bstrProcName, BSTR bstrParam, BSTR* plPower)/ TODO: Add your implementation code here*plPower = NULL;USES_CONVERSION;/建立和数据库的连接_ConnectionPtr m_pCon;m_pCon.CreateInstance(_uuidof(Conne

14、ction);char array200;GetWindowsDirectory(array,200);strcat(array,FB_DATA.INI);char servername100;GetPrivateProfileString(ServerName,NAME,servername,100,array);char str_con1024;wsprintf(str_con,Provider=SQLOLEDB.1;Data Source=%s;Initial Catalog=haitang;User ID=haitang;PWD=haitang,servername);m_pCon-O

15、pen(str_con,adModeUnknown);/建立命令对象_CommandPtr m_pCommand;m_pCommand.CreateInstance(ADODB.Command);m_pCommand-ActiveConnection = m_pCon;_variant_t name=proc_user;BSTR bname=SysAllocString(OLESTR(proc_user); m_pCommand-CommandText=bname;m_pCommand-CommandType=adCmdStoredProc;/将参数转换成char*类型,提取出两个char*参

16、数char *p=W2A(bstrParam);char* temp=p;char* p1=temp;while(*temp!=T)temp+;*temp=0;temp+;char* p2=temp;while(*temp!=T)temp+;*temp=0;/将两个参数转换成BSTR类型BSTR bstrP1=A2W(p1);BSTR bstrP2=A2W(p2);/建立参数对象1_ParameterPtr p_Param1;p_Param1.CreateInstance(ADODB.Parameter);p_Param1-Name=name;p_Param1-Type=adVarChar;p

17、_Param1-Size=50;p_Param1-Direction=adParamInput;p_Param1-Value=bstrP1;m_pCommand-Parameters-Append(p_Param1);/建立参数对象2_ParameterPtr p_Param2;p_Param2.CreateInstance(ADODB.Parameter);p_Param2-Name=key;p_Param2-Type=adVarChar;p_Param2-Size=50;p_Param2-Direction=adParamInput;p_Param2-Value=bstrP2;m_pCom

18、mand-Parameters-Append(p_Param2);/建立参数对象3_bstr_t bstrP3;_ParameterPtr p_Param3;p_Param3.CreateInstance(ADODB.Parameter);p_Param3-Name=power;p_Param3-Type=adInteger;p_Param3-Size=10;p_Param3-Direction=adParamOutput;/p_Param3-Value=bstrP3; /由于是输出参数，所以千万不能指定Value值m_pCommand-Parameters-Append(p_Param3);

19、/执行存储过程,并获得输出参数m_pCommand-Execute(NULL,NULL,adCmdStoredProc);_bstr_t value=p_Param3-GetValue();const char* ppp = value;*plPower = SysAllocString(A2W(ppp);return S_OK;注意，如果存储过程里面只写了一个select语句，执行后将返回一个记录集对象，ADO可以通过m_pRecordet=m_pCommand-Execute (.)来接受，但是如果存储过程中包含了多个select语句，ADO接受到的记录集对象是不可一使用的。10）使用命令

20、对象执行SQL语句_CommandPtr m_pCommand;m_pCommand.CreateInstance(ADODB.Command);m_pCommand-ActiveConnection = m_pCon;/m_pCon为数据库连接对象m_pCommand-CommandText=UPDATE TABLE1 set num_id = 2 WHERE value = 44;m_pCommand-CommandType=adCmdText;m_pCommand-Parameters-Refresh();/执行存储过程,并获得输出参数m_pCommand-Execute(NULL,NU

21、LL,adCmdUnknown);11) 得到记录集中字段的数目m_pRecordset-Fields-GetCount();也可以通过类似的方式获得字段类型FieldsPtr fields=m_Rec-GetFields();* pcActualColSize=fields-GetCount();VARIANT varIndex;VariantInit(&varIndex);varIndex.vt=VT_I4;FieldPtr field;DataTypeEnum adoType;for(long i=0;iGetItem(varIndex);adoType=field-GetType();

22、 下面是类型对应表enum DataTypeEnum adEmpty= 0,adTinyInt= 16,adSmallInt= 2,adInteger= 3,adBigInt= 20,adUnsignedTinyInt= 17,adUnsignedSmallInt= 18,adUnsignedInt= 19,adUnsignedBigInt= 21,adSingle= 4,adDouble= 5,adCurrency= 6,adDecimal= 14,adNumeric= 131,adBoolean= 11,adError= 10,adUserDefined= 132,adVariant= 1

23、2,adIDispatch= 9,adIUnknown= 13,adGUID= 72,adDate= 7,adDBDate= 133,adDBTime= 134,adDBTimeStamp= 135,adBSTR= 8,adChar= 129,adVarChar= 200,adLongVarChar= 201,adWChar= 130,adVarWChar= 202,adLongVarWChar= 203,adBinary= 128,adVarBinary= 204,adLongVarBinary= 205,adChapter= 136,adFileTime= 64,adPropVariant

24、= 138,adVarNumeric= 139DataTypeEnum;typedef enum ParameterDirectionEnum dbParamInput= 1,dbParamOutput= 2,dbParamInputOutput= 3,dbParamReturnValue= 4 ParameterDirectionEnum;Windows使用两种字符集ANSI和UNICODE，前者就是通常使用的单字节方式，但这种方式处理象中文这样的双字节字符不方便，容易出现半个汉字的情况。而后者是双字节方式，方便处理双字节字符。Windows NT的所有与字符有关的函数都提供两种方式的版本，

25、而Windows 9x只支持ANSI方式。_T一般同字常数相关，如_T(Hello)。如果你编译一个程序为ANSI方式，_T实际不起任何作用。而如果编译一个程序为UNICODE方式，则编译器会把Hello字符串以UNICODE方式保存。_T和_L的区别在于，_L不管你是以什么方式编译，一律以以UNICODE方式保存HRESULT 是一种简单的数据类型，通常被属性和 ATL 用作返回值。下表说明各种不同的值。头文件 winerror.h 中包含更多的值。名称说明值S_OK操作成功0xE_UNEXPECTED意外的失败0x8000FFFFE_NOTIMPL未实现0xE_OUTOFMEMORY未能分

26、配所需的内存0xEE_INVALIDARG一个或多个参数无效0xE_NOINTERFACE不支持此接口0xE_POINTER无效指针0xE_HANDLE无效句柄0xE_ABORT操作已中止0xE_FAIL未指定的失败0xE_ACCESSDENIED一般的访问被拒绝错误0x一、ADO简介ADO(ActiveX Data Object)是Microsoft数据库应用程序开发的新接口，是建立在OLE DB之上的高层数据库访问技术,不仅简单易用，并且不失灵活性.不失为C+利用数据库快速开发的不错选择。理论就不用我在这儿费话了,网上有很多,但光是理论,也不是不够的,ADO访问数据的方法很灵活,容易让人混

27、淆.网上大部分的实例都是基于MFC的,数据库也是ACCESS多,这儿我写了一个C+语言访问MS SQL2000的实例，希望对比我还菜鸟的菜鸟有所帮助。 二、建库首先在SQL2000企业管理中，建立一个数据库student,并创建一个表stu_info字段和值如下：snum sname sage ssex smajor 本拉登 23 男 计算机科学 张巧巧 25 女 旅游管理 张学友 26 男 计算机科学 三、访问程序清单如下：（win2000+VC6.0)/*利用ADO访问MS SQL2000要求: 【1】输出stu_info表内的每一条记录 【2】添加一条新记录【3】删除名字为本拉登的记录

28、*/ #import c:Program FilesCommon FilesSystemADOmsado15.dll no_namespace rename(EOF, EndOfFile)#include iostream#include iomanip /for setw()using namespace std;class STUpublic:char snum10; /学号 char sname10; /姓名 char ssex2; /姓别 long sage; /年龄 char smajor20; /专业 public:STU()STU(); int main()STU student

29、;:CoInitialize(NULL); / 初始化OLE/COM库环境 ，为访问ADO接口做准备_RecordsetPtr m_pRecordset(ADODB.Recordset);_ConnectionPtr m_pConnection(ADODB.Connection);_bstr_t bstrSQL(select * from stu_info); /查询语句 char * query_cmd = DELETE FROM stu_info WHERE sname = 本拉登;try/ 创建Connection对象m_pConnection.CreateInstance(ADODB.

30、Connection);/ 设置连接字符串，必须是BSTR型或者_bstr_t类型_bstr_t strConnect= Provider=SQLOLEDB;Server=(local);Database=student; uid=sa; pwd=123;/若数据库在网络上则Server为形如(192.168.1.5,3340)/用户sa和密码123只是针对我的库 m_pConnection-Open(strConnect,adModeUnknown);if(m_pConnection=NULL)cerrLind data ERROR!n;/ 创建记录集对象m_pRecordset.Creat

31、eInstance(_uuidof(Recordset);/ 取得表中的记录m_pRecordset-Open(bstrSQL,m_pConnection.GetInterfacePtr(),adOpenDynamic,adLockOptimistic,adCmdText);_variant_t vsnum,vsname,vsage,vssex,vsmajor; /对应库中的snum,sname,sage,ssex,smajorcout 学号 姓名 年龄 姓别 专业;cout n-n;while (!m_pRecordset-EndOfFile)vsnum = m_pRecordset-Get

32、Collect(_variant_t(long)0);/这儿给字段编号和字段名都可以 vsname = m_pRecordset-GetCollect(sname);vsage = m_pRecordset-GetCollect(sage);vssex = m_pRecordset-GetCollect(ssex);vsmajor = m_pRecordset-GetCollect(smajor);if (vsnum.vt != VT_NULL & vsname.vt != VT_NULL & vsage.vt != VT_NULL& vssex.vt != VT_NULL & vsmajor

33、.vt != VT_NULL)cout.setf(ios:left);cout setw(14) (char*)(_bstr_t)vsnum;cout setw(14) (char*)(_bstr_t)vsname;cout setw(8) vsage.lVal;cout setw(8) (char*)(_bstr_t)vssex;cout setw(20) (char*)(_bstr_t)vsmajor;cout.unsetf(ios:left);cout endl; m_pRecordset-MoveNext(); /移到下一条记录cout n-n;cout n请输入你要添加的学生信息n;

34、 cout 学号:;cin student.snum;cout n姓名:;cin student.sname;cout n年龄:;cin student.sage; cout n姓别:;cin student.ssex;cout n专业:;cin student.smajor;m_pRecordset-MoveFirst(); /移动到第一条记录m_pRecordset-AddNew(); /添加新记录m_pRecordset-PutCollect(snum,_variant_t(student.snum);m_pRecordset-PutCollect(sname,_variant_t(st

35、udent.sname);m_pRecordset-PutCollect(sage,_variant_t(student.sage);m_pRecordset-PutCollect(ssex,_variant_t(student.ssex);m_pRecordset-PutCollect(smajor,_variant_t(student.smajor);m_pRecordset-Update();m_pConnection-Execute(query_cmd,NULL,1); /用Execute执行sql语句来删除m_pRecordset-Close(); / 关闭记录集/ 捕捉异常catch(_com_error e)/ 显示错误信息cerr nERROR: (char*)e.Description();/抛出异常if(m_pConnection-State)m_pConnection-Close();:CoUninitialize();return 0;