快捷導(dǎo)航

在MySQL數(shù)據(jù)庫中使用C執(zhí)行SQL語句的方法

更新時間：2012年10月15日 02:23:28 作者：

與PostgreSQL相似，可使用許多不同的語言來訪問MySQL，包括C、C++、Java和Perl。從Professional Linux Programming中第5章有關(guān)MySQL的下列章節(jié)中，Neil Matthew和Richard Stones使用詳盡的MySQL C接口向我們介紹了如何在MySQL數(shù)據(jù)庫中執(zhí)行SQL語句。

他們將討論返回數(shù)據(jù)的語句，例如INSERT以及不返回數(shù)據(jù)的語句，例如UPDATE和DELETE。然后，他們將編寫從數(shù)據(jù)庫檢索數(shù)據(jù)的簡單程序

執(zhí)行SQL語句

現(xiàn)在，我們已經(jīng)有了一個連接，并且知道如何處理錯誤，是時候討論使用我們的數(shù)據(jù)庫來作一些實際工作了。執(zhí)行所有類型的SQL的主關(guān)鍵字是mysql_query：

int mysql_query(MYSQL *connection, const char *query)

正如您所見，它非常簡單。它取一個指向連接結(jié)構(gòu)的指針和包含要執(zhí)行的SQL的文本字符串；與命令行工具不同，將不使用結(jié)束分號。成功之后，返回0。在需要包含二進(jìn)制數(shù)據(jù)的特殊情況下，可以使用相關(guān)的函數(shù)，mysql_real_query。雖然出于本章的目的，我們僅需要討論mysql_query。
不返回數(shù)據(jù)的SQL語句

我們將先討論UPDATE、DELETE和INSERT語句。因為它們不返回數(shù)據(jù)，所以更易于使用。
這里我們將介紹的另一個重要函數(shù)是檢查受影響的行數(shù)的函數(shù)：

my_ulonglong mysql_affected_rows(MYSQL *connection);

可能關(guān)于這一函數(shù)的最顯而易見的事就是其非同尋常的返回結(jié)果。由于可移植性原因，這是一個特殊的無符號類型。為了在printf中使用，建議將其強制轉(zhuǎn)換成使用%lu格式規(guī)范的無符號長整數(shù)。這個函數(shù)返回受以前的UPDATE、INSERT或DELETE查詢影響的行數(shù)，這些查詢是使用mysql_query執(zhí)行的。
通常對于mysql_函數(shù)，返回碼0表示沒有行受影響；正數(shù)表示實際結(jié)果，通常是受影響的行數(shù)。
如前所述，當(dāng)使用mysql_affected_rows時可能出現(xiàn)未期望的結(jié)果。讓我們先討論受INSERT語句影響的行數(shù)，它將按預(yù)期進(jìn)行操作。將下列代碼添加到程序 connect2.c 中，并且稱其為insert1.c：

