1. 程式人生 > >mysql C api 多執行緒多連線 客戶端實現

mysql C api 多執行緒多連線 客戶端實現

mysql客戶端庫總是執行緒安全的。

對於除mysql_real_connect()外的所有函式,在預設情況下其他MySQL提供給我們的C API函式都是執行緒安全的。

要想使mysql_real_connect()成為執行緒安全的,必須用下述命令再次編譯客戶端庫:
shell> ./configure –enable-thread-safe-client
它建立了執行緒安全客戶端庫libmysqlclient_r。

要想使這些操作平穩工作,需要採取下述措施:

  1. 如果程式在呼叫mysql_real_connect()之前需要呼叫任何其他MySQL函式,請在啟動程式時呼叫my_init()(my_init()會在mysql_init中呼叫)。

  2. 呼叫任何MySQL函式之前,線上程處理程式中呼叫mysql_thread_init()(mysql_thread_init()會在mysql_init中呼叫)。

  3. 線上程中,呼叫pthread_exit()之前請呼叫mysql_thread_end()。這樣,就能釋放MySQL執行緒類變數使用的記憶體。

將客戶端連結到libmysqlclient_r時,如果存在未定義的符號,可能會出錯(記憶體洩漏)。在大多數情況下,其原因在於,未將執行緒庫包含在link/compile行上。

測試程式碼:

#include <stdio.h>
#include <stdlib.h>
#include <string.h> #include <unistd.h> #include <sys/socket.h> #include <netinet/in.h> #include <arpa/inet.h> #include <pthread.h> #include <mysql/mysql.h> void* work(void* arg) { MYSQL *m_pDBAccess; m_pDBAccess =mysql_init(NULL); if
(!m_pDBAccess){ printf("get mysql init is NULL\n"); return -1; } if(!mysql_real_connect(m_pDBAccess, "192.168.1.203", "root", "123456", "tposdb", 0, NULL, CLIENT_MULTI_STATEMENTS)){ printf("get mysql_real_connect is NULL\n"); mysql_close(m_pDBAccess); m_pDBAccess = NULL ; //在多執行緒環境下把下邊語句註釋掉使用 // mysql_thread_end(); return NULL; } mysql_autocommit(m_pDBAccess, 0); char value = 1; mysql_options(m_pDBAccess, MYSQL_OPT_RECONNECT, (char*)&value); if (mysql_query(m_pDBAccess, "CALL GetBankSerialNo('35220001', '310111173110010');")) // 如果失敗 { mysql_rollback(m_pDBAccess); printf("aa\n"); mysql_close(m_pDBAccess); m_pDBAccess = NULL ; //在多執行緒環境下把下邊語句註釋掉使用 //mysql_thread_end(); return NULL; } // mysql_rollback(m_pDBAccess); mysql_query(m_pDBAccess,"commit"); mysql_close(m_pDBAccess); m_pDBAccess = NULL ; //在多執行緒環境下把下邊語句註釋掉使用 //mysql_thread_end(); return NULL; } int main(int rgvs, char **rgva) { pthread_t tid; pthread_attr_t attr; pthread_attr_init(&attr); pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED); int i=0; for(i=0;i<100;i++) { pthread_create(&tid, &attr, work, NULL); } sleep(5); return 0; }

編譯命令:

gcc test.c -o test -L/usr/lib64/mysql -lmysqlclient_r -lpthread

測試命令:

valgrind --tool=memcheck --leak-check=full ./test

對比有mysql_thread_end();和無mysql_thread_end();的結果