标签：

　　自从小组纳新到现在一直没有学什么东西，鼓捣了几次系统，体验了一下Fedora，最终还是选择了Centos，看到学长炫酷的SS管理，自己也把原来的格掉重新搭了一个。说好的一天一道LeetCode也荒废了，博客也好久好久没有更新了，真是罪过、罪过。现在纳新早已结束，是时候拾起自己的老本行了。周末学习了一下MySQL的C语言API，试着用C++简单的封装了一下，现在做个记录，以防遗忘。

一、重要数据结构介绍

二、C API函数介绍

　　2、void mysql_close(MYSQL *mysql);

　　3、MYSQL *mysql_real_connect(MYSQL *mysql, const char *host, const char *user, const char *passwd, const char *db, unsigned int port, const char *unix_socket, unsigned int client_flag)

　　参数说明：

　　　　（2）、host值可以是一个主机名或一个IP地址。如果host是NULL或字符串"localhost"，假定是到本地主机的一个连接。如果OS支持套接字(Unix)或命名管道(Win32)，使用他们而不是TCP/IP与服务器连接。

　　　　（3）、user参数包含用户的MySQL登录ID。如果user是NULL，假定是当前用户。在Unix下，它是当前登录名。在Windows ODBC下，必须明确地指定当前用户名字。

　　　　（4）、passwd参数为user包含口令。如果passwd是NULL，只有在user表中对于有一个空白口令字段的用户的条目将被检查一个匹配。这允许数据库主管设置MySQL权限，使用户获得不同的口令，取决于他们是否已经指定一个口令。注意：不要试图在调用mysql_real_connect()前加密口令；口令加密自动被客户API处理。

　　　　（5）、db是数据库名。

　　　　（6）、如果port不是0，值对于TCP/IP连接将用作端口号。注意host参数决定连接的类型。

　　　　（7）、如果unix_socket不是NULL，字符串指定套接字或应该被使用的命名管道。

　　　　（8）、client_flag值通常是0。

　　4、int mysql_options(MYSQL *mysql, enum mysql_option option, const char *arg);

　　5、int mysql_query(MYSQL *mysql, const char *query);

　　6、int mysql_real_query(MYSQL *mysql, const char *query, unsigned int length);

　　7、MYSQL_RES *mysql_store_result(MYSQL *mysql);

　　8、MYSQL_RES *mysql_use_result(MYSQL *mysql);

　　9、 int mysql_next_result(MYSQL *mysql);

　　10、MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);

　　11、unsigned int mysql_num_fields(MYSQL_RES *result)或unsigned int mysql_num_fields(MYSQL *mysql)。第二中形式在MySQL 3.22.24或更新版本上不能工作。为了传递一个MYSQL* 参数，你必须使用unsigned int mysql_field_count(MYSQL *mysql)。

三、使用C++通过C API封装MySQL连接库

　　该类主要实现C++对MySQL C API的简单封装，使得使用C++连接MySQL时不必直接使用C API。一来练习一下好久没有使用的C++，二来练习一下MySQL提供的C API。

myDB.h：

#ifndef _MYDB_H
#define _MYDB_H
#include <mysql/mysql.h>

class myDB {
public :
    
    myDB();    //构造函数
    //myDB()=default;
    ~myDB();   //析构函数
    
    //连接数据库(无unix_socket参数),成功返回true,失败返回false
    bool connectDB(std::string host, std::string user, std::string passwd, std::string db, unsigned int port, unsigned int flag);
    //连接数据库,成功返回true,失败返回false
    bool connectDB(std::string host, std::string user, std::string passwd, std::string db, unsigned int port, std::string unix_socket, unsigned int flag);
    bool useSqlQuery(std::string sql); //使用SQL语句查询数据库
    bool useSqlModify(std::string sql); //使用SQL语句操作数据库
    void showResult(); //逐行输出获取到的信息

private:
    MYSQL *client = nullptr;
    MYSQL_RES *resource = nullptr;
    MYSQL_ROW row;
};

