mysql Connector C/C++ 多線程封裝

mysql Connector C/C++ 多線程封裝

在網上找了好久，有很多封裝，但是感覺對多線程處理的不多，都不是很理想。封裝完的第一個版本，想法比較簡單，使用一個單例模式，對應一個連接，多線程查詢的時候都是在這個鏈接上完成，如下簡略代碼

class DbClass
{
public:
     open(....)
    {
           mysql_real_connect(mDB);
     }       

     QuerySQL(....)
    { 
           mysql_real_query(mDB);
     } 
protected:
      MYSQL* mDB;

}

但實際使用中發現只要多線程一開就報錯，一般就是lost connect之類的錯誤，開始以為就是單純的連接斷開，所以在連接上面做了一些文章，每次查詢的時候使用ping確定連接是否正常，具體ping怎么寫我這里就不贅述了，網上有很多文章，加完了Ping,對連接設立了超時時間依然不能解決問題。

查了一下文檔發現在使用多線程時mysql_real_query函數和mysql_store_result函數必須加鎖，由於ping有可能造成連接重連，因此在ping里面也加上了鎖，如下代碼

class DbClass
{
public:
     open(....)
    {
           mysql_real_connect(mDB);
     }       
    
     ping()
     {
         mutex.lock();
         mysql_ping();
         mutex.unlock();
     }

     QuerySQL(....)
    { 
          mutex.lock();
           mysql_real_query(mDB);
          mutex.unlock();
     } 
protected:
      MYSQL* mDB;

}

這次再試終於不報錯了，高興了好長時間，這段代碼也就沒有再看，代碼測試到最后的時候，加上了計時等性能測量就發現問題了，多線程和單線程的用時一樣。。。。問題很明顯，這個其實就是串行訪問數據庫的，實質上還是單線程。而且即使單線程由於加的鎖比較多，速度也並不快。
重新思考了下，單連接上的多線程貌似肯定是不行了，一個連接同一時刻只能處理一個線程，想明白就好辦了，改成每個線程對應一個連接就OK了，而且這樣改由於連接並非共享資源，也不需要加互斥，會大大提高效率。

class DbClass
{
public:
     MYSQL*open(....)
    {
          MYSQL* pDB；
           mysql_real_connect(pDB);
          return pDB;
     }       
    
     ping(MYSQL* pDB)
     {
         mysql_ping(pDB);
     }

     QuerySQL(MYSQL* pDB, .....)
    { 
           mysql_real_query(pDB);
     } 

　　close(MYSQL* pDB)
   {
　　　　mysql_close(pDB);
    }
}

work_thread()
{
　　MYSQL* pDB = DbClass::open(); //應該是單例，這里就用static示意一下
   
    .....
    DbClass::ping(pDB);
 DbClass::QuerySQL(pDB);
    .....
    DbClass::close(pDB);
}

 

改完之后效果很明顯啊，單線程處理8000條數據（還有各種計算）大概要30秒，10線程處理只要3秒多一點，甚是欣慰。而且，原先由於鎖比較多單線程處理1000條數據大概也要20秒，現在8000要30秒，提高了很多了，還有優化的地方，不過已經滿足需要了，就這樣吧。

總結一下，mysql多線程的封裝需要注意如下幾點

1. 查詢前要先Ping確保連接正常

2. 每個線程對應一個連接

3. 若線程的刪除和建立比較頻繁，需要在獲取連接時使用連接池。