MFC中用Ado连接数据库

简介:

MFC中用Ado连接数据库

一、数据库操作准备
1、导入ADO动态链接库
   在工程的stdafx.h中加入如下语句:
   #import "c:\program files\common files\system\ado\msado15.dll" no_namespace\

   rename("EOF","adoEOF")
        这一语句有何作用呢?其最终作用同我们熟悉的#include类似,编译的时候系统会为我们生成msado15.tlhmsado15.tli两个C++头文件来定义ADO库,即加载ADO动态库(msado15.dll)

        其中,no_namespace表明不使用命名空间,rename("EOF","adoEOF")表明把ADO中用到的EOF改为adoEOF,防止发生命名冲突。

        注意:该代码需要在一行中完成,如果写成两行或者多行,行末要加上“\”符号,表示把这几行看成一行,如本例。


2、初始化OLE/COM库环境

        在基于MFC的应用里,初始化OLE/COM库环境的一个比较好的位置是在应用类的InitInstance成员函数中,而且直接使用AfxOleInit在退出应用时,该函数也负责COM资源的释放,将此函数添加在InitInstance中的如下位置:

BOOL CExpApp::InitInstance()
{
       AfxEnableControlContainer();
       //初始化OLE DLLs
       if(!AfxOleInit())
       {
           AfxMessageBox("初始化OLE DLL失败!");
           Return FALSE;
        }
       ......
}

        说明:也可以在InitInstance中使用::CoInitialize初始化OLE/COM库环境,但须在ExitInitInstance中使用::CoUninitialize释放占用的COM资源,显然使用AfxOleInit更为方便。


3、连接数据库

     在Doc\View程序中,通常在应用类(App类)中进行数据库的连接

     1)声明一个Connection指针

          _ConnectionPtr m_pConnection;

           注:ADO最重要的三个对象有三个:连接对象(Connection)、命令对象(Command)和记录集对象(RecordSet)。在使用这三个对象的时候,需要定义与之相对应的智能指针,分别为_ConnectionPtr_CommandPtr_RecordsetPtr

                   由上述ConnectionPtr指针的使用步骤可知,C++中的类指针使用方法一样,智能指针也要先定义指针变量、创建其实例(实例化),然后就可以调用它的方法和属性。不同的是,该智能指针最后是自动进行内存释放的。

                    所有的智能指针都是基于_com_ptr_t模板类的,该类封装了IUnknow接口的3个方法:QueryInterfaceAddrefRelease。它具有自动计数的机制,即在构造对象时,自动为该对象计数加1析构对象时,自动调用Release方法。(即该类型的指针在使用后不需要手动释放内存)(但需要调用Close方法,关闭连接或者记录集)所以智能指针会使代码更加简洁并且不易出错。

      2)创建Connection对象

            m_pConnection.CreateInstance(__uuidof(Connection));
            

            m_pConnection.CreateInstance("ADODB.Connection");

           上述两种方法均可。

            注意:上面调用_ConnectionPtr接口指针的方法CreateInstance时,用的是“.”而非

“->”

       3)设置连接字符串,以便指定需要的连接

             3.1) 使用JET数据库引擎实现对Acess2000类型的数据库info.mdb的连接

CString strSQL="Provider=Microsoft.Jet.OLEDB.4.0;Data Source=info.mdb;User ID=admin;Passward=;";

或者

CString strSQL=_T("Provider=Microsoft.Jet.OLEDB.4.0;Data Source=info.mdb;User ID=admin;Passward=;");

             3.2) 使用OLE DB提供者实现对SQL Server的标准安全连接串

strConnect=_T("Provider=sqloledb;Data Source=MyServerName;"

                       "Initial Catalog=MyDateBaseName;"

                       "User ID=MyUserName;Password=MyPassword;");

例程:strConnection="Provider=SQLOLEDB;DataSource=local;InitialCatalog=DVDRentDB_Data.MDF;"

                           "User ID=sa;Password=820415";

m_pConnection->Open((_bstr_t)strSQL,"","",adModeUnknown);

或者是在此处不设置User IDPassword,而直接在Open的第23个参数中设置。

strConnection="Provider=SQLOLEDB;DataSource=local;InitialCatalog=DVDRentDB_Data.MDF";

