对于一个简单的数据库应用，对于数据库的访问不是很频繁，这时在需要访问数据库时，新创建一个连接，用完后就关闭它，这样做也不会带来什么明显的性能上的开销。但是对于一个复杂的数据库应用，情况就完全不同了，频繁的建立、关闭连接，会极大的减低系统的性能，因为对于连接的使用成了系统性能的瓶颈。数据库连接池的基本原理是在内部对象池中维护一定数量的数据库连接，并对外暴露数据库连接获取和返回方法。用户使用完后将连接返回，此时连接并没有关闭，而是由连接池管理器回收，并为下一次使用做好准备。

数据库连接池负责分配、管理和释放数据库连接，它允许应用程序重复使用一个现有的数据库连接，而不是再重新建立一个；释放空闲时间超过最大空闲时间的数据库连接来避免因为没有释放数据库连接而引起的数据库连接遗漏。。这项技术能明显提高对数据库操作的性能。

mysqlpp::ConnectionPool

此类主要维护一个双向链表std::list PoolT，结构体内容包含：连接对象，是否在使用，上次使用时间，既然是链表就很容易的知道连接池当前的连接数及对连接增加删除操作

virtual Connection* exchange(const Connection* pc); //

virtual Connection* grab();　　　　　　　　　　　　　　//从连接池获取一个连接，如果没有则创建一个

Connection* safe_grab();　　　　　　　　　　　　　　  //从连接池获取一个可用的连接

virtual void release(const Connection* pc);　　　　　　//将一个连接置为未使用状态

void shrink() 　　　　　　　　　　　　　　　　　　　　　//从连接池删除未使用的连接

连接池的使用

mysqlpp::ScopedConnection

通过构造函数从连接池中获取一个Connection，析构函数将Connection对象重新放到连接池。

此类中维护了一个指向Connection指针，可以执行Connection的操作

MysqlConnectPool.h

#ifndef _MYSQL_CONNECT_POOL_H_#define _MYSQL_CONNECT_POOL_H_#include#include

class MysqlConnectPool : publicmysqlpp::ConnectionPool

{public:

MysqlConnectPool(std::stringdbname,

std::stringserverip,

std::stringuser,

std::stringpasswd,intport,

std::stringcharset)

:m_dbname(dbname)

,m_server_ip(serverip)

,m_user(user)

,m_password(passwd)

,m_charset(charset)

,m_port(port)

{

m_max_idle_time= 300;

}virtual ~MysqlConnectPool()

{

clear();

}const std::string& getDBName() const { returnm_dbname; }const std::string& getServerIP() const { returnm_server_ip; }const std::string& getUser() const { returnm_user; }const std::string& getPassword() const { returnm_password; }const std::string& getCharset() const { returnm_charset; }int getPort() const { returnm_port; }void setMaxIdleTime(intmax_idle)

{

m_max_idle_time=max_idle;

}virtual mysqlpp::Connection*grab()

{returnmysqlpp::ConnectionPool::grab();

}virtual void release(const mysqlpp::Connection*pc)

{

mysqlpp::ConnectionPool::release(pc);

}protected:virtual mysqlpp::Connection*create()

{

mysqlpp::Connection* conn = new mysqlpp::Connection(true);

mysqlpp::SetCharsetNameOption* pOpt = newmysqlpp::SetCharsetNameOption(m_charset.c_str());

conn->set_option( pOpt );

conn->connect(m_dbname.empty()? 0: m_dbname.c_str(),

m_server_ip.empty()? 0: m_server_ip.c_str(),

m_user.empty()? 0: m_user.c_str(),

m_password.empty()? "": m_password.c_str(),

m_port);returnconn;

}virtual void destroy(mysqlpp::Connection*cp)

{deletecp;

}virtual unsigned intmax_idle_time()

{returnm_max_idle_time;

}private:

std::stringm_dbname;

std::stringm_server_ip;

std::stringm_user;

std::stringm_password;

std::stringm_charset;intm_port;intm_max_idle_time;

};#endif

#include #include#include#include#include#include#include#include"MysqlConnectPool.h"std::shared_ptr db_pool =nullptr;

std::string db_name = "test";

std::string db_ip = "127.0.0.1";

std::string db_user = "root";

std::string db_passwd = "123456";int db_port = 3306;

std::string db_charset = "utf8";intmain()

{

db_pool= std::make_shared(db_name, db_ip, db_user, db_passwd, db_port, db_charset);for (int i = 0; i < 10; i++)

{try{

mysqlpp::ScopedConnection conn(*db_pool);

mysqlpp::Query query= conn->query();

//................................}catch (const mysqlpp::Exception&e) {

std::cout<< "error:" << e.what() << "\n";return false;

}

}return 0;

}