C++操作mysql方法总结(2)

C++通过ODBC和通过MFC ODBC操作mysql的两种方式

使用vs2013和64位的msql 5.6.16进行操作

项目中使用的数据库名和表数据请参考C++操作mysql方法总结(1)中的介绍

既然使用到了ODBC那么就要需要添加数据源了

控制面板->管理工具->数据源->用户DSN->添加

填写相关的数据库连接配置和使用的数据库,可点击Test进行测试,查看是否成功连接,设置完成后点击OK

其中Data Source Name即MySqlODBC我们会在连接数据库时用到

至此,数据源添加完毕

一、通过ODBC进行操作

开放数据库互连(Open Database Connectivity,ODBC)是微软提供的一组用于数据库访问的规范接口,多数数据库都提供了ODBC驱动

1、新建一个空项目

2、如果使用的mysql是64位的,需要将项目的解决方案平台由win32改成x64

至此,相关配置全部完成

程序代码

main.cpp

#include <Windows.h>
#include <iostream>
#include <iomanip>
#include <sql.h>
#include <odbcss.h>
#include <sqlext.h>
#define MAXBUFLEN   255 
#define MaxNameLen  20

#import "c:\program files\common files\system\ado\msado15.dll" no_namespace rename("EOF", "adoEOF")

SQLHENV  henv = SQL_NULL_HENV;//定义环境句柄
SQLHDBC  hdbc1 = SQL_NULL_HDBC;//定义数据库连接句柄     
SQLHSTMT  hstmt1 = SQL_NULL_HSTMT;//定义语句句柄

using namespace std;
int main()
{
    RETCODE retcode;//错误返回码
    retcode = SQLAllocHandle(SQL_HANDLE_ENV, NULL, &henv);
    if (retcode < 0)//错误处理
    {
        cout << "allocate ODBC Environment handle errors." << endl;
        return -1;
    }
    retcode = SQLSetEnvAttr(henv, SQL_ATTR_ODBC_VERSION,
        (SQLPOINTER)SQL_OV_ODBC3, SQL_IS_INTEGER);
    if (retcode < 0) //错误处理
    {
        cout << "the  ODBC is not version3.0 " << endl;
        return -1;
    }
    retcode = SQLAllocHandle(SQL_HANDLE_DBC, henv, &hdbc1);
    if (retcode < 0) //错误处理
    {
        cout << "allocate ODBC connection handle errors." << endl;
        return -1;
    }

    char* szDSN = "MySqlODBC";//添加数据源时,为其起的名字
    char* szUID = "root";
    char* szAuthStr = "123456";

    retcode = SQLConnect(hdbc1,
                        (SQLCHAR*)szDSN, 
                        (SWORD)strlen(szDSN), 
                        (SQLCHAR*)szUID, 
                        (SWORD)strlen(szUID), 
                        (SQLCHAR*)
                        szAuthStr,
                        (SWORD)strlen(szAuthStr));

    if (retcode < 0) //错误处理
    {
        cout << "connect to  ODBC datasource errors." << endl;
        return -1;
    }

    retcode = SQLAllocHandle(SQL_HANDLE_STMT, hdbc1, &hstmt1);
    if (retcode < 0) 
    {
        cout << "allocate ODBC statement handle errors." << endl;
        return -1;
    }
    retcode = SQLExecDirect(hstmt1, (SQLCHAR*)"SElECT *  FROM book", SQL_NTS);
    if (retcode < 0)
    {
        cout << "Executing statement  throught ODBC  errors." << endl;
        return -1;
    }
    SQLCHAR      bookname[MaxNameLen + 1];
    SQLCHAR         size[MaxNameLen + 1];
    SQLLEN         columnLen = 0;

    retcode = SQLBindCol(hstmt1, 2, SQL_C_CHAR, bookname, MaxNameLen, &columnLen);
    retcode = SQLBindCol(hstmt1, 3, SQL_C_CHAR, size, MaxNameLen, &columnLen);
    while ((retcode = SQLFetch(hstmt1)) != SQL_NO_DATA)
    {
        cout <<setw(9) <<"BookName:" << bookname << endl;
        cout << setw(9) << "Size:" << size << endl;
    }
    system("pause");
}

运行结果

一、通过MFC ODBC进行操作

MFC提供了对ODBC进行了封装,使得利用MFC创建ODBC的应用程序变得简单

1、新建一个win32的控制台应用程序

