連接池為了解決頻繁的創(chuàng)建、銷毀所帶來的系統(tǒng)開銷。
簡而言之，就是 自己先創(chuàng)建一定量的連接，然后在需要的時(shí)候取出一條連接使用。
當(dāng)然如果你只有一個(gè)線程連接數(shù)據(jù)庫，而且不是實(shí)時(shí)返回結(jié)果，那么你完全不必用連接池。
想一下網(wǎng)絡(luò)大型游戲服務(wù)器，你就明白為什么需要連接池了。
自己敲代碼寫了一個(gè)簡單的類，實(shí)現(xiàn)連接池，雖然沒有mysql++那么強(qiáng)大，但是還是自己有收獲。
Csqlpool.h 頭文件實(shí)現(xiàn)如下：
#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); //選擇數(shù)據(jù)庫 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) //選擇數(shù)據(jù)庫{ 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 測(cè)試文件實(shí)現(xiàn)如下：
