VC连接数据库方式目前Windows系统上常见的数据库接口包括：ODBC（开放数据库互连）：访问数据库得先配置数据源 MFC（Microsoft基础类）ODBC类 DAO（数据访问对象） RDO（远程数据对象） OLE DB（对象链接嵌入数据库） ADO（ActiveX数据对象） ODBC（Open Database Connectivity，开放数据库连接）是由Microsoft定义的一种数据库访问标准，它提供了一种标准的数据库访问方法以访问不同数据库提供商的数据库，其本质上是一组数据库访问API.虽然数据库访问有多种方法，但ODBC以其编程相对简单，在实际编程中被广泛使用。 VC++中提供了一组封装了ODBC API的MFC ODBC类，以减少程序代码编写量。在VC++中使用MFC ODBC类访问数据库时，一般都是先配置或选择已有的数据源，再构造CDatabase类对象，打开数据源，用该数据库类对象和SQL（结构化查询语言）可以对库进行访问，再构造CRecordset类或其继承类对象，用数据集类对象和SQL可以实现对库中的表的操作。在VC++中用MFC ODBC类操作SQL Server数据库基本上也是这个思路。 1.配置数据源 在程序中根据用户选择动态配置数据源而不调用ODBC数据源管理器，对于应用程序开发有时是十分必要的。毕竟ODBC数据源管理器对于对数据库不熟悉的用户显的复杂了，且ODBC数据源管理器的界面风格有可能与整个应用程序的界面风格不一致，对于严谨的应用程序开发者来说，这些都是不能容忍的。 配置SQL Server数据源时，必须有SQL Server服务器名和服务器中的目标数据库名（否则打开该数据源时，就会弹出配置数据源对话框或失败）。这与配置Access等数据库的数据源时指定数据库文件的路径不同。 可以通过ODBC API函数SQLBrowseConnect得到本地所有的SQL Server服务器、服务器中的库、语言信息等。其使用方法如下所示： 1得到服务器名 SQLBrowseConnect（hdbc， 'DRIVER={SQL Server}；'， SQL_NTS， BrowseResult， sizeof（BrowseResult）， &BrowseResultLen）； 其中hdbc是用SQLAllocHandle函数得到的连结句柄，第二个参数是指定连结属性的输入字符串，第三个参数是输入字符串的长度，第四个参数是输出字符串的指针，我们要得到的信息就存于这个字符串中，第五个参数指定输出字符串的长度，第六个参数是实际返回字符串的长度。BrowseResult所指向的函数返回的字符串中含有形如“SERVER：Server={Server_name1，Server_name2，…}”的字符串，其中Server_name1、Server_name2就是SQL Server服务器名。 2得到库名 当用户选定一个服务器之后，可以进一步利用SQLBrowseConnect函数得到服务器中存在的库或语言信息（如果需要的话）。 SQLBrowseConnect（hdbc，'SERVER=Server_name1；UID=sa；PWD=515578；'，SQL_NTS， BrowseResult， sizeof（BrowseResult）， &BrowseResultLen）； 其中UID和PWD是访问该服务器的用户名和密码。这次BrowseResult所指向的函数返回的字符串中含有形如DATABASE：Database={master，model，…}和LANGUAGE：Language={Arabic， Brazilian， English， …}的字符串，其中master、model为服务器中的数据库名。 利用这些得到信息就可以配置SQL Server数据源了： SQLConfigDataSource（NULL，ODBC_ADD_DSN，'SQL Server'，'DSN=myDSN\0 SERVER=xhm\0DATABASE=pubs\0\0' ）） 作者有幸在网上找到Santosh Rao编写的CSQLInfoEnumerator类，该类有 EnumerateSQLServers、EnumerateDatabase、EnumerateDatabaseLanguage三个成员函数，其封装了SQLBrowseConnect函数并进行相应的字符处理，大大简化了SQLBrowseConnect函数的使用。 2.与数据源建立连接 如果使用ODBC API函数进行连结，函数SQLConnect、SQLDriverConnect和SQLBrowseConnect都可以实现。其中SQLConnect函数用于给定所有参数直接建立与数据源的连接；SQLDriverConnect用于给定了部分连接参数，并弹出数据源浏览窗口与用户交互，获得足够的参数后建立与数据源的连接；而SQLBrowseConnect是通过迭代获取连结参数再进行连接，其使用如前所述。 MFC为连接数据源提供了一个数据库类CDatabase，通过它我们可以非常方便地与数据源建立连结： //m_db是CDatabase的对象 //m_szUserId，m_szPassword是CString对象，为访问数据源的用户名和密码 CString str; str = _T('DSN=xhmtest;UID=')+m_szUserId+_T(';PWD=')+m_szPassword; if (! m_db.OpenEx(str, CDatabase::noOdbcDialog ) ){ AfxMessageBox('打开数据源失败'); } 另外，如果我们想对数据源进行操作，就可以利用打开的CDatabase对象执行SQL语句实现。如新建一张表： str = 'CREATE TABLE TableDemo (Column1TEXT, Column2 NUMBER)'; m_db.ExecuteSQL(sSql); 3.得到数据库的结构信息 在VC++中可以单独利用ODBC API获取数据库的结构信息，但方法非常复杂，各种参数也不易理解，且返回的结果不易获取。MFC中也没有为应用程序开发者得到数据库结构信息而提供单独的类。但是我们还是可以通过一些已有的方法方便地获得数据库的结构信息。 3.1 得到数据库中的表 利用ODBC API函数SQLTables可以得到数据库中的表信息，但使用不易。 在MSDN的sample中有一个catalog例程，它示范了如果得到一个数据库的表信息和表中的字段信息，该程序中有两个非常实用的类：Ctables和Ccolumns.其中CTables继承CRecordset类，通过非常巧妙的方法封装了SQLTables函数，并将结果集存于CRecordset类，方便获取。 在程序中我们可以这样应用： //m_db是已经打开的CDatabse对象, //m_strTableOwner是CComboBox对象 CTables rs(&m_db); rs.Open(NULL, NULL, NULL, 'TABLE'); CString strTableRef; m_combTable.ResetContent(); while (!rs.IsEOF()) { strTableRef = _T('['); if (!rs.m_strTableOwner.IsEmpty()) strTableRef += rs.m_strTableOwner + _T('].['); strTableRef += rs.m_strTableName + _T(']'); m_combTable.AddString(strTableRef); rs.MoveNext(); } rs.Close(); 在CTables对象Open方法第四个能数指定“TABLE”是指返回库中的表，当该参数为“SYSTEM TABLE”时返回系统表，当为NULL时，返回所有表。 3.2 得到表中字段结构 得到表中字段结构有三种具体实现方式： 1直接利用ODBC API 函数SQLColumn；其实现也同样复杂。 2利用前面提到的封装了SQLColumns函数的CColumns类；其使用方法与CTables类似，其成员变量m_strColumnName即为字段名 3利用CRecordset类的成员函数。MFC在CRecordset类中提供了获取表结构信息方法，使用非常方便。（但很奇怪为什么CDatabase类没有获取库结构信息的类方法？） 我们以利用CRecodrset为例简单说明怎样得到表结构。假设现在要得到用户在CComboBox对象中所选表的所有字段名，并将它埴入一个CListCtrl对象（其View属性被设为Report）的列名中去： //m_strTableOwner和上同，为CComboBox对象 //m_listData为ClistCtrl对象 CRecordset rs CODBCFieldInfo info; CString strSQL; m_combTable.GetLBText(m_combTable.GetCurSel(), strSQL); strSQL = _T('SELECT * FROM ') + strSQL; rs.Open(Open(CRecordset::snapshot, strSQL, CRecordset::readOnly); int nColumns = rs.GetODBCFieldCount(); for (int nNum = 0; nNum < nColumns; nNum++) { prs->GetODBCFieldInfo(nNum, info); m_listData.InsertColumn(nNum, info.m_strName, LVCFMT_LEFT, 80) } 另外，我们可以利用CRecordSet：：GetFieldValue函数通过指定列名或列序数得到记录集中游标所指记录的值，通过CRecordset：：AddNew、CRecordset：：CancelUpdate、CRecordset：：Delete、CRecordset：：Edit、CRecordset：：Update等函数操作CRecordset打开的表。 ======== vc++与MySQL数据库的连接1.MySQL数据库的安装 你可以从MySQL的官网上或者从如下地址下载MySQL的数据库安装包(http://download.csdn.net/detail/nuptboyzhb/4619847)。本文以mysql-5.0.27-win32为例。下载完之后解压安装。注意：在安装的过程中，选择安装“完全版”(complete)，不要选择默认的“典型”。否者，没有c++相关的连接库。然后一直点next即可。安装过程中让你注册，你就按部就班的做就行了。安装完之后的文件目录如下： [Image] 2.数据库的建立 你可以直接用MySQL的命令行窗口去建立一个数据库和一个表。但是，我强烈推荐你用可视化的工具（你可以去搜一下）。在这里，我之前安装过wamp5就直接用网页版的phpmyadmin工具。如果你安装过wamp5,直接在浏览器中输入：http://localhost/phpmyadmin/即可。然后我们新建一个名为testdb的数据库再在其中新建一个表：name_table.然后新增数据：zhb 22studentsnjupt [Image][Image] 3.VC++6.0的配置 本文以经典的vc++6.0为例。(当然，VS2005 2008 2010等，也是这样配置)。打开vc++6.0,工具->选项->目录(选项卡)，在其Include files添加MySQL的include路径。如我的MySQL的include文件夹的路径为：C:\Program Files\MySQL\MySQL Server 5.0\include。切换下拉框，选择Library files，添加MySQL的lib路径。如我的为：C:\Program Files\MySQL\MySQL Server 5.0\lib\opt 4.编程连接数据库并查询 [c++ codes] 源码打印？ #include <windows.h> #include <stdio.h> #include <stdlib.h> #include <string.h> #include <mysql.h> #include <iostream> #pragma comment(lib,'libmysql.lib')//连接MysQL需要的库 using namespace std; int main() { const char user[] = 'root'; //username const char pswd[] = '*********'; //password const char host[] = 'localhost'; //or'127.0.0.1' const char table[] ='testdb'; //database unsigned int port = 3306; //server port MYSQL myCont; MYSQL_RES *result; MYSQL_ROW sql_row; MYSQL_FIELD *fd; char column[32][32]; int res; mysql_init(&myCont); if(mysql_real_connect(&myCont,host,user,pswd,table,port,NULL,0)) { cout<<'connect succeed!'<<endl; mysql_query(&myCont, 'SET NAMES GBK'); //设置编码格式,否则在cmd下无法显示中文 res=mysql_query(&myCont,'select * from name_table');//查询 if(!res) { result=mysql_store_result(&myCont);//保存查询到的数据到result if(result) { int i,j; cout<<'number of result: '<<(unsigned long)mysql_num_rows(result)<<endl; for(i=0;fd=mysql_fetch_field(result);i++)//获取列名 { strcpy(column[i],fd->name); } j=mysql_num_fields(result); for(i=0;i<j;i++) { printf('%s\t',column[i]); } printf('\n'); while(sql_row=mysql_fetch_row(result))//获取具体的数据 { for(i=0;i<j;i++) { printf('%s\n',sql_row[i]); } printf('\n'); } } } else { cout<<'query sql failed!'<<endl; } } else { cout<<'connect failed!'<<endl; } if(result!=NULL) mysql_free_result(result);//释放结果资源 mysql_close(&myCont);//断开连接 return 0; } 实验结果 [Image] http://blog.csdn.net/nuptboyzhb/article/details/8043091 ======== 用vc如何访问ACCESS数据库？在现代软件开发中，数据库技术被越来越广泛应用，很多项目都存在着大量的数据需要存储，通常都会采用数据库来存储这些数据。最初，数据库厂商推出一个新的数据库产品时，相应的，他会为程序员提供一套访问该数据库的接口，即API。不同的数据库厂商提供的访问接口是不一样的，这样在使用一个新的数据库时，就要学习一套新的API，当然这就加大了开发数据库的难度，也不利于数据库在软件开发过程中的应用。因此，后来Microsoft就推出了一些标准的访问数据库的技术。 这一部分主要介绍ADO访问数据库的情况，对于其它技术，可以自行查阅相应书籍，ADO中有以下3个核心对象。 @Connection对象 Connection对象表示到数据库的链接，它管理应用程序和数据库之间的通信，下面的2个对象都有一个ActiveConnection属性，该属性用来引用Connection对象。 @Command对象 Command对象用来 处理 重复执行的查询，或处理 需要检查 在存储过程中的输出或返回值 的查询。 @RecordSet对象 RecordSet对象用来保存数据，存放查询的结果，这些结果由数据的行（记录）和列（字段）组成。每一列都存放在RecordSet的Fields集合中的一个Field对象中。 第一步： 在VC中利用ADO访问数据库时，首先需要导入ADO库。在程序的预编译头文件stdAfx.h中导入该库，方法是利用import指令将此动态链接库导入，具体代码如下：#import 'c:/program files/common files/system/ado/msado15.dll' no_namespace rename('EOF','rsEOF')，代码中使用了no_namespace关键字，namespace是命名空间，本例中不需要命名空间，主要是为了访问方便，在程序中可以直接访问ADO提供的Connection、Command、RecordSet这3个COM接口。最后利用rename将EOF改为rsEOF。EOF表示 记录集 的结尾，因为文件也是以EOF为结尾的，为了避免冲突，在导入ADO库时，需要将EOF改为rsEOF。至于将其改为什么名字，可以根据自己的习惯来定。 在导入ADO库之后，编译程序，会出现一条警告，在VC中利用ADO访问数据库时都会存在这一警告，对程序并没有影响，可以不用理会。编译之后，在Debug目录下，可以看到编译器为我们产生了两个文件，msado15.tlh和msado15.tli。可以将msado15.tlh看作是一个头文件，msado15.tli看作是一个源文件，这两个文件是在导入ADO库之后，编译器在编译的时候自动生成的，利用ADO技术访问数据库并不需要为工程导入这两个文件。 第二步： 为需要访问数据库的类添加2个成员变量，_RecordsetPtr m_pRs（数据集对象）;_ConnectionPtr m_pConn;（数据库链接对象） 接着在程序初始化的时候初始化这2个对象 CoInitialize(NULL); try { //初始化数据库连接对象 m_pConn.CreateInstance('ADODB.Connection'); m_pRs.CreateInstance(__uuidof(Recordset));//这里必须初始化。 //定义数据库连接字符串，打开本地Access库 m_pConn->ConnectionString='Provider=Microsoft.ACE.OLEDB.12.0;Data Source=DBS.mdb;Persist Security Info=False'; //打开数据库连接 m_pConn->Open('','','',adConnectUnspecified); } catch(_com_error &e) { ::CoUninitialize(); ::AfxMessageBox(e.ErrorMessage()); return FALSE; } COM组件在使用时，需要初始化COM库，这就需要调用CoInitialize(NULL);函数来实现，该函数有一个参数，该参数是保留的，直接传递NULL即可，同时在访问完COM库之后，程序需要调用CoUninitialize();函数卸载COM库。 接着，初始化 数据链接对象 和 数据集对象。在初始化这两个对象时，利用__uuidof获取ADO Connection和ADO RecordSet对象的全局唯一标识符（GUID）。对m_pConn对象进行初始化。 然后，利用智能指针对象去访问该对象的属性和方法了。首先，为数据库链接对象的链接字符串赋值。然后调用链接对象的Open方法打开与数据库的链接。关于链接字符串的获得：不必死记硬背，可以利用VB开发环境来得到链接字符串，P756。 接下来就可以利用链接对象的Execute方法来从数据库获得数据了。 void CMy_DbsDlg::OnBtnQue() { try { CString strsql; strsql.Format('SELECT * FROM RoomStandard'); HRESULT hr=m_pRs->Open(_variant_t(strsql),(m_pConn.GetInterfacePtr()),adOpenStatic,adLockOptimistic,adCmdText); //m_pRs=m_pConn->Execute((_bstr_t)strsql,NULL,adCmdText); _variant_t vFieldValue; if(SUCCEEDED(hr)) { //m_pRs->MoveFirst();//移至第一条记录---------默认指针在第一条记录上 m_list.DeleteAllItems(); int i=0,n=0; while(!(m_pRs->GetrsEOF()))//while(!m_pRs->rsEOF) { int k=0; vFieldValue=m_pRs->GetCollect(_variant_t(long(k))); if(vFieldValue.vt!=NULL) { k=1; m_list.InsertItem(n,_bstr_t(vFieldValue));//插入列表控件 for(;k<9;k++) { vFieldValue=m_pRs->GetCollect(_variant_t(long(k))); if(vFieldValue.vt!=NULL) { m_list.SetItemText(n,k,_bstr_t(vFieldValue)); } } } n++;//记录数加1； m_pRs->MoveNext(); } m_pRs->Close(); } } catch(_com_error e) { AfxMessageBox(e.ErrorMessage()); AfxMessageBox((LPCTSTR)(e.Description())); } /// //这里要判断一下记录是不是打开的，要以防不正常的情况下记录没有关闭！ if(m_pRs) { if (m_pRs->State) { m_pRs->Close(); } } } 当数据操作完成之后，调用记录集对象的Close方法关闭记录集，最后调用链接对象的Close方法关闭链接。然后还需要释放智能指针在COM接口上的引用计数，即分别调用记录集对象和链接对象的Release方法，该方法将释放相应COM接口的引用计数。智能指针有一个特点，在访问其它属性和方法时，都是用->操作符，但在调用Release方法释放引用计数时，必须使用.操作符。 ======== VC++ADO连接数据库一、ADO简介 ADO(ActiveX Data Object)是Microsoft数据库应用程序开发的新接口，是建立在OLE DB之上的高层数据 库访问技术，请不必为此担心，即使你对OLE DB，COM不了解也能轻松对付ADO,因为它非常简单易用，甚 至比你以往所接触的ODBC API、DAO、RDO都要容易使用，并不失灵活性。本文将详细地介绍在VC下如何使 用ADO来进行数据库应用程序开发，并给出示例代码。 本文示例代码 二、基本流程 (1)初始化COM库，引入ADO库定义文件 (2)用Connection对象连接数据库 (3)利用建立好的连接，通过Connection、Command对象执行SQL命令，或利用Recordset对象取得结果记录 集进行查询、处理。 (4)使用完毕后关闭连接释放对象。 准备工作: 为了大家都能测试本文提供的例子，我们采用Access数据库，您也可以直接在我们提供的示例代码中找到 这个test.mdb。 下面我们将详细介绍上述步骤并给出相关代码。 【1】COM库的初始化 我们可以使用AfxOleInit()来初始化COM库，这项工作通常在CWinApp::InitInstance()的重载函数中完成 ，请看如下代码: BOOL CADOTest1App::InitInstance() { AfxOleInit(); ...... 【2】用#import指令引入ADO类型库 我们在stdafx.h中加入如下语句：(stdafx.h这个文件哪里可以找到?你可以在FileView中的Header Files 里找到) #import 'c:\program files\common files\system\ado\msado15.dll' no_namespace rename ('EOF','adoEOF') 这一语句有何作用呢？其最终作用同我们熟悉的＃i nclude类似,编译的时候系统会为我们生成 msado15.tlh,ado15.tli两个C++头文件来定义ADO库。 几点说明: (1) 您的环境中msado15.dll不一定在这个目录下，请按实际情况修改 (2) 在编译的时候肯能会出现如下警告，对此微软在MSDN中作了说明，并建议我们不要理会这个警告。 msado15.tlh(405) : warning C4146: unary minus operator applied to unsigned type, result still unsigned 【3】创建Connection对象并连接数据库 首先我们需要添加一个指向Connection对象的指针: _ConnectionPtr m_pConnection; 下面的代码演示了如何创建Connection对象实例及如何连接数据库并进行异常捕捉。 BOOL CADOTest1Dlg::OnInitDialog() { CDialog::OnInitDialog(); HRESULT hr; try { hr = m_pConnection.CreateInstance('ADODB.Connection');///创建Connection对象 if(SUCCEEDED(hr)) { hr = m_pConnection->Open('Provider=Microsoft.Jet.OLEDB.4.0;Data Source=test.mdb','','',adModeUnknown);///连接数据库 ///上面一句中连接字串中的Provider是针对ACCESS2000环境的，对于ACCESS97,需要改 为:Provider=Microsoft.Jet.OLEDB.3.51; } } catch(_com_error e)///捕捉异常 { CString errormessage; errormessage.Format('连接数据库失败!\r\n错误信息:%s',e.ErrorMessage()); AfxMessageBox(errormessage);///显示错误信息 } 在这段代码中我们是通过Connection对象的Open方法来进行连接数据库的，下面是该方法的原型 HRESULT Connection15::Open ( _bstr_t ConnectionString, _bstr_t UserID, _bstr_t Password, long Options ) ConnectionString为连接字串,UserID是用户名, Password是登陆密码,Options是连接选项,用于指定 Connection对象对数据的更新许可权, Options可以是如下几个常量: adModeUnknown:缺省。当前的许可权未设置 adModeRead:只读 adModeWrite:只写 adModeReadWrite:可以读写 adModeShareDenyRead:阻止其它Connection对象以读权限打开连接 adModeShareDenyWrite:阻止其它Connection对象以写权限打开连接 adModeShareExclusive:阻止其它Connection对象打开连接 adModeShareDenyNone:允许其它程序或对象以任何权限建立连接 我们给出一些常用的连接方式供大家参考: (1)通过JET数据库引擎对ACCESS2000数据库的连接 m_pConnection->Open('Provider=Microsoft.Jet.OLEDB.4.0;Data Source=C:\\test.mdb','','',adModeUnknown); (2)通过DSN数据源对任何支持ODBC的数据库进行连接: m_pConnection->Open('Data Source=adotest;UID=sa;PWD=;','','',adModeUnknown); (3)不通过DSN对SQL SERVER数据库进行连接： m_pConnection->Open('driver={SQL Server};Server=127.0.0.1;DATABASE=vckbase;UID=sa;PWD=139','','',adModeUnknown); 其中Server是SQL服务器的名称，DATABASE是库的名称 Connection对象除Open方法外还有许多方法，我们先介绍Connection对象中两个有用的属性 ConnectionTimeOut与State ConnectionTimeOut用来设置连接的超时时间，需要在Open之前调用，例如: m_pConnection- >ConnectionTimeout = 5;///设置超时时间为5秒 m_pConnection->Open('Data Source=adotest;','','',adModeUnknown); State属性指明当前Connection对象的状态，0表示关闭，1表示已经打开，我们可以通过读取这个属性来 作相应的处理，例如: if(m_pConnection->State) m_pConnection->Close(); ///如果已经打开了连接则关闭它 【4】执行SQL命令并取得结果记录集 为了取得结果记录集，我们定义一个指向Recordset对象的指针:_RecordsetPtr m_pRecordset; 并为其创建Recordset对象的实例: m_pRecordset.CreateInstance('ADODB.Recordset'); SQL命令的执行可以采用多种形式，下面我们一进行阐述。 (1)利用Connection对象的Execute方法执行SQL命令 Execute方法的原型如下所示: _RecordsetPtr Connection15::Execute ( _bstr_t CommandText, VARIANT * RecordsAffected, long Options ) 其中CommandText是命令字串，通常是SQL命令。参数RecordsAffected是操作完成后所影响的 行数, 参数Options表示CommandText中内容的类型，Options可以取如下值之一： adCmdText:表明CommandText是文本命令 adCmdTable:表明CommandText是一个表名 adCmdProc:表明CommandText是一个存储过程 adCmdUnknown:未知 Execute执行完后返回一个指向记录集的指针，下面我们给出具体代码并作说明。 _variant_t RecordsAffected; ///执行SQL命令：CREATE TABLE创建表格users,users包含四个字段:整形ID,字符串username,整形old, 日期型birthday m_pConnection->Execute('CREATE TABLE users(ID INTEGER,username TEXT,old INTEGER,birthday DATETIME)',&RecordsAffected,adCmdText); ///往表格里面添加记录 m_pConnection->Execute('INSERT INTO users(ID,username,old,birthday) valueS (1, nullnullnullnullnullnullnullnullWashingtonnullnullnullnullnullnullnullnull,25,nullnullnullnu llnullnullnullnull1970/1/1nullnullnullnullnullnullnullnull)',&RecordsAffected,adCmdText); ///将所有记录old字段的值加一 m_pConnection->Execute('UPDATE users SET old = old+1',&RecordsAffected,adCmdText); ///执行SQL统计命令得到包含记录条数的记录集 m_pRecordset = m_pConnection->Execute('SELECT COUNT(*) FROM users',&RecordsAffected,adCmdText); _variant_t vIndex = (long)0; _variant_t vCount = m_pRecordset->GetCollect(vIndex);///取得第一个字段的值放入vCount变量 m_pRecordset->Close();///关闭记录集 CString message; message.Format('共有%d条记录',vCount.lVal); AfxMessageBox(message);///显示当前记录条数 (2)利用Command对象来执行SQL命令 _CommandPtr m_pCommand; m_pCommand.CreateInstance('ADODB.Command'); _variant_t vNULL; vNULL.vt = VT_ERROR; vNULL.scode = DISP_E_PARAMNOTFOUND;///定义为无参数 m_pCommand->ActiveConnection = m_pConnection;///非常关键的一句，将建立的连接赋值给它 m_pCommand->CommandText = 'SELECT * FROM users';///命令字串 m_pRecordset = m_pCommand->Execute(&vNULL,&vNULL,adCmdText);///执行命令，取得记录集 在这段代码中我们只是用Command对象来执行了SELECT查询语句，Command对象在进行存储过程的调用中能 真正体现它的作用。下次我们将详细介绍。 (3)直接用Recordset对象进行查询取得记录集 例如 m_pRecordset->Open('SELECT * FROM users',_variant_t((IDispatch *) m_pConnection,true),adOpenStatic,adLockOptimistic,adCmdText); Open方法的原型是这样的: HRESULT Recordset15::Open ( const _variant_t & Source, const _variant_t & ActiveConnection, enum CursorTypeEnum CursorType, enum LockTypeEnum LockType, long Options ) 其中： 1Source是数据查询字符串 2ActiveConnection是已经建立好的连接（我们需要用Connection对象指针来构造一个_variant_t对象) 3CursorType光标类型，它可以是以下值之一,请看这个枚举结构: enum CursorTypeEnum { adOpenUnspecified = -1,///不作特别指定 adOpenForwardOnly = 0,///前滚静态光标。这种光标只能向前浏览记录集，比如用MoveNext向前滚动,这 种方式可以提高浏览速度。但诸如BookMark,RecordCount,AbsolutePosition,AbsolutePage都不能使用 adOpenKeyset = 1,///采用这种光标的记录集看不到其它用户的新增、删除操作，但对于更新原有记录的 操作对你是可见的。 adOpenDynamic = 2,///动态光标。所有数据库的操作都会立即在各用户记录集上反应出来。 adOpenStatic = 3///静态光标。它为你的记录集产生一个静态备份，但其它用户的新增、删除、更新操 作对你的记录集来说是不可见的。 }; 4LockType锁定类型，它可以是以下值之一，请看如下枚举结构： enum LockTypeEnum { adLockUnspecified = -1,///未指定 adLockReadOnly = 1,///只读记录集 adLockPessimistic = 2,悲观锁定方式。数据在更新时锁定其它所有动作，这是最安全的锁定机制 adLockOptimistic = 3,乐观锁定方式。只有在你调用Update方法时才锁定记录。在此之前仍然可以做数 据的更新、插入、删除等动作 adLockBatchOptimistic = 4，乐观分批更新。编辑时记录不会锁定，更改、插入及删除是在批处理模式 下完成。 }; 5Options请参考本文中对Connection对象的Execute方法的介绍 【5】记录集的遍历、更新 根据我们刚才通过执行SQL命令建立好的users表，它包含四个字段:ID,username,old,birthday 以下的代码实现：打开记录集，遍历所有记录，删除第一条记录，添加三条记录，移动光标到第二条记录 ，更改其年龄，保存到数据库。 _variant_t vUsername,vBirthday,vID,vOld; _RecordsetPtr m_pRecordset; m_pRecordset.CreateInstance('ADODB.Recordset'); m_pRecordset->Open('SELECT * FROM users',_variant_t((IDispatch*) m_pConnection,true),adOpenStatic,adLockOptimistic,adCmdText); while(!m_pRecordset->adoEOF)///这里为什么是adoEOF而不是EOF呢?还记得rename('EOF','adoEOF')这 一句吗? { vID = m_pRecordset->GetCollect(_variant_t((long)0));///取得第1列的值,从0开始计数，你也可以直 接给出列的名称，如下一行 vUsername = m_pRecordset->GetCollect('username');///取得username字段的值 vOld = m_pRecordset->GetCollect('old'); vBirthday = m_pRecordset->GetCollect('birthday'); ///在DEBUG方式下的OUTPUT窗口输出记录集中的记录 if(vID.vt != VT_NULL && vUsername.vt != VT_NULL && vOld.vt != VT_NULL && vBirthday.vt != VT_NULL) TRACE('id:%d,姓名:%s,年龄:%d,生日:%s\r\n',vID.lVal,(LPCTSTR)(_bstr_t)vUsername,vOld.lVal, (LPCTSTR)(_bstr_t)vBirthday); m_pRecordset->MoveNext();///移到下一条记录 } m_pRecordset->MoveFirst();///移到首条记录 m_pRecordset->Delete(adAffectCurrent);///删除当前记录 ///添加三条新记录并赋值 for(int i=0;i<3;i++) { m_pRecordset->AddNew();///添加新记录 m_pRecordset->PutCollect('ID',_variant_t((long)(i+10))); m_pRecordset->PutCollect('username',_variant_t('叶利钦')); m_pRecordset->PutCollect('old',_variant_t((long)71)); m_pRecordset->PutCollect('birthday',_variant_t('1930-3-15')); } m_pRecordset->Move(1,_variant_t((long)adBookmarkFirst));///从第一条记录往下移动一条记录,即移 动到第二条记录处 m_pRecordset->PutCollect(_variant_t('old'),_variant_t((long)45));///修改其年龄 m_pRecordset->Update();///保存到库中 【6】关闭记录集与连接 记录集或连接都可以用Close方法来关闭 m_pRecordset->Close();///关闭记录集 m_pConnection->Close();///关闭连接 ,最后我给大家写了一个小例子，例子中读出所有记录放 到列表控件中、并可以添加、删除、修改记录。 点这里下载示例代码 后记：限于篇幅ADO中的许多内容还没有介绍，下次我们将详细介绍Recordset对象的属性、方法并解决几 个关键的技术：绑定方式处理记录集数据、存储过程的调用、事务处理、图象在数据库中的保存与读取、 与表格控件的配合使用等。 ======== VC对ADO的操作文章概要：VC用ADO访问数据库全攻略,介绍了VC用ADO来访问数据库的各个对象及各方法， 一、ADO概述 ADO是Microsoft为最新和最强大的数据访问范例 OLE DB 而设计的，是一个便于使用的应用程序层接口。ADO 使您能够编写应用程序以通过 OLE. DB 提供者访问和操作数据库服务器中的数据。ADO 最主要的优点是易于使用、速度快、内存支出少和磁盘遗迹小。ADO 在关键的应用方案中使用最少的网络流量，并且在前端和数据源之间使用最少的层数，所有这些都是为了提供轻量、高性能的接口。之所以称为 ADO，是用了一个比较熟悉的暗喻，OLE 自动化接口。 OLE DB是一组”组件对象模型”(COM) 接口，是新的数据库低层接口，它封装了ODBC的功能，并以统一的方式访问存储在不同信息源中的数据。OLE DB是Microsoft UDA(Universal Data Access)策略的技术基础。OLE DB 为任何数据源提供了高性能的访问，这些数据源包括关系和非关系数据库、电子邮件和文件系统、文本和图形、自定义业务对象等等。也就是说，OLE DB 并不局限于 ISAM、Jet 甚至关系数据源，它能够处理任何类型的数据，而不考虑它们的格式和存储方法。在实际应用中，这种多样性意味着可以访问驻留在 Excel 电子数据表、文本文件、电子邮件/目录服务甚至邮件服务器，诸如 Microsoft Exchange 中的数据。但是，OLE DB 应用程序编程接口的目的是为各种应用程序提供最佳的功能，它并不符合简单化的要求。您需要的API 应该是一座连接应用程序和OLE DB 的桥梁，这就是 ActiveX Data Objects (ADO)。 二、在VC中使用ADO(开发步骤好下：) 1、引入ADO库文件 使用ADO前必须在工程的stdafx.h头文件里用直接引入符号#import引入ADO库文件,以使编译器能正确编译。代码如下所示： 用#import引入ADO库文件 #import 'c:\program files\common files\system\ado\msado15.dll'no_namespaces rename('EOF' adoEOF') 这行语句声明在工程中使用ADO，但不使用ADO的名字空间，并且为了避免常数冲突，将常数EOF改名为adoEOF。现在不需添加另外的头文件，就可以使用ADO接口了。 2、初始化OLE/COM库环境 必须注意的是，ADO库是一组COM动态库，这意味应用程序在调用ADO前，必须初始化OLE/COM库环境。在MFC应用程序里，一个比较好的方法是在应用程序主类的InitInstance成员函数里初始化OLE/COM库环境。 BOOL CMyAdoTestApp：：InitInstance() { if(!AfxOleInit())//这就是初始化COM库 { AfxMessageBox(“OLE初始化出错!”); return FALSE; } …… } 3、ADO接口简介 ADO库包含三个基本接口:_ConnectionPtr接口、_CommandPtr接口和_RecordsetPtr接口。 _ConnectionPtr接口返回一个记录集或一个空指针。通常使用它来创建一个数据连接或执行一条不返回任何结果的SQL语句，如一个存储过程。使用_ConnectionPtr接口返回一个记录集不是一个好的使用方法。对于要返回记录的操作通常用_RecordserPtr来实现。而用_ConnectionPtr操作时要想得到记录条数得遍历所有记录，而用_RecordserPtr时不需要。 _CommandPtr接口返回一个记录集。它提供了一种简单的方法来执行返回记录集的存储过程和SQL语句。在使用_CommandPtr接口时，你可以利用全局_ConnectionPtr接口，也可以在_CommandPtr接口里直接使用连接串。如果你只执行一次或几次数据访问操作，后者是比较好的选择。但如果你要频繁访问数据库，并要返回很多记录集，那么，你应该使用全局_ConnectionPtr接口创建一个数据连接，然后使用_CommandPtr接口执行存储过程和SQL语句。 _RecordsetPtr是一个记录集对象。与以上两种对象相比，它对记录集提供了更多的控制功能，如记录锁定，游标控制等。同_CommandPtr接口一样，它不一定要使用一个已经创建的数据连接，可以用一个连接串代替连接指针赋给_RecordsetPtr的connection成员变量，让它自己创建数据连接。如果你要使用多个记录集，最好的方法是同Command对象一样使用已经创建了数据连接的全局_ConnectionPtr接口 ，然后使用_RecordsetPtr执行存储过程和SQL语句。 4、使用_ConnectionPtr接口 _ConnectionPtr主要是一个连接接口，取得与数据库的连接。它的连接字符串可以是自己直接写，也可以指向一个ODBC DSN。。 _ConnectionPtr pConn; if (FAILED(pConn.CreateInstance('ADODB.Connection'))) { AfxMessageBox('Create Instance failed!'); return; } CString strSRC; strSRC='Driver=SQL Server;Server='; strSRC+='suppersoft'; strSRC+=';Database='; strSRC+='mydb'; strSRC+=';UID=SA;PWD='; CString strSQL = 'Insert into student(no,name,sex,address) values(3,'aaa','male','beijing')'; _variant_t varSRC(strSRC); _variant_t varSQL(strSQL); _bstr_t bstrSRC(strSRC); if (FAILED(pConn->Open(bstrSRC,'','',-1))) { AfxMessageBox('Can not open Database!'); pConn.Release(); return; } COleVariant vtOptional((long)DISP_E_PARAMNOTFOUND,VT_ERROR); pConn->Execute(_bstr_t(strSQL),&vtOptional,-1); pConn.Release(); AfxMessageBox('ok!'); 5、使用_RecordsetPtr接口(以连接SQL Server为例) _RecordsetPtr pPtr; if (FAILED(pPtr.CreateInstance('ADODB.Recordset'))) { AfxMessageBox('Create Instance failed!'); return FALSE; } CString strSRC; strSRC='Driver=SQL Server;Server='; strSRC+='210.46.141.145'; strSRC+=';Database='; strSRC+='mydb'; strSRC+=';UID=sa;PWD='; strSRC+='sa'; CString strSQL = 'select id,name,gender,address from personal'; _variant_t varSRC(strSRC); _variant_t varSQL(strSQL); if(FAILED(pPtr->Open(varSQL,varSRC,adOpenStatic,adLockOptimistic,adCmdText))) { AfxMessageBox('Open table failed!'); pPtr.Release(); return FALSE; } while(!pPtr->GetadoEOF()) { _variant_t varNo; _variant_t varName; _variant_t varSex; _variant_t varAddress; varNo = pPtr->GetCollect ('id'); varName = pPtr->GetCollect ('name'); varSex = pPtr->GetCollect ('gender'); varAddress = pPtr->GetCollect ('address'); CString strNo =(char *)_bstr_t(varNo); CString strName =(char *)_bstr_t(varName); CString strSex =(char *)_bstr_t(varSex); CString strAddress =(char *)_bstr_t(varAddress); strNo.TrimRight(); strName.TrimRight(); strSex.TrimRight(); strAddress.TrimRight(); int nCount = m_list.GetItemCount(); int nItem = m_list.InsertItem (nCount,_T('')); m_list.SetItemText (nItem,0,strNo); m_list.SetItemText (nItem,1,strName); m_list.SetItemText (nItem,2,strSex); m_list.SetItemText (nItem,3,strAddress); pPtr->MoveNext(); } pPtr->Close(); pPtr.Release(); 6、使用_CommandPtr接口 _CommandPtr接口返回一个Recordset对象，并且提供了更多的记录集控制功能，以下代码示例了使用_CommandPtr接口的方法： 代码11:使用_CommandPtr接口获取数据 _CommandPtr pCommand; _RecordsetPtr pRs; pCommand.CreateInstance(__uuidof(Command)); pCommand->ActiveConnection=pConn; pCommand->CommandText='select * from student'; pCommand->CommandType=adCmdText; pCommand->Parameters->Refresh(); pRs=pCommand->Execute(NULL,NULL,adCmdUnknown); _variant_t varValue = pRs->GetCollect('name'); CString strValue=(char*)_bstr_t(varValue); 6、关于数据类型转换由于COM对象是跨平台的，它使用了一种通用的方法来处理各种类型的数据， 因此Cstring 类和COM对象是不兼容的，我们需要一组API来转换COM对象和C++类型的数据。_vatiant_t和_bstr_t就是这样两种对象。它们提供了通用的方法转换COM对象和C++类型的数据。 ............................................................................................ 1. 生成应用程序框架并初始化OLE/COM库环境 创建一个标准的MFC AppWizard(exe)应用程序，然后在使用ADO数据库的InitInstance函数中初始化OLE/COM库（因为ADO库是一个COM DLL库）。 本例为： BOOL CAdotestDlg::OnInitDialog() { ::CoInitialize(NULL); //初始化OLE/COM库环境 } 程序最后要调用 ::CoUninitialize()；//释放程序占用的COM 资源。 另外： m_pRecordset->Close(); 注意！！！不要多次关闭！！！！！！！！！！！！ m_pConnection->Close(); m_pRecordset = NULL; m_pConnection = NULL; 2. 引入ADO库文件 使用ADO前必须在工程的stdafx.h文件最后用直接引入符号＃import引入ADO库文件，以使编译器能正确编译。代码如下： #import 'C:\Program Files\common files\system\ado\msado15.dll' no_namespace rename('EOF','adoEOF') ADO类的定义是作为一种资源存储在ADO DLL(msado15.dll）中，在其内部称为类型库。类型库描述了自治接口，以及C＋＋使用的COM vtable接口。当使用＃import指令时，在运行时Visual C＋＋需要从ADO DLL中读取这个类型库，并以此创建一组C＋＋头文件。这些头文件具有.tli 和.tlh扩展名，读者可以在项目的目录下找到这两个文件。在C＋＋程序代码中调用的ADO类要在这些文件中定义。 程序的第三行指示ADO对象不使用名称空间。在有些应用程序中，由于应用程序中的对象与ADO中的对象之间可能会出现命名冲突，所以有必要使用名称空间。如果要使用名称空间，则可把第三行程序修改为： rename_namespace('AdoNS')。第四行代码将ADO中的EOF(文件结束)更名为adoEOF，以避免与定义了自己的EOF的其他库冲突。 3．利用智能指针进行数据库操作 在CaboutDlg头文件中定义两个ADO智能指针类实例,并在对话框中加入一个ListCtrl。 class CAdotestDlg : public CDialog { _ConnectionPtr m_pConnection; _RecordsetPtr m_pRecordset; ClistCtrl m_List; ...... } ADO库包含三个智能指针:_ConnectionPtr、_CommandPtr和_RecordsetPtr。 _ConnectionPtr通常被用来创建一个数据连接或执行一条不返回任何结果的SQL语句，如一个存储过程。 _CommandPtr返回一个记录集。它提供了一种简单的方法来执行返回记录集的存储过程和SQL语句。在使用_CommandPtr接口时，可以利用全局_ConnectionPtr接口，也可以在_CommandPtr接口里直接使用连接串。 _RecordsetPtr是一个记录集对象。与以上两种对象相比，它对记录集提供了更多的控制功能，如记录锁定、游标控制等。 在使用ADO程序的事件响应中OnButton1加入以下代码: void CAdotestDlg::OnButton1() { m_List.ResetContent(); m_pConnection.CreateInstance(_uuidof(Connection)); //初始化Connection指针 m_pRecordset.CreateInstance(_uuidof(Recordset));//初始化Recordset指针 try { m_pConnection->Open('DSN=ADOTest','','',0); //连接叫作ADOTest的ODBC数据源 //注意：这是连接不需要用户ID或密码的open 函数 // 否则形式为 ->Open('DSN=test;uid=sa;pwd=123;','','',0); // 执行SQL语句得到一个记录集把其指针赋值给m_pRecordset CString strSql='select * from middle'; BSTR bstrSQL = strSql.AllocSysString(); m_pRecordset->Open(bstrSQL,(IDispatch*)m_pConnection,adOpenDynamic,adLockOptimistic,adCmdText); //adOpenDynamic：动态 adLockOptimistic乐观封锁法 adCmdText：文本查询语句 while(!m_pRecordset->adoEOF)//遍历所有记录 { //取纪录字段值方式之一 _variant_t TheValue; //VARIANT数据类型 TheValue = m_pRecordset->GetCollect('BIG_NAME');//得到字段BIG_NAME的值 if(TheValue.vt!=VT_NULL) m_List.AddString((char*)_bstr_t(TheValue)); //将该值加入到列表控件中 //取纪录字段值方式之二 // _bstr_t TheValue1=m_pRecordset->Fields->GetItem('BIG_NAME')->Value; // CString temp=TheValue1.copy(); // m_List.AddString(temp); //数据类型转换 _variant_t vUsername,vBirthday,vID,vOld; TRACE('id:%d,姓名:%s,年龄:%d,生日:%s\r\n', vID.lVal,(LPCTSTR)(_bstr_t)vUsername,vOld.lVal,(LPCTSTR)(_bstr_t)vBirthday); m_pRecordset->MoveNext();//转到下一条纪录 } m_pRecordset->Close(); m_pConnection->Close(); } catch (_com_error e)//异常处理 { AfxMessageBox(e.ErrorMessage()); } m_pRecordset->Close(); //注意！！！不要多次关闭！！！！否则会出错 m_pConnection->Close(); m_pRecordset = NULL; m_pConnection = NULL; } 程序中通过_variant_t和_bstr_t转换COM对象和C＋＋类型的数据, _variant_t类封装了OLE自治VARIANT数据类型。在C++中使用_variant_t类要比直接使用VARIANT数据类型容易得多。 好，编译后该程序就能运行了，但记住运行前要创建一个叫ADOTest的ODBC数据源。该程序将把表middle中的BIG_NAME字段值显示在列表控件中。 在Visual C++中用ADO进行数据库编程(中) 4．执行SQL命令并取得结果记录集 为了取得结果记录集，我们定义一个指向Recordset对象的指针:_RecordsetPtr m_pRecordset; 并为其创建Recordset对象的实例: m_pRecordset.CreateInstance('ADODB.Recordset'); SQL命令的执行可以采用多种形式，下面我们一进行阐述。 (1)利用Connection对象的Execute方法执行SQL命令 Execute方法的原型如下所示: _RecordsetPtr Connection15::Execute ( _bstr_t CommandText, VARIANT * RecordsAffected, long Options ) 其中CommandText是命令字串，通常是SQL命令。 参数RecordsAffected是操作完成后所影响的行数, 参数Options表示CommandText中内容的类型，Options可以取如下值之一： adCmdText:表明CommandText是文本命令 adCmdTable:表明CommandText是一个表名 adCmdProc:表明CommandText是一个存储过程 adCmdUnknown:未知 Execute执行完后返回一个指向记录集的指针，下面我们给出具体代码并作说明。 _variant_t RecordsAffected; ///执行SQL命令：CREATE TABLE创建表格users,users包含四个字段:整形ID,字符串username,整形old,日期型birthday m_pConnection->Execute('CREATE TABLE users(ID INTEGER,username TEXT,old INTEGER,birthday DATETIME)', &RecordsAffected, adCmdText); ///往表格里面添加记录 m_pConnection->Execute('INSERT INTO users(ID,username,old,birthday) VALUES (1, ''''Washington'''',25,''''1970/1/1'''')',&RecordsAffected,adCmdText); ///将所有记录old字段的值加一 m_pConnection->Execute('UPDATE users SET old = old+1',&RecordsAffected,adCmdText); ///执行SQL统计命令得到包含记录条数的记录集 m_pRecordset = m_pConnection->Execute('SELECT COUNT(*) FROM users',&RecordsAffected,adCmdText); _variant_t vIndex = (long)0; _variant_t vCount = m_pRecordset->GetCollect(vIndex);///取得第一个字段的值放入vCount变量 上两句可以写成— _variant_t vCount = m_pRecordset->GetCollect((_variant_t)((long)0)); m_pRecordset->Close();///关闭记录集 CString message; message.Format('共有%d条记录',vCount.lVal); AfxMessageBox(message);///显示当前记录条数 (2)利用Command对象来执行SQL命令 _CommandPtr m_pCommand; m_pCommand.CreateInstance('ADODB.Command'); _variant_t vNULL; vNULL.vt = VT_ERROR; vNULL.scode = DISP_E_PARAMNOTFOUND;///定义为无参数 m_pCommand->ActiveConnection = m_pConnection;///非常关键的一句，将建立的连接赋值给它 m_pCommand->CommandText = 'SELECT * FROM users';///命令字串 m_pRecordset = m_pCommand->Execute(&vNULL,&vNULL,adCmdText);///执行命令，取得记录集 在这段代码中我们只是用Command对象来执行了SELECT查询语句，Command对象在进行存储过程的调用中能真正体现它的作用。下次我们将详细介绍。 (3)直接用Recordset对象进行查询取得记录集 实例—— void CGmsaDlg::OnDBSelect() { // TODO: Add your control notification handler code here _RecordsetPtr Rs1; //定义Recordset对象 _bstr_t Connect('DSN=GMS;UID=sa;PWD=;');//定义连接字符串 _bstr_t Source ('SELECT count(*) FROM buaa.mdb010'); //要执行的SQL语句 ::CoInitialize(NULL); //初始化Rs1对象 HRESUL hr = Rs1.CreateInstance( __uuidof( Recordset ) ); //省略对返回值hr的判断 Rs1->Open( Source, Connect, adOpenForwardOnly, adLockReadOnly, -1 ); _variant_t temp=Rs1->GetCollect(_variant_t((long)0)); CString strTemp=(char* )(_bstr_t)temp; MessageBox('OK!'+strTemp); } 例如 m_pRecordset->Open('SELECT * FROM users', _variant_t((IDispatch *)m_pConnection,true), adOpenStatic, adLockOptimistic, adCmdText); Open方法的原型是这样的: HRESULT Recordset15::Open ( const _variant_t & Source, const _variant_t & ActiveConnection, enum CursorTypeEnum CursorType, enum LockTypeEnum LockType, long Options ) 其中： 1Source是数据查询字符串 2ActiveConnection是已经建立好的连接（我们需要用Connection对象指针来构造一个_variant_t对象) 3CursorType光标类型，它可以是以下值之一,请看这个枚举结构: enum CursorTypeEnum { adOpenUnspecified = -1,///不作特别指定 adOpenForwardOnly = 0,///前滚静态光标。这种光标只能向前浏览记录集，比如用MoveNext向前滚动,这种方式可以提高浏览速度。但诸如BookMark,RecordCount,AbsolutePosition,AbsolutePage都不能使用 adOpenKeyset = 1,///采用这种光标的记录集看不到其它用户的新增、删除操作，但对于更新原有记录的操作对你是可见的。 adOpenDynamic = 2,///动态光标。所有数据库的操作都会立即在各用户记录集上反应出来。 adOpenStatic = 3///静态光标。它为你的记录集产生一个静态备份，但其它用户的新增、删除、更新操作对你的记录集来说是不可见的。 }; 4LockType锁定类型，它可以是以下值之一，请看如下枚举结构： enum LockTypeEnum { adLockUnspecified = -1,///未指定 adLockReadOnly = 1,///只读记录集 adLockPessimistic = 2,悲观锁定方式。数据在更新时锁定其它所有动作，这是最安全的锁定机制 adLockOptimistic = 3,乐观锁定方式。只有在你调用Update方法时才锁定记录。在此之前仍然可以做数据的更新、插入、删除等动作 adLockBatchOptimistic = 4，乐观分批更新。编辑时记录不会锁定，更改、插入及删除是在批处理模式下完成。 }; 5Options可以取如下值之一： adCmdText:表明CommandText是文本命令 adCmdTable:表明CommandText是一个表名 adCmdProc:表明CommandText是一个存储过程 adCmdUnknown:未知 10、邦定数据 定义一个绑定类，将其成员变量绑定到一个指定的记录集，以方便于访问记录集的字段值。 (1). 从CADORecordBinding派生出一个类： class CCustomRs : public CADORecordBinding { BEGIN_ADO_BINDING(CCustomRs) ADO_VARIABLE_LENGTH_ENTRY2(3, adVarChar, m_szau_fname, sizeof(m_szau_fname), lau_fnameStatus, false) ADO_VARIABLE_LENGTH_ENTRY2(2, adVarChar, m_szau_lname, sizeof(m_szau_lname), lau_lnameStatus, false) ADO_VARIABLE_LENGTH_ENTRY2(4, adVarChar, m_szphone, sizeof(m_szphone), lphoneStatus, true) END_ADO_BINDING() public: CHAR m_szau_fname[22]; ULONG lau_fnameStatus; CHAR m_szau_lname[42]; ULONG lau_lnameStatus; CHAR m_szphone[14]; ULONG lphoneStatus; }; 其中将要绑定的字段与变量名用BEGIN_ADO_BINDING宏关联起来。每个字段对应于两个变量，一个存放字段的值，另一个存放字段的状态。字段用从1开始的序号表示，如1，2，3等等。 特别要注意的是：如果要绑定的字段是字符串类型，则对应的字符数组的元素个数一定要比字段长度大2（比如m_szau_fname[22]，其绑定的字段au_fname的长度实际是20），不这样绑定就会失败。我分析多出的2可能是为了存放字符串结尾的空字符null和BSTR字符串开头的一个字（表示BSTR的长度）。这个问题对于初学者来说可能是一个意想不到的问题。 CADORecordBinding类的定义在icrsint.h文件里，内容是： class CADORecordBinding { public: STDMETHOD_(const ADO_BINDING_ENTRY*, GetADOBindingEntries) (VOID) PURE; }; BEGIN_ADO_BINDING宏的定义也在icrsint.h文件里，内容是： #define BEGIN_ADO_BINDING(cls) public: \ typedef cls ADORowClass; \ const ADO_BINDING_ENTRY* STDMETHODCALLTYPE GetADOBindingEntries() { \ static const ADO_BINDING_ENTRY rgADOBindingEntries[] = { ADO_VARIABLE_LENGTH_ENTRY2宏的定义也在icrsint.h文件里： #define ADO_VARIABLE_LENGTH_ENTRY2(Ordinal, DataType, Buffer, Size, Status, Modify)\ {Ordinal, \ DataType, \ 0, \ 0, \ Size, \ offsetof(ADORowClass, Buffer), \ offsetof(ADORowClass, Status), \ 0, \ classoffset(CADORecordBinding, ADORowClass), \ Modify}, #define END_ADO_BINDING宏的定义也在icrsint.h文件里： #define END_ADO_BINDING() {0, adEmpty, 0, 0, 0, 0, 0, 0, 0, FALSE}};\ return rgADOBindingEntries;} (2). 绑定 _RecordsetPtr Rs1; IADORecordBinding *picRs=NULL; CCustomRs rs; ...... Rs1->QueryInterface(__uuidof(IADORecordBinding), (LPVOID*)&picRs)); picRs->BindToRecordset(&rs); 派生出的类必须通过IADORecordBinding接口才能绑定，调用它的BindToRecordset方法就行了。 (3). rs中的变量即是当前记录字段的值 //Set sort and filter condition: // Step 4: Manipulate the data Rs1->Fields->GetItem('au_lname')->Properties->GetItem('Optimize')->Value = true; Rs1->Sort = 'au_lname ASC'; Rs1->Filter = 'phone LIKE '415 5*''; Rs1->MoveFirst(); while (VARIANT_FALSE == Rs1->EndOfFile) { printf('Name: %s\t %s\tPhone: %s\n', (rs.lau_fnameStatus == adFldOK ? rs.m_szau_fname : ''), (rs.lau_lnameStatus == adFldOK ? rs.m_szau_lname : ''), (rs.lphoneStatus == adFldOK ? rs.m_szphone : '')); if (rs.lphoneStatus == adFldOK) strcpy(rs.m_szphone, '777'); TESTHR(picRs->Update(&rs)); // Add change to the batch Rs1->MoveNext(); } Rs1->Filter = (long) adFilterNone; ...... if (picRs) picRs->Release(); Rs1->Close(); pConn->Close(); 只要字段的状态是adFldOK，就可以访问。如果修改了字段，不要忘了先调用picRs的Update（注意不是Recordset的Update），然后才关闭，也不要忘了释放picRs（即picRs->Release();）。 (4). 此时还可以用IADORecordBinding接口添加新纪录 if(FAILED(picRs->AddNew(&rs))) ...... 11. 访问长数据 在Microsoft SQL中的长数据包括text、image等这样长类型的数据，作为二进制字节来对待。 可以用Field对象的GetChunk和AppendChunk方法来访问。每次可以读出或写入全部数据的一部分，它会记住上次访问的位置。但是如果中间访问了别的字段后，就又得从头来了。 请看下面的例子： //写入一张照片到数据库： VARIANT varChunk; SAFEARRAY *psa; SAFEARRAYBOUND rgsabound[1]; //VT_ARRAY │ VT_UI1 CFile f('h:\\aaa.jpg',Cfile::modeRead); BYTE bVal[ChunkSize+1]; UINT uIsRead=0; //Create a safe array to store the array of BYTES while(1) { uIsRead=f.Read(bVal,ChunkSize); if(uIsRead==0)break; rgsabound[0].cElements =uIsRead; rgsabound[0].lLbound = 0; psa = SafeArrayCreate(VT_UI1,1,rgsabound); for(long index=0;index<uIsRead;index++) { if(FAILED(SafeArrayPutElement(psa,&index,&bVal[index]))) ::MessageBox(NULL,'啊，又出毛病了。','提示',MB_OK │ MB_ICONWARNING); } varChunk.vt = VT_ARRAY│VT_UI1; varChunk.parray = psa; try{ m_pRecordset->Fields->GetItem('photo')->AppendChunk(varChunk); } catch (_com_error &e) { CString str=(char*)e.Description(); ::MessageBox(NULL,str+'\n又出毛病了。','提示',MB_OK │ MB_ICONWARNING); } ::VariantClear(&varChunk); ::SafeArrayDestroyData( psa); if(uIsRead<ChunkSize)break; }//while(1) f.Close(); //从数据库读一张照片： CFile f; f.Open('h:\\bbb.jpg',Cfile::modeWrite│Cfile::modeCreate); long lPhotoSize = m_pRecordset->Fields->Item['photo']->ActualSize; long lIsRead=0; _variant_t varChunk; BYTE buf[ChunkSize]; while(lPhotoSize>0) { lIsRead=lPhotoSize>=ChunkSize? ChunkSize:lPhotoSize; varChunk = m_pRecordset->Fields-> Item['photo']->GetChunk(lIsRead); for(long index=0;index<lIsRead;index++) { ::SafeArrayGetElement(varChunk.parray,&index,buf+index); } f.Write(buf,lIsRead); lPhotoSize-=lIsRead; }//while() f.Close(); 12. 使用SafeArray问题 学会使用SafeArray也是很重要的，因为在ADO编程中经常要用。它的主要目的是用于automation中的数组型参数的传递。因为在网络环境中，数组是不能直接传递的，而必须将其包装成SafeArray。实质上SafeArray就是将通常的数组增加一个描述符，说明其维数、长度、边界、元素类型等信息。SafeArray也并不单独使用，而是将其再包装到VARIANT类型的变量中，然后才作为参数传送出去。在VARIANT的vt成员的值如果包含VT_ARRAY│...,那么它所封装的就是一个SafeArray，它的parray成员即是指向SafeArray的指针。SafeArray中元素的类型可以是VARIANT能封装的任何类型，包括VARIANT类型本身。 使用SafeArray的具体步骤： 方法一： 包装一个SafeArray： (1). 定义变量，如： VARIANT varChunk; SAFEARRAY *psa; SAFEARRAYBOUND rgsabound[1]; (2). 创建SafeArray描述符： uIsRead=f.Read(bVal,ChunkSize);//read array from a file. if(uIsRead==0)break; rgsabound[0].cElements =uIsRead; rgsabound[0].lLbound = 0; psa = SafeArrayCreate(VT_UI1,1,rgsabound); (3). 放置数据元素到SafeArray： for(long index=0;index<uIsRead;index++) { if(FAILED(SafeArrayPutElement(psa,&index,&bVal[index]))) ::MessageBox(NULL,'出毛病了。','提示',MB_OK │ MB_ICONWARNING); } 一个一个地放，挺麻烦的。 (4). 封装到VARIANT内： varChunk.vt = VT_ARRAY│VT_UI1; varChunk.parray = psa; 这样就可以将varChunk作为参数传送出去了。 读取SafeArray中的数据的步骤： (1). 用SafeArrayGetElement一个一个地读 BYTE buf[lIsRead]; for(long index=0;index<lIsRead;index++) { ::SafeArrayGetElement(varChunk.parray,&index,buf+index); } 就读到缓冲区buf里了。 方法二： 使用SafeArrayAccessData直接读写SafeArray的缓冲区： (1). 读缓冲区： BYTE *buf; SafeArrayAccessData(varChunk.parray, (void **)&buf); f.Write(buf,lIsRead); SafeArrayUnaccessData(varChunk.parray); (2). 写缓冲区： BYTE *buf; ::SafeArrayAccessData(psa, (void **)&buf); for(long index=0;index<uIsRead;index++) { buf[index]=bVal[index]; } ::SafeArrayUnaccessData(psa); varChunk.vt = VT_ARRAY│VT_UI1; varChunk.parray = psa; 这种方法读写SafeArray都可以，它直接操纵SafeArray的数据缓冲区，比用SafeArrayGetElement和SafeArrayPutElement速度快。特别适合于读取数据。但用完之后不要忘了调用::SafeArrayUnaccessData(psa)，否则会出错的。 13. 使用书签( bookmark ) 书签可以唯一标识记录集中的一个记录，用于快速地将当前记录移回到已访问过的记录，以及进行过滤等等。Provider会自动为记录集中的每一条记录产生一个书签，我们只需要使用它就行了。我们不能试图显示、修改或比较书签。ADO用记录集的Bookmark属性表示当前记录的书签。 用法步骤： (1). 建立一个VARIANT类型的变量 _variant_t VarBookmark; (2). 将当前记录的书签值存入该变量 也就是记录集的Bookmark属性的当前值。 VarBookmark = rst->Bookmark; (3). 返回到先前的记录 将保存的书签值设置到记录集的书签属性中： // Check for whether bookmark set for a record if (VarBookmark.vt == VT_EMPTY) printf('No Bookmark set!\n'); else rst->Bookmark = VarBookmark; 设置完后，当前记录即会移动到该书签指向的记录。 14、设置过滤条件 Recordset对象的Filter属性表示了当前的过滤条件。它的值可以是以AND或OR连接起来的条件表达式（不含WHERE关键字）、由书签组成的数组或ADO提供的FilterGroupEnum枚举值。为Filter属性设置新值后Recordset的当前记录指针会自动移动到满足过滤条件的第一个记录。例如： rst->Filter = _bstr_t ('姓名='赵薇' AND 性别=’女’'); 在使用条件表达式时应注意下列问题： （1）、可以用圆括号组成复杂的表达式 例如： rst->Filter = _bstr_t ('(姓名='赵薇' AND 性别=’女’) OR AGE<25'); 但是微软不允许在括号内用OR，然后在括号外用AND，例如： rst->Filter = _bstr_t ('(姓名='赵薇' OR 性别=’女’) AND AGE<25'); 必须修改为： rst->Filter = _bstr_t ('(姓名='赵薇' AND AGE<25) OR (性别=’女’ AND AGE<25)'); （2）、表达式中的比较运算符可以是LIKE LIKE后被比较的是一个含有通配符*的字符串，星号表示若干个任意的字符。 字符串的首部和尾部可以同时带星号* rst->Filter = _bstr_t ('姓名 LIKE '*赵*' '); 也可以只是尾部带星号： rst->Filter = _bstr_t ('姓名 LIKE '赵*' '); Filter属性值的类型是Variant，如果过滤条件是由书签组成的数组，则需将该数组转换为SafeArray，然后再封装到一个VARIANT或_variant_t型的变量中，再赋给Filter属性。 15、索引与排序 （1）、建立索引 当以某个字段为关键字用Find方法查找时，为了加快速度可以以该字段为关键字在记录集内部临时建立索引。只要将该字段的Optimize属性设置为true即可，例如： pRst->Fields->GetItem('姓名')->Properties-> GetItem('Optimize')->PutValue('True'); pRst->Find('姓名 = '赵薇'',1,adSearchForward); ...... pRst->Fields->GetItem('姓名')->Properties-> GetItem('Optimize')->PutValue('False'); pRst->Close(); 说明：Optimize属性是由Provider提供的属性（在ADO中称为动态属性），ADO本身没有此属性。 （2）、排序 要排序也很简单，只要把要排序的关键字列表设置到Recordset对象的Sort属性里即可，例如： pRstAuthors->CursorLocation = adUseClient; pRstAuthors->Open('SELECT * FROM mytable', _variant_t((IDispatch *) pConnection), adOpenStatic, adLockReadOnly, adCmdText); ...... pRst->Sort = '姓名 DESC, 年龄 ASC'; 关键字（即字段名）之间用逗号隔开，如果要以某关键字降序排序，则应在该关键字后加一空格，再加DESC（如上例）。升序时ASC加不加无所谓。本操作是利用索引进行的，并未进行物理排序，所以效率较高。 但要注意，在打开记录集之前必须将记录集的CursorLocation属性设置为adUseClient，如上例所示。Sort属性值在需要时随时可以修改。 16、事务处理 ADO中的事务处理也很简单，只需分别在适当的位置调用Connection对象的三个方法即可，这三个方法是： （1）、在事务开始时调用 pCnn->BeginTrans(); （2）、在事务结束并成功时调用 pCnn->CommitTrans (); （3）、在事务结束并失败时调用 pCnn->RollbackTrans (); 在使用事务处理时，应尽量减小事务的范围，即减小从事务开始到结束（提交或回滚）之间的时间间隔，以便提高系统效率。需要时也可在调用BeginTrans()方法之前，先设置Connection对象的IsolationLevel属性值，详细内容参见MSDN中有关ADO的技术资料。 三、使用ADO编程常见问题解答 以下均是针对MS SQL 7.0编程时所遇问题进行讨论。 1、连接失败可能原因 Enterprise Managemer内，打开将服务器的属性对话框，在Security选项卡中，有一个选项Authentication。 如果该选项是Windows NT only，则你的程序所用的连接字符串就一定要包含Trusted_Connection参数，并且其值必须为yes，如： 'Provider=SQLOLEDB;Server=888;Trusted_Connection=yes' ';Database=master;uid=lad;'; 如果不按上述操作，程序运行时连接必然失败。 如果Authentication选项是SQL Server and Windows NT，则你的程序所用的连接字符串可以不包含Trusted_Connection参数，如： 'Provider=SQLOLEDB;Server=888;Database=master;uid=lad;pwd=111;'; 因为ADO给该参数取的默认值就是no，所以可以省略。我认为还是取默认值比较安全一些。 2、改变当前数据库的方法 使用Tansct-SQL中的USE语句即可。 3、如何判断一个数据库是否存在 (1)、可打开master数据库中一个叫做SCHEMATA的视图，其内容列出了该服务器上所有的数据库名称。 (2) 、更简便的方法是使用USE语句，成功了就存在；不成功，就不存在。例如： try{ m_pConnect->Execute ( _bstr_t('USE INSURANCE_2002'),NULL, adCmdText│adExecuteNoRecords ); } catch (_com_error &e) { blSuccess=FALSE; CString str='数据库INSURANCE_2002不存在！\n'; str+=e.Description(); ::MessageBox(NULL,str,'警告',MB_OK │ MB_ICONWARNING); } 4、判断一个表是否存在 （1）、同样判断一个表是否存在，也可以用是否成功地打开它来判断，十分方便，例如： try{ m_pRecordset->Open(_variant_t('mytable'), _variant_t((IDispatch *)m_pConnection,true), adOpenKeyset, adLockOptimistic, adCmdTable); } catch (_com_error &e) { ::MessageBox(NULL,'该表不存在。','提示',MB_OK │ MB_ICONWARNING); } (2)、要不然可以采用麻烦一点的办法，就是在MS-SQL服务器上的每个数据库中都有一个名为sysobjects的表，查看此表的内容即知指定的表是否在该数据库中。 (3)、同样，每个数据库中都有一个名为TABLES的视图(View)，查看此视图的内容即知指定的表是否在该数据库中。 5、类型转换问题 （1）、类型VARIANT_BOOL 类型VARIANT_BOOL等价于short类型。The VARIANT_BOOL is equivalent to short. see it's definition below: typdef short VARIANT_BOOL （2）、_com_ptr_t类的类型转换 _ConnectionPtr可以自动转换成IDspatch*类型，这是因为_ConnectionPtr实际上是_com_ptr_t类的一个实例，而这个类有此类型转换函数。 同理，_RecordsetPtr和_CommandPtr也都可以这样转换。 （3）、_bstr_t和_variant_t类 在ADO编程时，_bstr_t和_variant_t这两个类很有用，省去了许多BSTR和VARIANT类型转换的麻烦。 6、打开记录集时的问题 在打开记录集时，在调用Recordset的Open方法时，其最后一个参数里一定不能包含adAsyncExecute，否则将因为是异步操作，在读取数据时无法读到数据。 7、异常处理问题 对所有调用ADO的语句一定要用try和catch语句捕捉异常，否则在发生异常时，程序会异常退出。 8、使用SafeArray问题 在初学使用中，我曾遇到一个伤脑筋的问题，一定要注意： 在定义了SAFEARRAY的指针后，如果打算重复使用多次，则在中间可以调用::SafeArrayDestroyData释放数据，但决不能调用::SafeArrayDestroyDescriptor，否则必然出错，即使调用SafeArrayCreate也不行。例如： SAFEARRAY *psa; ...... //When the data are no longer to be used: ::SafeArrayDestroyData( psa); 我分析在定义psa指针时，一个SAFEARRAY的实例（也就是SAFEARRAY描述符）也同时被自动建立了。但是只要一调用::SafeArrayDestroyDescriptor，描述符就被销毁了。 所以我认为::SafeArrayDestroyDescriptor可以根本就不调用，即使调用也必须在最后调用。 9、重复使用命令对象问题 一个命令对象如果要重复使用多次（尤其是带参数的命令），则在第一次执行之前，应将它的Prepared属性设置为TRUE。这样会使第一次执行减慢，但却可以使以后的执行全部加快。 10、绑定字符串型字段问题 如果要绑定的字段是字符串类型，则对应的字符数组的元素个数一定要比字段长度大2（比如m_szau_fname[22]，其绑定的字段au_fname的长度实际是20），不这样绑定就会失败。 11、使用AppendChunk的问题 当用AddNew方法刚刚向记录集内添加一个新记录之后，不能首先向一个长数据字段（image类型）写入数据，必须先向其他字段写入过数据之后，才能调用AppendChunk写该字段，否则出错。也就是说，AppendChunk不能紧接在AddNew之后。另外，写入其他字段后还必须紧接着调用AppendChunk，而不能调用记录集的Update方法后，才调用AppendChunk，否则调用AppendChunk时也会出错。换句话说，就是必须AppendChunk在前，Update在后。因而这个时候就不能使用带参数的AddNew了，因为带参数的AddNew会自动调用记录集的Update，所以AppendChunk就跑到Update的后面了，就只有出错了！因此，这时应该用不带参数的AddNew。 我推测这可能是MS SQL 7.0的问题，在MS SQL 2000中则不存在这些问题，但是AppendChunk仍然不能在Update之后。 四、小结 一般情况下，Connection和Command的Execute用于执行不产生记录集的命令，而Recordset的Open用于产生一个记录集，当然也不是绝对的。特别Command主要是用于执行参数化的命令，可以直接由Command对象执行，也可以将Command对象传递给Recordset的Open。 本文中的代码片断均在VC++ 6.0、Windows NT 4.0 SP6和MS SQL 7.0中调试通过。相信您读过之后，编写简单的数据库程序应该没有问题了。当然要编写比较实用的、复杂一点的程序，还需要对OLE DB、ADO以及数据库平台再多了解一点，希望您继续努力，一定会很快成功的！详细参考资料请参见微软MSDN July 2000光盘或MS SQL 7.0在线文档资料（Books online）。文中难免有错误和不妥之处，敬请各位批评指正！ ............................................................................................ ADO 数据库连接-实例分析-VC 因为是笔记，所以不一定很有序，贴出来的意思一方面是可以给大家一个参考，一边也有希望大家一起来完善的意思，其中错误和不足之处当然希望大家可以及时地通知我，在贴上来的时候，我有一个想法，因为我在使用的过程中，总是会遇上一些莫明其妙的错误，所以我想大家有可能也会遇上，于是，我给出了一个错误总结，当然这里就需要大家一起来完善了，如果大家有什么心得和见解，希望在评论中留言，我会及时地接受大家的意见并把他们加进来（当然是在得到您的允许的情况下） 1、导入库文件使用ADO前必须在工程的stdafx.h文件最后用直接引入符号＃import引入ADO库文件，以使编译器能正确编译。代码如下： #import 'C:Program Filescommon filessystemadomsado15.dll' no_namespace rename('EOF','EndOfFile') rename('BOF','FirstOfFile') ADO类的定义是作为一种资源存储在ADO DLL(msado15.dll）中，在其内部称为类型库。类型库描述了自治接口，以及C＋＋使用的COM vtable接口。当使用＃import指令时，在运行时Visual C＋＋需要从ADO DLL中读取这个类型库，并以此创建一组C＋＋头文件。这些头文件具有.tli 和.tlh扩展名，读者可以在项目的目录下找到这两个文件。在C＋＋程序代码中调用的ADO类要在这些文件中定义。 程序的第三行指示ADO对象不使用名称空间。在有些应用程序中，由于应用程序中的对象与ADO中的对象之间可能会出现命名冲突，所以有必要使用名称空间。如果要使用名称空间，则可把第三行程序修改为： rename_namespace('AdoNS')。第四行代码将ADO中的EOF(文件结束)更名为adoEOF，以避免与定义了自己的EOF的其他库冲突。 2、初始化COM环境 （1）::CoInitialize(NULL); //初始化OLE/COM库环境 :: CoUninitialize();//既然初始化了环境，当然就有必要释放他了 （2）也可以调用MFC全局函数 AfxOleInit(); 3、三大对象的定义和创建实例 (1) _ConnectionPtr pConnection('ADODB.Connection'); _RecordsetPtr pRecordset('ADODB.Recordset'); _CommandPtr pCommand('ADODN.Command'); (2) _ConnectionPtr pConnection; _RecordsetPtr pRecordset; _CommandPtr pCommand; pConnection.CreateInstance(__uuidof(Connection)); pRecordset.CreateInstance(__uuidof(Recordset)); pCommand.CreateInstance(__uuidof(Command)); (3) _ConnectionPtr pConnection; _RecordsetPtr pRecordset; _CommandPtr pCommand; pConnection.CreateInstance('ADODB.Connection'); pRecordset.CreateInstance('ADODB.Recordset'); pCommand.CreateInstance('ADODB.Command'); 4、打开一个连接 pConnection->Open(ConnectionString,'','',adModeUnknown);///连接数据库 上面的连接字符串ConnectionString根据不同的数据源，分别对应不同的写法 1）访问Access 2000 'Provider=Microsoft.Jet.OLEDB.4.0;Data Source=databaseName;User ID=userName;Password=userPassWord' 2)访问ODBC数据 ' Provider=MADASQL;DSN=dsnName;UID=userName;PWD=userPassword;' 3)访问Oracle数据库 “Provider=MSDAORA;Data Sourse=serverName;User ID=userName;Password=userPassword;' 3)访问MS SQL数据库 'Provider=SQLOLEDB,Data Source=serverName;Initial Catalog=databaseName;User ID=userName;Password=userPassword;' 4、执行SQL命令 SQL命令比较多，但是不去考虑细节，这里只说出通用的方法 CString strSQL;//定义SQL命令串，用来保存SQL语句 strSQL.Format('SQL statement'); 然后在每个要用到SQL命令串的方法中，使用strSQL.AllocSysString()的方法进行类型转换 5、com的专用数据类型 variant ,bstr ,SafeArray variant变量的范围包括很多，使用_variant_t 进行管理 bstr是一种字符串变量，使用_bstr_t进行管理 6、关闭连接 if(m_pConnection->State)//不能多次关闭，否则会出现错误 m_pConnection->Close(); 7、结构化异常处理 ADO封装了COM接口，所以需要进行错误处理 如下例： HRESULT hr; try { hr = m_pConnection.CreateInstance('ADODB.Connection');///创建Connection对象 if(SUCCEEDED(hr)) { hr = m_pConnection->Open('Provider=Microsoft.Jet.OLEDB.4.0;Data Source=test.mdb','','',adModeUnknown);///连接数据库 ///上面一句中连接字串中的Provider是针对ACCESS2000环境的，对于ACCESS97,需要改 为:Provider=Microsoft.Jet.OLEDB.3.51; } } catch(_com_error e)///捕捉异常 { CString errormessage; errormessage.Format('连接数据库失败! 错误信息:%s',e.ErrorMessage()); AfxMessageBox(errormessage);///显示错误信息 } 8、错误原因的分析 (1)不支持接口，可能是不能插入空值 ======== 相关链接ODBC部分 http://www.cnblogs.com/cy163/archive/2010/11/16/1878870.html VC6.0数据库编程之MFC ODBC http://www./index.php/wv/248 一个完善的ODBC数据库程序 http://blog.csdn.net/suxinpingtao51/article/details/11742085 MFC ODBC数据操作编程 http://www.jb51.net/article/52780.htm VC实现ODBC数据库操作实例解析 http://blog.163.com/yuyi_vc/blog/static/1703717532010112623058864/ CRecordset类的常用成员函数 成员变量 以及操作实例 http://www./pro/html/201404/12211.html CRecordSet操作数据库 http://blog.csdn.net/elcoteq983/article/details/7000745 CRecordset类 ADO部分 http://blog.csdn.net/supermanking/article/details/3082934 VC中调用ADO对象访问数据库的范例 ======== VC中用ADO和DataGrid控件显示和更新数据库中的数据VC中用ADO和DataGrid控件显示和更新数据库中数据。 以VC6.0为例 1、新建一对话框 在资源视图中新建一个对话框，将对话框调整到适当大小，双击对话框创建对话框类。 2、往对话框上添加DataGrid控件 在VC6中点击 Project->add to project->components and controls。在弹出的对话框中双击Registered ActiveX Controls 在弹出的控件列表中选择Microsoft DataGrid Control 6.0（SP6）（OLEDB），点击insert，接下来的每一部都点确认按钮（ok按钮）。我们发现在工具箱中多了一个DataGrid控件的图标。 拖动该图标到对话框中，并且调整大小，设置属性为AllowAddNew、AllowDelete、AllowUpdate、ColumnHeaders、Enabled。 在DataCrid上右击用ClassWizard给对话框添加一个DataGrid变量m_dataGrid。 3、 添加代码 在对话框头文件中添加如下代码#import 'C://program files//common files//system//ado//msado15.dll' no_namespace rename ('EOF', 'adoEOF') 在对话框头文件的对话框类中添加如下代码 _ConnectionPtr pConnection;//数据库连接指针 _RecordsetPtr m_pRecordSet;//数据集指针 重载对话框OnInitDialog（）函数，在其中添加如下代码 CoInitialize(NULL); //初始化Com组件 pConnection.CreateInstance(__uuidof(Connection)); //Connection用于与数据库服务器的链接 CString conStr; //数据库连接字符串 conStr.Format(_T('Driver=SQL SERVER;Database=%s;Server=%s; UID=%s;PWD=%s;'),'test','(local)','sa','sa');//注：此为ADO连接MS SQL数据库的一种方式，如果不是MS SQL数据库则连接方式不同 /******************连接数据库********************/ try { pConnection->ConnectionTimeout = 5; //设置连接时间 pConnection->Open(_bstr_t(conStr),'','',adModeUnknown); //连接SQL SERVER } catch(_com_error e) //捕捉异常 { //AfxMessageBox(e.ErrorMessage()); return -5; } //创建数据集 m_pRecordSet.CreateInstance('ADODB.Recordset'); m_pRecordSet->CursorLocation= adUseClient; CString cmdStr; cmdStr='select pithology as 岩性,patno as 对应花纹 from Pithology_Patno'; try { m_pRecordSet->Open(_variant_t(cmdStr),_variant_t((IDispatch *)pConnection,true),adOpenKeyset, adLockOptimistic, adCmdUnknown); } catch (CException e) { CString emsg; e.GetErrorMessage((LPTSTR)&emsg,1); AfxMessageBox(emsg); return false; } m_dataGrid.SetRefDataSource(NULL); m_dataGrid.SetRefDataSource((LPUNKNOWN)m_pRecordSet); m_dataGrid.Refresh(); CoUninitialize(); 现在DataGrid控件便具有添加、删除、修改数据的功能了。 ======== 8 ADO一个完整增删改查模块的说明
增删改查4个功能做到一个界面上；
首先在对话框构造函数初始化各个成员变量； 然后是数据交换和消息映射； RefreshData函数刷新列表框的数据显示； 对话框初始化函数中设置列头和各列的宽度； 添加是调用AddNew方法实现， pRst->AddNew(vaFieldlist, vaValuelist) 很多时候也可以执行insert into 的sql语句来实现； 删除是通过执行SQL来实现： sql_.Format('DELETE FROM CP WHERE CP_NO='%s'',m_no); 查询是通过执行SQL来实现： sql.Format('SELECT * FROM CP WHERE %s='%s'', col, qry); 更新是首先获取到该条记录， sql_.Format('SELECT * FROM CP WHERE CP_NO=%s', m_no); 设置值以后调用Update， pRst->Update(vaFieldlist, vaValuelist); |
|
|