m_pConnection->Open((_bstr_t)strSQL,"sa","820415",adModeUnknown);

注意:上面设置连接字符串的时候,如果过长需要分行时,则每一行都要加上双引号,在最后加上分号即可。

如果是本地服务器,则DataSource=local或本地服务器名均可

若数据库没有设置密码,在连接字符串中可以将其省略,但User ID不能省

若数据库和程序文件不在同一文件夹下,直接写数据库名即可,在InitialCatalog中不需加上该数据库的存储器地址

             3.3) 使用OLE DB提供者实现对远程SQL Server的标准安全连接串

strConnect=_T("Provider=sqloledb;Network Library=DBMSSOCN;"

                        "Data Source=130.120.110.001,1433;"

                       "Initial Catalog=MyDateBaseName;"

                        "User ID=MyUserName;Password=MyPassword;");

      4)、使用m_pConnectionOpen方法实现对数据库的连接

       在ADO的操作中建议使用try...catch( )来捕获错误信息,因为它有时会经常出现一些意想不到的错误

try
{
         m_pConnection->Open( (_bstr_t) strSQL," "," ",adModeUnknown);
}
catch(_com_error e)         //捕捉异常
{
         CString strError;
         strError.Format( "连接数据库发生异常! \r \n错误信息:%s",e.ErrorMessage( ) );
         AfxMessageBox(errormessage);         //显示错误信息
}

4、关闭连接

      一般重载App类的ExitInstace( )函数实现

      调用m_pConnectionClose方法关闭连接即可

      m_pConnection->Close( );

      m_pConnection=NULL;

      注意:由于初始化COM库调用的是AfxOleInit,这种方法初始化COM库的优点就在于资源    的释放也是自动进行的,所以不必担心资源泄漏的问题。

二、数据库操作

       ADO库中包含的三个基本接口为_ConnectionPtr接口、_CommandPtr接口、_RecordsetPtr接口。

      1_ConnectionPtr接口

            该接口返回一个记录集或一个空指针。

            通常用它来创建一个数据库连接,或执行一条不返回任何结果的SQL语句,如一个存储过程。

            不推荐使用_ConnectionPtr接口返回一个记录集,对于要返回记录集的操作通常用_RecordsetPtr来实现,而且使用_ConnectionPtr时要想得到记录数目必须遍历所有记录,但使用_RecordsetPtr时则不需要。

     2_CommandPtr接口

      该接口返回一个记录集。

      它提供了一种简单的方法来执行返回记录集的存储过程和SQL语句。

      在使用_CommandPtr接口时,可以利用全局_ConnectionPtr接口,也可以在_CommandPtr