#endif

#include <iostream>
#include <cstdlib>
#include "myDB.h"
#include <mysql/mysql.h>

//构造函数
myDB::myDB()
{
    if ((client = mysql_init(nullptr)) == nullptr) {
        std::cerr << "The database init failed." << std::endl;
    }
}

//析构函数
myDB::~myDB()
{
    if (resource) {
        mysql_free_result(resource);
    }

    if (client) {
        mysql_close(client);
    }
}

//连接函数
bool myDB::connectDB(std::string host, std::string user, std::string passwd, 
                std::string db, unsigned int port, std::string unix_socket, unsigned int flag)
{
    if (!mysql_real_connect(client, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, unix_socket.c_str(), flag)) {
        std::cerr << "The database connect failed:" << mysql_error(client) << std::endl;
        return false;
    }

    return true;
}

bool myDB::connectDB(std::string host, std::string user, std::string passwd, 
                std::string db, unsigned int port, unsigned int flag)
{
    if (!mysql_real_connect(client, host.c_str(), user.c_str(), passwd.c_str(), db.c_str(), port, NULL, flag)) {
        std::cerr << "The database connect failed:" << mysql_error(client) << std::endl;
        return false;
    }

    return true;
}

//使用SQL语句查询数据库
bool myDB::useSqlQuery(std::string sql)
{
    if (mysql_real_query(client, sql.c_str(), sql.size())) {
        std::cerr << "query failed:" << mysql_error(client) << std::endl;
        return false;
    }

    if ((resource = mysql_store_result(client)) == nullptr) {
        std::cerr << "store failed:" << mysql_error(client) << std::endl;
        return false;
    }

    return true;
}

//使用SQL增删改数据库的值
bool myDB::useSqlModify(std::string sql)
{
    if (mysql_real_query(client, sql.c_str(), sql.size())) {
        std::cerr << "modify failed:" << mysql_error(client) << std::endl;
        return false;
    }

    return true;
}

//逐行输出获取到的信息
void myDB::showResult()
{
    if (resource) {
        while ((row = mysql_fetch_row(resource)) != NULL) {
            for (int j = 0; j < mysql_num_fields(resource); ++j) {
                std::cout << row[j] << "\t";
            }
            std::cout << std::endl;
        }
        mysql_free_result(resource);
        resource = nullptr;
    }
}

#include <iostream>
#include <cstdlib>
#include "myDB.h"

int main(int argc, char *argv[])
{
    myDB db;
    if (db.connectDB("127.0.0.1", "root", "", "crashcourse", 3306, 0) == false) {
        std::cout << "连接失败" <<std::endl; exit(-1);
    }

    if (db.useSqlQuery("SELECT * FROM orders") != false) {
        db.showResult();
    }

    if (!db.useSqlModify("INSERT INTO customers(cust_name, cust_address, cust_city) VALUES('haha', 'nicai', 'nihao')")) {
        std::cout << "插入失败" << std::endl;
    }
    if (!db.useSqlModify("INSERT INTO customers(cust_name, cust_address, cust_city) VALUES('hh', 'nicai', 'nihao')")) {
        std::cout << "插入失败" << std::endl;
    }

    if (!db.useSqlModify("DELETE FROM customers WHERE cust_name = 'haha'")) {
        std::cout << "删除失败" << std::endl;
    }


    return EXIT_SUCCESS;
}

四、总结

　　这层封装看似简单但是在实际的应用中还是挺有用的。最显而易见的就是在一个项目中如果将不同的DBMS产品提供的语言API进行一次封装后就可以实现DBMS层的操作和持久化层操作分离，进而减少业务代码对某个DBMS提供的API的依赖。如果后期更换数据库的话只考虑更改DBMS提供的API封装这一层的代码，使得工程代码的可拓展性大大增强。

C++操作数据库

标签：

原文地址：http://blog.csdn.net/jung_zhang/article/details/51587124