摘要:目前,數據庫在各行各業中廣泛應用。在眾多商業數據庫軟件中,SQL SERVER
和ORACLE被較多的使用,因此這兩個數據庫軟件的價格也較昂貴。本文主要介紹MySQL數據庫在單線程或多線程程序環境下使用C
API訪問MySQL數據庫方法,并給出了相應代碼和分析。該數據庫屬于開源數據庫,具有較高的成熟度,并且對于社區版本可以免費使用,因此對于需要使用
C API訪問數據庫的項目開發,可降低開發成本。
關鍵詞:MySQL;C API;多線程
中圖分類號:TP311文獻標識碼:A文章編號:1009-3044(2007)16-30904-02
Based on C API MySQL Database Multi-threaded Access Methods
YU Cheng-gong
(Zhejiang Pharmaceutical College,Ningbo 315100,China)
Abstract:Currently,the database in all walks of life were widely
used.In many commercial database software,SQL Server and Oracle are
used more and therefore their prices are more expensive. This paper
describes the MySQL database in single-threaded or multi-threaded
programming environment using C API access to the MySQL database, and
gives the corresponding code and analysis. The database is open source
database, with a higher maturity level, and the community version can
be used for free. It satisfies the need to use the C API access to the
database of project development, and reduces development costs.
Key words:MySQL;C API;multi-threaded
1 引言
隨著社會信息化的深入,數據庫在社會各個領域被廣泛應用。在這些數據庫應用項目開發過程中,需要做兩方面的決策:1.
使用何種數據庫軟件;2. 采用何種方式訪問數據庫。數據庫軟件的選擇面比較寬,在目前眾多商業數據庫軟件中,SQL SERVER
和ORACLE被較多的使用,當然這兩個數據庫軟件的價格也較昂貴,本文選擇可免費使用的MySQL數據庫社區版本,MySQL庫屬于開源數據庫,具有較
高的成熟度和可靠性。數據庫的訪問方式有很多,可以使用ODBC、DAO、ADO等方法,這些方法簡單直接但是效率不高,不適合大型復雜的系統使用,例如
網絡游戲的數據庫系統開發需要考慮同時大量的數據庫訪問,因此訪問的效率非常重要。基于C程序語言的高效率,使用C
API訪問數據庫可以提高數據庫的訪問效率。基于以上兩點,本文將介紹基于C
API的MySQL數據庫訪問方法,給出在單線程和多線程程序環境下的具體代碼和分析。
2 建表
為了方便說明數據庫的訪問,先建立一個數據庫表TestTable,可以使用SQL語句創建該表,也可以使用MySQL提供的圖形界面來創建。數據庫表中字段如下:
該數據庫表使用最常見的用戶名和密碼作為字段,本文將通過該表來實現不同程序環境下基于C API的數據庫的訪問方法。
3 單線程程序的數據庫訪問
單線程應用程序訪問MySQL數據庫相對簡單,其過程包含以下幾步:
(1)初始化MySQL庫
(2)初始化數據庫連接句柄
(3)連接數據庫
(4)通過SQL語句操作數據庫并處理相應數據
(5)關閉數據庫連接
(6)結束MySQL庫
通過這五個步驟即可實現數據庫的訪問,具體代碼和分析如下:
//在main主函數中添加代碼
//1.定義訪問數據庫所需變量
MYSQL * myData;
MYSQL_RES * res;
MYSQL_ROW row;
//2. 初始化MySQL庫和數據庫連接句柄
myData = mysql_init((MYSQL*) 0);
//3. 連接數據庫,MYSQL_IP和MYSQL_PORT表示數據庫的IP和端口
// MYSQL_ACCOUNT, MYSQL_PASSWORD表示數據庫連接的帳號和密碼
//MYSQL_DBNAME表示所要訪問的數據庫名
mysql_real_connect( myData, MYSQL_IP, MYSQL_ACCOUNT, MYSQL_PASSWORD, MYSQL_DBNAME, MYSQL_PORT,NULL, 0 )
//4. 通過SQL語句操作數據庫并處理相應數據
//4.1新建用戶名為abcdef,密碼為123456的記錄
mysql_query(myData, "insert into TestTable value(‘abcdef’,’ 123456’)");
//4.2顯示所有記錄
//查詢所有記錄
mysql_query(myData, "select * from TestTable");
//將查詢結果保存到res中
res = mysql_store_result( myData ) ;
//逐條顯示記錄
Int j = 0;
while ( row = mysql_fetch_row( res ) ) {//獲取一條記錄
j = mysql_num_fields( res ) ;//獲取每條記錄的字段數
for ( k = 0 ; k < j ; k++ )
printf( “%s”, row[k] ) ;
printf( “\n”) ;
}
//釋放res
mysql_free_result( res ) ;
//5. 關閉數據庫連接
mysql_close( myData );
//6. 結束MySQL庫
mysql_library_end();
關于代碼的幾點說明:
(1)定義變量中的三個數據結構為訪問MySQL所需,MYSQL結構表示一個數據庫連接的句柄,其中包含了數據庫連接所需的參數,MYSQL_RES結構表示數據庫訪問中一個查詢的返回結果,MYSQL_ROW結構表示返回結構中的一條記錄;
(2)獲取查詢結果res并處理完畢,必須釋放res,否則會造成內存泄露
(3)在單線程時,步驟初始化MySQL庫和數據庫連接句柄可合并, 由mysql_init()來處理。該函數會自動調用函數mysql_library_init()來初始化MySQL庫,同時初始化連接句柄。
4 多線程環境下的數據庫訪問
多線程環境下的數據庫訪問需要保證線程安全。Windows版本的MySQL C
API函數都是線程安全的,除了mysql_library_init(),而我們剛才的代碼中使用的mysql_init()函數會自動調用函數
mysql_library_init()來初始化MySQL庫,因此在多線程環境下,需要不同的初始化代碼和清理代碼。具體過程如下:
(1)在主函數中調用mysql_library_init()來初始化MySQL庫;
(2)啟動各數據庫訪問線程
(3)主函數等待各個線程的結束
(4)調用mysql_library_end ()清理MySQL庫。
其中數據庫訪問線程的代碼和單線程數據庫訪問代碼類似,但是需要如下變化:
(1)單線程中的第2步初始化MySQL庫和數據庫連接句柄,不能再使用mysql_init(),代碼應作如下修改:
//初始化線程
my_init();
mysql_thread_init();
//初始化myData
myData = malloc(sizeof(MYSQL));
memset(&myData, 0, sizeof(MYSQL))
(2)上述初始化myData,只是將myData所有成員設為0,如果有需要可以根據具體情況設置該結構成員的值,例myData->reconnect= 1,其作用是設置數據庫連接屬性為重連接,即當數據庫連接斷開時,自動重新連接;
(3)單線程中的第6步不在需要,改為結束線程的清理工作,即調用mysql_thread_end()函數。
5 總結
綜上所述,使用C
API訪問MySQL數據庫在不同線程環境下的區別主要在于初始化和訪問結束后清理代碼,也就是說除了初始化和清理代碼,MySQL提供給我們的C
API函數都是線程安全的。最后需要有一點說明,使用C
API訪問數據庫可以提高數據庫的訪問效率,但并不是所有的數據庫項目都適合這種方式,該方式適合需要大量實時并發處理的數據庫項目,例如網絡游戲的數據
庫項目,對于有此需求的數據庫項目可參考本文。
參考文獻:
[1]MySQL AB,MySQL 5.0 Reference Manual.
注:“本文中所涉及到的圖表、公式注解等形式請以PDF格式閱讀原文。”