接口里直接使用连接串。如果只执行一次或者几次数据库访问操作,后者是比较好的选择。但是,如果频繁访问数据库,并要返回很多记录集,那么应该使用全局_ConnectionPtr接口创建一个数据库连接,然后使用_CommandPtr接口执行存储过程和SQL语句

       3_RecordsetPtr接口

       该接口是一个记录集对象。

       与前两种对象相比,它对记录集提供了更多的控制功能,如记录锁定、游标控制等。同_CommandPtr接口一样,它不一定要使用一个已经创建的数据库连接,可以用一个连接串代替连接指针赋给_RecordsetPtrconnection成员变量,让它自己创建数据库连接。如果使用多个记录集,最好的方法是同Command对象一样使用已经创建了数据连接的全局_ConnectionPtr接口,然后使用_RecordsetPtr执行存储过程和SQL语句。

        注意:可以使用Recordset对象来执行查询命令,但如果查询或者存储过程是需要参数的,这时就只能使用Command对象

        使用Recordset对象操作数据库:

       假定已经成功使用Connection对象创建了数据源的连接,连接指针为m_pConnection

       1)创建记录集

              声明记录集指针        _RecordsetPtr    m_pRecordset;

              创建记录集                m_pRecordset.CreateInstance(__uuidof(Recordset));

       2)打开记录集

               记录集指针创建完毕后,调用该指针的Open方法打开记录集。

               该函数声明如下:

                                 HRESULT Recordset15::Open ( const _variant_t & Source, 

                                                                                          const _variant_t & ActiveConnection,

                                                                                          enum CursorTypeEnum CursorType,

                                                                                          enum LockTypeEnum LockType,

                                                                                          long Options ) ;

               各个参数的含义如下:

                参数Source:为_variant_t类型的引用,可以为有效的Command对象、SQL语句、表名、存储过程调用等。

                参数ActiveConnection:为_variant_t类型的引用,为已经建立好的连接。

               参数CursorType:用于设置在打开Recordset时提供者应使用的游标类型,它可取CursorTypeEnum 中的任一值,默认值为adOpenForwardOnly

               参数 LockType:用于设置在打开Recordset时提供者应使用的锁定类型,它可取枚举LockTypeEnum中的任一值,默认值为adLockReadOnly

               参数 Options:用于设置获取Source(即Open第一个参数)的方式,其类型long

 

 

 

       例程1: CString strSQL = "select * from mytablename";

                     m_pRecordset->Open ( _variant_t (strSQL),

                                                               m_pConnection.GetInterfacePtr( ),
                                                               adOpenDynamic,
                                                               adLockOptimistic,
                                                               adCmdText ) ;

              使用SQL语句作为Open方法的第一个参数Source的值,此时OptionsadCmdText

       例程2    m_pRecordset->Open ( _variant_t ("tbDVDInfo") ),

                                                                  m_pConnection.GetInterfacePtr( ),
                                                                  adOpenDynamic,
                                                                  adLockOptimistic,
                                                                  adCmdTable ) ;

                  直接使用表名作为第一个参数,此时Options应为adCmdTable

       3)遍历记录集

        一般在返回记录集时,通常要遍历结果记录集,以便查看或编辑某一条记录,Recoreset指针提供了几个用于实现遍历的方法。

 

       注意:为了避免发生异常,一般在使用MoveFirstMovePrev之前,需要使用记录集的指针BOF属性来检测当前的记录集指针是否位于第一条记录之前;在使用MoveLastMoveNext之前需要使用记录集指针的EOF属性来检测当前的记录集指针是否位于最后一条记录之后

       4)记录集定位

            记录集接口类提供了两种定位方法:绝对定位和书签定位

            前者通过设置或者获取AbsolutePosition属性即可,其值从1开始,并且当前记录为记录集中第一条记录时等于1

            对于后者可以通过设置或获取BookMark属性即可

       5)访问记录集

            最简单的方法是直接使用如下语句:

            m_pRecordset->GetCollect (字段名);

            设置字段值:

            m_pRecordset->PutCollect (字段名,新值);

两个方法的原型:

_variant_t GetCollect ( const _variant_t & Index )

void PutCollect ( const _variant_t & Index , const _variant_t &pvar )

其中:参数Index可以是字符串表示字段名,也可以是整型,表示字段对应的序号。

            pvar表示要写入的变量值。

例如:

         _variant_t var;

         var=m_pRentRecordset->GetCollect("ID");
         var=m_pRentRecordset->GetCollect(long(0));   都可以

       6)记录集更新

            更新记录集包括添加新的记录、编辑当前记录和删除当前记录

            记录集接口指针对这三种操作分别提供了相应的方法

            添加新的记录:AddNew

            编辑当前记录:Edit

            删除当前记录:Delete

            注意:记录集接口指针针对AddNew以及Edit方法提供了Update方法,用于在数据库中更新新添加或者编辑后的记录

            AddNew方法:用于添加新纪录(该添加是直接在表的末尾续加的),该方法可以使用参数,在参数中指定要添加的新纪录;也可以不使用参数,而在后面使用PutCollect方法,并需使用Update函数保存新纪录。

            Update方法:用于保存从调用AddNew方法以来所作的任何更改。

//++++++++++++++++++++++++++++++++++++++++++
//在表的末尾增加新纪录
        m_pRecordset->AddNew();
//++++++++++++++++++++++++++++++++++++++++++
        m_pRecordset->PutCollect("姓名",_variant_t(m_strName));

        m_pRecordset->PutCollect("工作单位",_variant_t(m_strComName));
        m_pRecordset->PutCollect("单位地址",_variant_t(m_strComAddr));

//更新数据库-将新纪录存入数据库
        m_pRecordset->Update();

       7)记录集关闭

            在对记录集的操作完成后,必须及时关闭记录集。

            if ( m_pRecordset != NULL )

            {

                     m_pRecordset ->Close( );

                     m_pRecordset =NULL;

            }

 