2、进行以下修改

MFC的使用:在共享DLL中使用MFC

字符集:使用Unicode字符集

3、如果使用的mysql是64位的,需要将项目的解决方案平台由win32改成x64

至此,相关配置全部完成

程序代码

main.cpp

#include "stdafx.h"
#include "afxdb.h"
#include <iostream>
#include <iomanip>
using namespace std;
int _tmain(int argc, _TCHAR* argv[])
{
    CDatabase db;

    if (!db.IsOpen())//判断数据库是否已经被打开
    {

        BOOL bflag=     db.Open(NULL, FALSE, FALSE, _T("ODBC;DSN=MySqlODBC;UID=root;PWD=123456"));    
        if (!bflag)
        {
            cout << "ERROR" << endl;
        }
    }

    CRecordset rs(&db);
    CString str;
    str.Format(L"select * from book");
    try
    {
        rs.Open(CRecordset::forwardOnly, (L"%s", str));
        short nFields = rs.GetODBCFieldCount();
        while (!rs.IsEOF())
        {

            CDBVariant varValue;
            rs.GetFieldValue(L"bookname", varValue);
            cout << setw(9) << "BookName:" << *varValue.m_pstringA << endl;
            rs.GetFieldValue(L"size", varValue);
            cout << setw(9) << "Size:" << *varValue.m_pstringA << endl;
            rs.MoveNext();
        }
    }
    catch (...)
    {
        cout << "ERRPR" << endl;
    }

    db.Close();
    system("pause");
}

运行结果

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏杨建荣的学习笔记

关于修改分区表的准备和操作细则(r3笔记26天)

在之前的博文中,讨论过一个根据分区键值发现性能问题的案例。90%以上的数据都分布在了一个分区上,其它的分区要么没有数据要么数据很少,这是很明显的分区问题。当然这...

3066
来自专栏杨建荣的学习笔记

使用logon trigger完成动态的session跟踪(r4笔记第29天)

在之前讨论过 关于oracle中session跟踪的总结,可以参见链接 http://blog.itpub.net/23718752/viewspace-115...

2874
来自专栏大内老A

谈谈基于Kerberos的Windows Network Authentication[下篇]

六、User2User Sub-Protocol:有效地保障Server的安全 通过3个Sub-protocol的介绍,我们可以全面地掌握整个Kerberos的...

2297
来自专栏数据和云

时过境迁:Oracle跨平台迁移之XTTS方案与实践

作者简介 ? 谢金融 云和恩墨东区交付部 Oracle 工程师,多年来从事 Oracle 第三方服务,曾服务过金融、制造业、物流、政府等许多行业的客户,精通数据...

1.2K10
来自专栏杨建荣的学习笔记

物化视图prebuilt和在线重定义 (r10笔记第25天)

数据迁移中有一种解决方案很有亮点,如果表的数据量大,迁移涉及的表不多,同时对于维护时间有要求的情况下,物化视图的prebuilt方式就是一种很不错的选择。 大体...

3624
来自专栏重庆的技术分享区

如何在Debian 8上安装MySQL

MySQL是一种流行的数据库管理系统,用于Web和服务器应用程序。本指南将介绍如何在运行Debian 8(Jessie)的Linode上安装,配置和管理MySQ...

8772
来自专栏性能与架构

MySql 查看Query Cache的状态

query cache 是mysql性能优化时的重要指标,通过查看query cache的状态信息,就可以知道例如 缓存是否有碎片、命中缓存的数量、没用到缓存的...

3767
来自专栏乐沙弥的世界

Oracle OWI 等待事件历史视图及相关视图

    Oracle提供的等待事件视图使得我们可以获取指定session以及实例级别等待事件的详细信息,这些视图分别是v$session_wait,v$sess...

844
来自专栏乐沙弥的世界

Oracle 数据库实例启动关闭过程

Oracle数据库实例的启动,严格来说应该是实例的启动,数据库仅仅是在实例启动后进行装载。Oracle数据启动的过程被划分为

1504
来自专栏做全栈攻城狮

C#(Net)软件开发常用工具汇总,提高你的开发效率

作为C#语言官方的开发工具,VS的强大只有在多种语言开发工具使用之后,你才会明白VS的强大之处。可谓神器。其中,开发工具尽量选择版本高的。数据库尽量选择版本低的...

1752

扫码关注云+社区

领取腾讯云代金券