MySQL的C++封装

　　最近的项目数据库管理系统从SQL SERVER2000迁移到了MySQL上来，之前基于ADO的连接方式连接上SQL SERVER，使用MySQL数据库管理系统之后，直接在MySQL的C语言的API上以面向对象的方式封装实现了数据库的创建，表的创建，数据库的读写操作快速搭建原型，目前没有添加连接池模块和事务处理。

　　1.MySQL的特性

　　使用C和C++编写，并使用了多种编译器进行测试，保证源代码的可移植性。

　　支持AIX、BSDi、FreeBSD、HP-UX、Linux、Mac OS、Novell NetWare、NetBSD、OpenBSD、OS/2 Wrap、Solaris、Windows等多种操作系统。

　　为多种編程语言提供了API。这些編程语言包括C、C++、C#、VB.NET、Delphi、Eiffel、Java、Perl、PHP、Python、Ruby和Tcl等。

　　支持多線程，充分利用CPU资源，支持多用户。

　　優化的SQL查询算法，有效地提高查询速度。

　　既能够作为一个单独的应用程序在客户端服务器网络环境中运行，也能够作为一个程序库而嵌入到其他的软件中。

　　提供多语言支持，常见的编码如中文的GB 2312、BIG5，日文的Shift JIS等都可以用作數據表名和數據列名。

　　提供TCP/IP、ODBC和JDBC等多种数据库连接途径。

　　提供用于管理、检查、优化数据库操作的管理工具。

　　可以处理拥有上千万条记录的大型数据库。

　　2.C++的API封装

　　用C++连接SQL有两种可直接使用的接口：MySQL Connector/C++和MySQL+ +，<1>MySQL Connector/C++是最新发布的MySQL连接器，由Sun Microsystems开发。MySQL connector为C++提供面向对象的编程接口(API)和连接MySQL Server的数据库驱动器与现存的driver不同，Connector/C++是JDBC API在C++中的实现。换句话说，Connector/C++ driver的接口主要是基于Java语言的JDBC API。Java数据库连接(JDBC)是Java连接各种数据库的业界标准。Connector/C++实现了JDBC 4.0的大部分规范。熟悉JDBC编程的C++程序开发者可以提高程序开发的效率。

　　<2>MySQL++是一个用C++封装了MySQL的C API的类库。它是建立标准C ++标准库(STL)之上，使处理数据库处理STL容器一样容易。此外，MySQL的++提供了让你避免最重复的工作，提供了原生C++接口。

　　3.MySQL的C++封装实现

　　在快速搭建原型的过程中，没有用到这两种连接方式，直接在MySQL C API上封装实现。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

#ifndef __MYSQL_INTERFACE_H__
#define __MYSQL_INTERFACE_H__

#include "winsock.h"
#include <iostream>
#include <string>
#include "mysql.h"
#include <vector>
#include <string>

#pragma comment(lib, "ws2_32.lib")
#pragma comment(lib, "libmysql.lib")
using namespace std;

class MySQLInterface
{
public:
    MySQLInterface();
    virtual ~MySQLInterface();

    bool connectMySQL(char* server, char* username, char* password, char* database,int port);
    bool createDatabase(std::string& dbname);
    bool createdbTable(const std::string& query);

    void errorIntoMySQL();
    bool writeDataToDB(string queryStr);
    bool getDatafromDB(string queryStr, std::vector<std::vector<std::string> >& data);
    void closeMySQL();

public:
    int errorNum;                    //错误代号
    const char* errorInfo;             //错误提示

private:
    MYSQL mysqlInstance;                      //MySQL对象，必备的一个数据结构
    MYSQL_RES *result;                 //用于存放结果建议用char* 数组将此结果转存
};

#endif

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118

#include "stdafx.h"
#include "MySQLInterface.h"

//构造函数初始化各个变量和数据
MySQLInterface::MySQLInterface():
    errorNum(0),errorInfo("ok")
{
    mysql_library_init(0,NULL,NULL);
    mysql_init(&mysqlInstance);
    mysql_options(&mysqlInstance,MYSQL_SET_CHARSET_NAME,"gbk");
}

MySQLInterface::~MySQLInterface()
{

}

//连接MySQL
bool MySQLInterface::connectMySQL(char* server, char* username, char* password, char* database,int port)
{
    if(mysql_real_connect(&mysqlInstance,server,username,password,database,port,0,0) != NULL)
        return true;
    else
        errorIntoMySQL();
    return false;
}
//判断数据库是否存在，不存在则创建数据库，并打开
bool MySQLInterface::createDatabase(std::string& dbname)
{
    std::string queryStr = "create database if not exists ";
    queryStr += dbname;
    if (0 == mysql_query(&mysqlInstance,queryStr.c_str()))
    {
        queryStr = "use ";
        queryStr += dbname;
        if (0 == mysql_query(&mysqlInstance,queryStr.c_str()))
        {
            return true;
        }

    }
    errorIntoMySQL();
    return false;
}
//判断数据库中是否存在相应表，不存在则创建表
bool MySQLInterface::createdbTable(const std::string& query)
{
    if (0 == mysql_query(&mysqlInstance,query.c_str()))
    {
        return true;
    }
    errorIntoMySQL();
    return false;
}

//写入数据
bool MySQLInterface::writeDataToDB(string queryStr)
{
    if(0==mysql_query(&mysqlInstance,queryStr.c_str()))
        return true;
    else
        errorIntoMySQL();
    return false;
}
//读取数据
bool MySQLInterface::getDatafromDB(string queryStr, std::vector<std::vector<std::string> >& data)
{
    if(0!=mysql_query(&mysqlInstance,queryStr.c_str()))
    {
        errorIntoMySQL();
        return false;
    }

    result=mysql_store_result(&mysqlInstance);

    int row=mysql_num_rows(result);
    int field=mysql_num_fields(result);

    MYSQL_ROW line=NULL;
    line=mysql_fetch_row(result);

    int j=0;
    std::string temp;
    while(NULL!=line)
    {
        std::vector<std::string> linedata;
        for(int i=0; i<field;i++)
        {
            if(line[i])
            {
                temp = line[i];
                linedata.push_back(temp);
            }
            else
            {
                temp = "";
                linedata.push_back(temp);
            }
        }
        line=mysql_fetch_row(result);
        data.push_back(linedata);
    }
    return true;
}

//错误信息
void MySQLInterface::errorIntoMySQL()
{
    errorNum=mysql_errno(&mysqlInstance);
    errorInfo=mysql_error(&mysqlInstance);
}

//断开连接
void MySQLInterface::closeMySQL()
{
    mysql_close(&mysqlInstance);
}

时间： 2024-09-13 21:28:44

MySQL的C++封装

MySQL的C++封装的相关文章

Zebra_Database v2.3发布面向对象MySQL数据库操作封装

Zebra_Database v2.2发布面向对象MySQL数据库操作封装

数据库-新人自学PHPmysql和mysqli对封装工具类的疑问

mysql储存函过程和储存函数都属于存储程序

MySQL源代码：从SQL语句到MySQL内部对象

Mysql 的存储过程和存储函数

中国php新动力,Jwork框架即将发表

Mysql对文件操作的封装

MYSQL的操作类（已封装）