专栏首页magicsoarC++操作mysql方法总结(2)

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 条评论
登录 后参与评论

相关文章

  • C++获取private的变量-偷走private

    private提供了对数据的封装,使得private成员只能被类自身的成员函数以及类的友元访问,其他的函数或者类想要访问private成员只能通过该类所提供的s...

    magicsoar
  • Effective Modern C++翻译(3)-条款2:明白auto类型推导

    条款2 明白auto类型推导 如果你已经读完了条款1中有关模板类型推导的内容,那么你几乎已经知道了所有关于auto类型推导的事情,因为除了一个古怪的例外,aut...

    magicsoar
  • 使用windows live writer发表的博客

    试插入代码 #include <iostream.h> using namespace std; int main() { cout<<"hell...

    magicsoar
  • Netty 100万级高并发服务器配置

    每一种该语言在某些极限情况下的表现一般都不太一样,那么我常用的Java语言,在达到100万个并发连接情况下,会怎么样呢,有些好奇,更有些期盼。

    java架构师
  • 产品岗秋招提前批面经-上篇(含阿里美团头条...)

    你要尽全力保护你的梦想。那些嘲笑你梦想的人,他们必定会失败,他们想把你变成和他们一样的人。我坚信,只要我心中有梦想,我就会与众不同。你也是。——《当幸福来敲门》

    牛客网
  • c++ fstream + string 处理大数据

    起因 (1)之前处理文本数据时,各种清洗数据用的都是java的File,FileReader/FileWriter,BufferedReader/Buffer...

    CSDN技术头条
  • 【专业技术】linux下socket编程

    1. 网络中进程之间如何通信 进程通信的概念最初来源于单机系统。由于每个进程都在自己的地址范围内运行,为保证两个相互通信的进程之间既互不干扰又协调一致工作,操作...

    程序员互动联盟
  • 【总结】牛客职播第十期:程盟有你,way来可期

    Zoctopus
  • 倍福TwinCAT 3.1无缝集成 PLC 和机器人控制

    在 2014 年慕尼黑国际机器人及自动化技术贸易博览会(Automatica 2014)上,Beckhoff 和 KUKA 展示了一个崭新的通用接口。TwinC...

    机器人网
  • diff命令

    接手别人的工作,想把一些操作集成到ansible管理,但是因为之前同事没留下任何文档,只能自己摸着石头过河。编写playbook要清楚某些配置文件做了哪些改动,...

    阿dai学长

扫码关注云+社区

领取腾讯云代金券