C++实现MySQL数据库连接池

**C++实现MySQL数据库连接池**

在实际开发中，数据库连接是非常耗时的操作。为了提高程序的性能和效率，我们可以使用连接池来管理数据库连接。连接池是一种缓存数据库连接的机制，它可以重复利用已经建立好的连接，从而减少了每次连接和断开的时间。

在本文中，我们将使用C++语言实现一个简单的MySQL数据库连接池。

### **1. 连接池类设计**

首先，我们需要定义一个连接池类，负责管理数据库连接。这个类应该具备以下功能：

* 创建新的连接* 获取可用的连接* 归还连接

cpp// mysql_pool.h#ifndef MYSQL_POOL_H#define MYSQL_POOL_H#include 
#include 

class MySQLPool {
public:
 // 构造函数 MySQLPool(int maxConnections, const char* host, const char* user, const char* password, const char* database);

 // 销毁函数 ~MySQLPool();

 // 获取可用的连接 MYSQL* getConnection();

 // 归还连接 void returnConnection(MYSQL* connection);

private:
 int maxConnections_;
 std::list connections_;
};

#endif // MYSQL_POOL_H

cpp// mysql_pool.cpp#include "mysql_pool.h"
#include <iostream>

MySQLPool::MySQLPool(int maxConnections, const char* host, const char* user, const char* password, const char* database)
 : maxConnections_(maxConnections) {
 // 创建新的连接 for (int i =0; i < maxConnections_; ++i) {
 MYSQL* connection = mysql_init(NULL);
 if (!mysql_real_connect(connection, host, user, password, database,0, NULL,0)) {
 std::cerr << "Error connecting to MySQL: " << mysql_error(connection) << std::endl;
 mysql_close(connection);
 return;
 }
 connections_.push_back(connection);
 }
}

MySQLPool::~MySQLPool() {
 // 销毁函数 for (auto connection : connections_) {
 mysql_close(connection);
 }
}

MYSQL* MySQLPool::getConnection() {
 if (!connections_.empty()) {
 MYSQL* connection = connections_.front();
 connections_.pop_front();
 return connection;
 } else {
 std::cerr << "Error: No available connections in pool." << std::endl;
 return NULL;
 }
}

void MySQLPool::returnConnection(MYSQL* connection) {
 if (connection != NULL) {
 connections_.push_back(connection);
 }
}

cpp// main.cpp#include "mysql_pool.h"
#include <iostream>

int main() {
 MySQLPool pool(10, "localhost", "root", "", "test");

 MYSQL* connection = pool.getConnection();
 if (connection != NULL) {
 std::cout << "Connected to MySQL." << std::endl;
 // 使用连接进行数据库操作 mysql_query(connection, "SELECT * FROM test_table");
 // 归还连接 pool.returnConnection(connection);
 } else {
 std::cerr << "Error: Unable to get a connection from the pool." << std::endl;
 }

 return0;
}