本文转自农夫山泉别墅博客园博客,原文链接:http://www.cnblogs.com/yaowen/archive/2013/01/05/2846027.html,如需转载请自行联系原作者

相关文章
|
1月前
|
SQL 开发框架 .NET
ASP.NET连接SQL数据库:详细步骤与最佳实践指南ali01n.xinmi1009fan.com
随着Web开发技术的不断进步,ASP.NET已成为一种非常流行的Web应用程序开发框架。在ASP.NET项目中,我们经常需要与数据库进行交互,特别是SQL数据库。本文将详细介绍如何在ASP.NET项目中连接SQL数据库,并提供最佳实践指南以确保开发过程的稳定性和效率。一、准备工作在开始之前,请确保您
157 3
|
21天前
|
关系型数据库 MySQL 数据库连接
python脚本:连接数据库,检查直播流是否可用
【10月更文挑战第13天】本脚本使用 `mysql-connector-python` 连接MySQL数据库,检查 `live_streams` 表中每个直播流URL的可用性。通过 `requests` 库发送HTTP请求,输出每个URL的检查结果。需安装 `mysql-connector-python` 和 `requests` 库,并配置数据库连接参数。
120 68
|
17天前
|
SQL Java 数据库连接
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率。本文介绍了连接池的工作原理、优势及实现方法,并提供了HikariCP的示例代码。
31 3
|
24天前
|
关系型数据库 MySQL 数据库连接
DBeaver如何连接一个数据库
【10月更文挑战第27天】DBeaver 是一款功能强大的通用数据库管理工具,支持多种主流数据库。本文介绍了使用 DBeaver 连接数据库的基本步骤,包括下载安装、创建新连接、选择数据库类型、配置连接参数、测试连接以及最终连接到数据库。详细的操作指南帮助用户轻松管理和操作数据库。
123 9
|
17天前
|
Java 数据库连接 数据库
深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销,从而显著提升系统性能
在Java应用开发中,数据库操作常成为性能瓶颈。本文通过问题解答形式,深入探讨Java连接池技术如何通过复用数据库连接、减少连接建立和断开的开销,从而显著提升系统性能。文章介绍了连接池的优势、选择和使用方法,以及优化配置的技巧。
16 1
|
17天前
|
Java 数据库连接 数据库
Java连接池在数据库性能优化中的重要作用。连接池通过预先创建和管理数据库连接,避免了频繁创建和关闭连接的开销
本文深入探讨了Java连接池在数据库性能优化中的重要作用。连接池通过预先创建和管理数据库连接,避免了频繁创建和关闭连接的开销,显著提升了系统的响应速度和吞吐量。文章介绍了连接池的工作原理,并以HikariCP为例,展示了如何在Java应用中使用连接池。通过合理配置和优化,连接池技术能够有效提升应用性能。
32 1
|
25天前
|
SQL JavaScript 关系型数据库
node博客小项目:接口开发、连接mysql数据库
【10月更文挑战第14天】node博客小项目:接口开发、连接mysql数据库
|
1月前
|
Java 关系型数据库 MySQL
springboot学习五:springboot整合Mybatis 连接 mysql数据库
这篇文章是关于如何使用Spring Boot整合MyBatis来连接MySQL数据库,并进行基本的增删改查操作的教程。
68 0
springboot学习五:springboot整合Mybatis 连接 mysql数据库
|
20天前
|
SQL 关系型数据库 数据库连接
"Nacos 2.1.0版本数据库配置写入难题破解攻略:一步步教你排查连接、权限和配置问题,重启服务轻松解决!"
【10月更文挑战第23天】在使用Nacos 2.1.0版本时,可能会遇到无法将配置信息写入数据库的问题。本文将引导你逐步解决这一问题,包括检查数据库连接、用户权限、Nacos配置文件,并提供示例代码和详细步骤。通过这些方法,你可以有效解决配置写入失败的问题。
44 0
|
1月前
|
SQL 存储 监控
串口调试助手连接SQL数据库的技巧与方法
串口调试助手是电子工程师和软件开发人员常用的工具,它能够帮助用户进行串口通信的调试和数据分析