欢迎您访问 最编程 本站为您分享编程语言代码,编程技术文章!
您现在的位置是: 首页

使用 mysqlclient 库用 c++ 开发 mysql 封装的客户端

最编程 2024-05-05 10:36:39
...

一般都是封装一个客户端类进行开发,如下的mysql.h:

#pragma once
#include <mysql/mysql.h>
#include <string>
#include <iostream>

// 数据库操作类
class MySQL {
public:
    MySQL(); // 初始化数据库连接资源
    ~MySQL(); // 释放数据库连接资源
    bool connect(); // 连接数据库
    bool update(std::string sql); // 更新(insert, delete, update都是这个接口)
    MYSQL_RES *query(std::string sql); // 查询操作
    MYSQL* getConnection();     // 获取连接
private:
    MYSQL *_conn; //一条连接
};

mysql.cpp如下:

#include "mysql.h"

// 数据库配置信息
static std::string server = "127.0.0.1";
static uint16_t port = 3306;
static std::string user = "root";
static std::string password = "123456";
static std::string dbname = "chat";

// 初始化数据库连接资源
MySQL::MySQL() {
    _conn = mysql_init(nullptr);
}

// 释放数据库连接资源
MySQL::~MySQL() {
    if (_conn) {
        mysql_close(_conn);
    }
}

// 连接数据库
bool MySQL::connect() {
    MYSQL *p = mysql_real_connect(_conn, server.c_str(), user.c_str(), password.c_str(), dbname.c_str(), port, nullptr, 0);
    if (p) {
        // C和C++代码默认的编码字符是ASCII,如果不设置,从MySQL上拉下来的中文会乱码
        mysql_query(_conn, "set names gbk");
        std::cout << "connect mysql success!" << std::endl;
    } 
    else {
        std::cout << "connect mysql failed!" << std::endl;
    }
    return p; //空不就是false吗
}

// 更新(insert,delete,update都是这个接口)
bool MySQL::update(std::string sql) {
    if (mysql_query(_conn, sql.c_str())) {
        std::cout << __FILE__ << ":" << __LINE__ << ":" << sql << "更新失败!" << std::endl;
        return false;
    }
    std::cout << __FILE__ << ":" << __LINE__ << ":" << sql << "更新成功!" << std::endl;
    return true;
}

// 查询操作
MYSQL_RES *MySQL::query(std::string sql) {
    if (mysql_query(_conn, sql.c_str())) {
        std::cout << __FILE__ << ":" << __LINE__ << ":" << sql << "查询失败!" << std::endl;
        return nullptr;
    }
    return mysql_use_result(_conn);
}

// 获取连接
MYSQL* MySQL::getConnection() {
    return _conn;
}

推荐阅读