連接池為了解決頻繁的創建、銷毀所帶來的系統開銷。
簡而言之，就是 自己先創建一定量的連接，然后在需要的時候取出一條連接使用。
當然如果你只有一個線程連接數據庫，而且不是實時返回結果，那么你完全不必用連接池。
想一下網絡大型游戲服務器，你就明白為什么需要連接池了。
自己敲代碼寫了一個簡單的類，實現連接池，雖然沒有mysql++那么強大，但是還是自己有收獲。
Csqlpool.h 頭文件實現如下：
#pragma once#include#include #include #pragma comment( lib , "libmysql.lib" )using namespace std;class Csqlpool{public: ~Csqlpool(void); static Csqlpool *GetSqlPool(); bool IniSqlPool( const char *host , const char *name , const char *pwd , unsigned int port , unsigned int conMax ); //初始化連接池 bool SelectDB( MYSQL *sql, const char *DB); //選擇數據庫 MYSQL *GetConnect(); // 獲取連接 void RelConnect(MYSQL *sql) ; // 釋放連接 MYSQL_RES* GetQuery( MYSQL *sql , const char *query); //mysql操作 增刪查改 void RelQuery(MYSQL_RES *res); //釋放MYSQL_RES資源 bool Query(MYSQL *sql , const char *query); //增、刪、改操作protected: Csqlpool(void);private: list
m_sql_free; //空閑連接 static Csqlpool *pSqlPool; CRITICAL_SECTION m_session; //獲取空閑線程};
#include "StdAfx.h"#include "Csqlpool.h"Csqlpool *Csqlpool::pSqlPool = NULL;Csqlpool::Csqlpool(void){ InitializeCriticalSection( &m_session );}Csqlpool::~Csqlpool(void){ while ( m_sql_free.size() ) { mysql_close( m_sql_free.front() ); m_sql_free.pop_front(); } DeleteCriticalSection(&m_session);}Csqlpool* Csqlpool::GetSqlPool(){ if ( pSqlPool == NULL ) { return new Csqlpool; } return pSqlPool;}bool Csqlpool::IniSqlPool( const char *host ,const char *name , const char *pwd , unsigned int port , unsigned int conMax ) //初始化連接池{ int nsum = 0 ; for (unsigned int i = 0 ; i < conMax ;++i ) { MYSQL *pmysql; pmysql = mysql_init( (MYSQL*)NULL ); if ( pmysql != NULL ) { if ( mysql_real_connect( pmysql , host , name , pwd , NULL , 3306 , NULL , 0 ) ) { m_sql_free.push_back(pmysql); } else { if ( nsum++ == 100 ) { return false; } continue; } } continue; } return true;}bool Csqlpool::SelectDB( MYSQL *sql, const char *DB) //選擇數據庫{ if(mysql_select_db(sql , DB)) { return false; } return true;}MYSQL* Csqlpool::GetConnect() // 獲取連接{ if ( m_sql_free.size() ) { EnterCriticalSection(&m_session); MYSQL *mysql = m_sql_free.front(); m_sql_free.pop_front(); LeaveCriticalSection(&m_session); return mysql; } else return NULL;}void Csqlpool::RelConnect(MYSQL *sql) // 釋放連接{ EnterCriticalSection(&m_session); m_sql_free.push_back(sql); LeaveCriticalSection(&m_session);}MYSQL_RES* Csqlpool::GetQuery( MYSQL *sql , const char *query) //查詢操作{ if ( mysql_query( sql , query ) == 0 ) { return mysql_store_result( sql ); } else return NULL;}void Csqlpool::RelQuery(MYSQL_RES *res) //mysql_res release{ mysql_free_result(res);}bool Csqlpool::Query(MYSQL *sql , const char *query) //增、刪、改操作{ if ( mysql_query( sql , query ) ) { return false; } return true;}testsqlpool.cpp 測試文件實現如下：