復(fù)制代碼代碼如下:

 
#include 
#include 
#include "mysql.h" 
int main(int argc, char *argv[]) { 
MYSQL my_connection; 
int res; 
mysql_init(&my_connection); 
if (mysql_real_connect(&my_connection, "localhost", 
"rick", "bar", "rick", 0, NULL, 0)) { 
printf("Connection success\n"); 
res = mysql_query(&my_connection, 
"INSERT INTO children(fname,age), 
VALUES('Ann',3)"); 
if (!res) { 
printf("Inserted %lu rows\n", 
(unsigned long)mysql_affected_rows(&my_connection)); 
} else { 
fprintf(stderr, "Insert error %d: s\n",mysql_errno , 
(&my_connection), 
mysql_error(&my_connection)); 
} 
mysql_close(&my_connection); 
} else { 
fprintf(stderr, "Connection failed\n"); 
if (mysql_errno(&my_connection)) { 
fprintf(stderr, "Connection error %d: %s\n", 
mysql_errno(&my_connection), 
mysql_error(&my_connection)); 
} 
} 
return EXIT_SUCCESS; 
} 

正如預(yù)期，插入的行數(shù)為1。
現(xiàn)在，我們更改代碼，所以 'insert' 部分被替換成：

復(fù)制代碼代碼如下:

 
mysql_errno(&my_connection), mysql_error(&my_connection)); 
} 
} 
res = mysql_query(&my_connection, "UPDATE children SET AGE = 4 
WHERE fname = 'Ann'"); 
if (!res) { 
printf("Updated %lu rows\n", 
(unsigned long)mysql_affected_rows(&my_connection)); 
} else { 
fprintf(stderr, "Update error %d: %s\n", 
mysql_errno(&my_connection), 
mysql_error(&my_connection)); 
} 

現(xiàn)在假設(shè)子表中有的數(shù)據(jù)，如下：

childno

fname

age

1

2

3

4

5

6

7

8

9

10

11

Jenny

Andrew

Gavin

Duncan

Emma

Alex

Adrian

Ann

14

10

4

2

0

11

5

3

4

3

4

如果我們執(zhí)行update1，希望報告的受影響行數(shù)為4，但是實際上程序報告2，因為它僅必須更改2行，雖然WHERE子句標(biāo)識了4行。如果想讓mysql_affected_rows報告的結(jié)果為4這可能是熟悉其它數(shù)據(jù)庫的人所期望的），則需要記住將CLIENT_FOUND_ROWS標(biāo)志傳遞到mysql_real_connect，在 update2.c中的程序如下：

復(fù)制代碼代碼如下:

 
if (mysql_real_connect(&my_connection, "localhost", 
"rick", "bar", "rick", 0, NULL, CLIENT_FOUND_ROWS)) { 

如果我們在數(shù)據(jù)庫中復(fù)位數(shù)據(jù)，然后運行帶有這種修改的程序，則它報告的行數(shù)為4。
函數(shù)mysql_affected_rows還有最后一個奇怪之處，它發(fā)生在從數(shù)據(jù)庫中刪除數(shù)據(jù)時。如果使用WHERE子句，則mysql_affected_rows將按預(yù)期返回刪除行數(shù)。但是，如果沒有WHERE子句，則刪除所有行，報告受影響的行數(shù)卻為0。這是因為由于效率原因優(yōu)化刪除整個表。這種行為不受CLIENT_FOUND_ROWS選項標(biāo)志的影響。

返回數(shù)據(jù)的語句

現(xiàn)在是時候討論SQL的最普遍用法了，從數(shù)據(jù)庫檢索數(shù)據(jù)的SELECT語句。

MySQL 還支持返回結(jié)果的SHOW、DESCRIBE和EXPLAIN SQL語句，但是這里不考慮它們。按慣例，手冊中包含這些語句的說明。
您將會從PostgreSQL章記起，可以從PQexec中的SQL SELECT 語句檢索數(shù)據(jù)，這里馬上獲取所有數(shù)據(jù)，或者使用游標(biāo)從數(shù)據(jù)庫中逐行檢索數(shù)據(jù)，以便搞定大數(shù)據(jù)。
由于完全相同的原因，MySQL的檢索方法幾乎完全相同，雖然它實際上不用游標(biāo)的形式描述逐行檢索。但是，它提供了縮小這兩種方法間差異的API，如果需要，它通常使兩種方法的互換更加容易。
通常，從MySQL數(shù)據(jù)庫中檢索數(shù)據(jù)有4個階段：

發(fā)出查詢
檢索數(shù)據(jù)
處理數(shù)據(jù)
執(zhí)行所需的任何整理

象以前一樣，我們使用mysql_query發(fā)出查詢。數(shù)據(jù)檢索是使用mysql_store_result或mysql_use_result完成的，這取決于想如何檢索數(shù)據(jù)，隨后使用mysql_fetch_row調(diào)用序列來處理數(shù)據(jù)。最后，必須調(diào)用mysql_free_result以允許MySQL執(zhí)行任何所需的整理。
全部立即數(shù)據(jù)檢索的函數(shù)
可以從SELECT語句（或其他返回數(shù)據(jù)的語句）中檢索完所有數(shù)據(jù)，在單一調(diào)用中，使用mysql_store_result：

復(fù)制代碼代碼如下:

MYSQL_RES *mysql_store_result(MYSQL *connection);

必須在mysql_query檢索數(shù)據(jù)后才能調(diào)用這個函數(shù)，以在結(jié)果集中存儲該數(shù)據(jù)。這個函數(shù)從服務(wù)器中檢索所有數(shù)據(jù)并立即將它存儲在客戶機中。它返回一個指向以前我們從未遇到過的結(jié)構(gòu)（結(jié)果集結(jié)構(gòu)）的指針。如果語句失敗，則返回NULL。
使用等價的PostgreSQL時，應(yīng)該知道返回NULL意味著已經(jīng)發(fā)生了錯誤，并且這與未檢索到數(shù)據(jù)的情況不同。即使，返回值不是NULL，也不意味著當(dāng)前有數(shù)據(jù)要處理。
如果未返回NULL，則可以調(diào)用mysql_num_rows并且檢索實際返回的行數(shù)，它當(dāng)然可能是0。

復(fù)制代碼代碼如下:

my_ulonglong mysql_num_rows(MYSQL_RES *result);

它從mysql_store_result取得返回的結(jié)果結(jié)構(gòu)，并且在該結(jié)果集中返回行數(shù)，行數(shù)可能為0。如果mysql_store_result成功，則mysql_num_rows也總是成功的。
這種mysql_store_result和mysql_num_rows的組合是檢索數(shù)據(jù)的一種簡便并且直接的方法。一旦mysql_store_result成功返回，則所有查詢數(shù)據(jù)都已經(jīng)存儲在客戶機上并且我們知道可以從結(jié)果結(jié)構(gòu)中檢索它，而不用擔(dān)心會發(fā)生數(shù)據(jù)庫或網(wǎng)絡(luò)錯誤，因為對于程序所有數(shù)據(jù)都是本地的。還可以立即發(fā)現(xiàn)返回的行數(shù)，它可以使編碼更簡便。如前所述，它將所有結(jié)果立即地發(fā)送回客戶機。對于大結(jié)果集，它可能耗費大量的服務(wù)器、網(wǎng)絡(luò)和客戶機資源。由于這些原因，使用更大的數(shù)據(jù)集時，最好僅檢索需要的數(shù)據(jù)。不久，我們將討論如何使用mysql_use_result函數(shù)來完成該操作。
一旦檢索了數(shù)據(jù)，則可以使用mysql_fetch_row來檢索它，并且使用mysql_data_seek、mysql_row_seek、mysql_row_tell操作結(jié)果集。在開始檢索數(shù)據(jù)階段之前，讓我們先討論一下這些函數(shù)。

復(fù)制代碼代碼如下:

MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);

這個函數(shù)采用從存儲結(jié)果中獲取的結(jié)果結(jié)構(gòu)，并且從中檢索單一行，在行結(jié)構(gòu)中返回分配給您的數(shù)據(jù)。當(dāng)沒有更多數(shù)據(jù)或者發(fā)生錯誤時，返回NULL。稍后，我們將回來處理這一行中的數(shù)據(jù)。

復(fù)制代碼代碼如下:

void mysql_data_seek(MYSQL_RES *result, my_ulonglong offset);

這個函數(shù)允許您進(jìn)入結(jié)果集，設(shè)置將由下一個獲取操作返回的行。offset是行號，它必須在從0到結(jié)果集中的行數(shù)減 1 的范圍內(nèi)。傳遞0將導(dǎo)致在下一次調(diào)用mysql_fetch_row時返回第一行。

復(fù)制代碼代碼如下:

MYSQL_ROW_OFFEST mysql_row_tell(MYSQL_RES *result);

這個函數(shù)返回一個偏移值，它表示結(jié)果集中的當(dāng)前位置。它不是行號，不能將它用于mysql_data_seek。但是，可將它用于：

復(fù)制代碼代碼如下:

MYSQL_ROW_OFFSET mysql_row_seek(MYSQL_RES *result, MYSQL_ROW_OFFSET offset);

它移動結(jié)果集中的當(dāng)前位置，并返回以前的位置。
有時，這一對函數(shù)對于在結(jié)果集中的已知點之間跳轉(zhuǎn)很有用。請注意，不要將row tell和row seek使用的偏移值與data_seek使用的行號混淆。這些是不可交換的，結(jié)果將是您所希望看到的。

復(fù)制代碼代碼如下:

void mysql_free_result(MYSQL_RES *result);

完成結(jié)果集時，必須總是調(diào)用這個函數(shù)，以允許MySQL庫整理分配給它的對象。
檢索數(shù)據(jù)
現(xiàn)在開始編寫從數(shù)據(jù)庫中檢索數(shù)據(jù)的第一個程序。我們將選擇所有年齡大于5的行的內(nèi)容。不幸的是我們還不知道如何處理這個數(shù)據(jù)，所以我們能做的只有循環(huán)檢索它。這便是 select1.c：

復(fù)制代碼代碼如下:

 
#include 
#include 

#include "mysql.h" 

MYSQL my_connection; 
MYSQL_RES *res_ptr; 
MYSQL_ROW sqlrow; 

int main(int argc, char *argv[]) { 
int res; 

mysql_init(&my_connection); 
if (mysql_real_connect(&my_connection, "localhost", "rick", 
"bar", "rick", 0, NULL, 0)) { 
printf("Connection success\n"); 

res = mysql_query(&my_connection, "SELECT childno, fname, 
age FROM children WHERE age > 5"); 
if (res) { 
printf("SELECT error: %s\n", mysql_error(&my_connection)); 
} else { 
res_ptr = mysql_store_result(&my_connection); 
if (res_ptr) { 
printf("Retrieved %luows\n",(unsignedlong)mysql_num_rows(res_ptr)); 
while ((sqlrow = mysql_fetch_row(res_ptr))) { 
printf("Fetched data...\n"); 
} 
if (mysql_errno(&my_connection)) { 
fprintf(stderr, "Retrive error: s\n",mysql_error(&my_connection)); 
} 
} 
mysql_free_result(res_ptr); 
} 

mysql_close(&my_connection); 

} else { 
fprintf(stderr, "Connection failed\n"); 
if (mysql_errno(&my_connection)) { 
fprintf(stderr, "Connection error %d: %s\n", 
mysql_errno(&my_connection),mysql_error(&my_connection)); 
} 
} 

return EXIT_SUCCESS; 
} 

檢索結(jié)果集并循環(huán)通過已檢索的數(shù)據(jù)的重要部分都已突出顯示。

一次檢索一行數(shù)據(jù)

要按需要逐行檢索數(shù)據(jù)，而不是立即獲取全部數(shù)據(jù)并將它存儲在客戶機中，可以將mysql_store_result調(diào)用替換成 mysql_use_result：

復(fù)制代碼代碼如下:

MYSQL_RES *mysql_use_result(MYSQL *connection);

這個函數(shù)還取得一個連接對象并返回結(jié)果結(jié)合指針，或者出錯時返回NULL。與mysql_store_result相似，它返回指向結(jié)果集對象的指針；關(guān)鍵的不同點在于返回時，實際上沒有將任何數(shù)據(jù)檢索到結(jié)果集，只是初始化結(jié)果集以準(zhǔn)備好檢索數(shù)據(jù)。

參考資料

您可以參閱本文在developerWorks全球站點上的英文原文.

本文章取自Wrox Press Ltd出版的Professional Linux一書的第5章。

關(guān)于作者

Rick Stones是一位系統(tǒng)設(shè)計師，他在一家大型泛歐制藥分銷和分配公司的IT部門工作。從1985年開始，他一直在使用各種形式的 UNIX，并且發(fā)現(xiàn)帶有早期 .99 CD-ROM發(fā)行版的Linux。他用各種語言編寫UNIX、Linux和其它平臺的軟件，同時還安裝并管理幾臺Linux服務(wù)器。在非常有限的業(yè)余時間，他努力提高他的鋼琴演奏技巧。

從大學(xué)時代開始接觸C和UNIX V6時起，Neil Matthew對于UNIX和Linux已經(jīng)超過20年的經(jīng)驗。從那時起他就在IT業(yè)工作，主要從事通信軟件的開發(fā)，一直保持對于深奧的編程語言和開發(fā)技術(shù)的熱情?，F(xiàn)在，他作為系統(tǒng)設(shè)計師，對技術(shù)戰(zhàn)略和QA提出建議。他熱心于在公司企業(yè)內(nèi)建立Linux商業(yè)案例。業(yè)余時間，寫作或騎馬為樂，Neil努力勸說他的妻子和兩個孩子與他一起在鄉(xiāng)間散步。Neil參與編寫了Wrox Press發(fā)行的好幾本書，最著名的是共同著作了Beginning Linux Programming和Professional Linux Programming。

您可能感興趣的文章: