《Mysql學習在MySQL數據庫中使用C執行SQL語句的方法》要點：
本文介紹了Mysql學習在MySQL數據庫中使用C執行SQL語句的方法，希望對您有用。如果有疑問，可以聯系我們。
他們將討論返回數據的語句,例如INSERT以及不返回數據的語句,例如UPDATE和DELETE.然后,他們將編寫從數據庫檢索數據的簡單程序
執行SQL語句
現在,我們已經有了一個連接,并且知道如何處理錯誤,是時候討論使用我們的數據庫來作一些實際工作了.執行所有類型的SQL的主關鍵字是mysql_query：
int mysql_query(MYSQL *connection, const char *query)
正如您所見,它非常簡單.它取一個指向連接結構的指針和包含要執行的SQL的文本字符串；與命令行工具不同,將不使用結束分號.成功之后,返回0.在需要包含二進制數據的特殊情況下,可以使用相關的函數,mysql_real_query.雖然出于本章的目的,我們僅需要討論mysql_query.
不返回數據的SQL語句
我們將先討論UPDATE、DELETE和INSERT語句.因為它們不返回數據,所以更易于使用.
這里我們將介紹的另一個重要函數是檢查受影響的行數的函數：
my_ulonglong mysql_affected_rows(MYSQL *connection);
可能關于這一函數的最顯而易見的事就是其非同尋常的返回結果.由于可移植性原因,這是一個特殊的無符號類型.為了在printf中使用,建議將其強制轉換成使用%lu格式規范的無符號長整數.這個函數返回受以前的UPDATE、INSERT或DELETE查詢影響的行數,這些查詢是使用mysql_query執行的.
通常對于mysql_函數,返回碼0表示沒有行受影響；正數表示實際結果,通常是受影響的行數.
如前所述,當使用mysql_affected_rows時可能出現未期望的結果.讓我們先討論受INSERT語句影響的行數,它將按預期進行操作.將下列代碼添加到程序 connect2.c 中,并且稱其為insert1.c：
代碼如下:
#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;
}
正如預期,插入的行數為1.
現在,我們更改代碼,所以 'insert' 部分被替換成：
代碼如下:
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));
}
現在假設子表中有的數據,如下：
| childno |
fname |
age |
| 1
MYSQL數據庫2
MYSQL數據庫3
MYSQL數據庫4
MYSQL數據庫5
MYSQL數據庫6
MYSQL數據庫7
MYSQL數據庫8
MYSQL數據庫9
MYSQL數據庫10
MYSQL數據庫11
|
Jenny
MYSQL數據庫Andrew
MYSQL數據庫Gavin
MYSQL數據庫Duncan
MYSQL數據庫Emma
MYSQL數據庫Alex
MYSQL數據庫Adrian
MYSQL數據庫Ann
MYSQL數據庫Ann
MYSQL數據庫Ann
MYSQL數據庫Ann
|
14
MYSQL數據庫10
MYSQL數據庫4
MYSQL數據庫2
MYSQL數據庫0
MYSQL數據庫11
MYSQL數據庫5
MYSQL數據庫3
MYSQL數據庫4
MYSQL數據庫3
MYSQL數據庫4
|
如果我們執行update1,希望報告的受影響行數為4,但是實際上程序報告2,因為它僅必須更改2行,雖然WHERE子句標識了4行.如果想讓mysql_affected_rows報告的結果為4這可能是熟悉其它數據庫的人所期望的),則需要記住將CLIENT_FOUND_ROWS標志傳遞到mysql_real_connect,在 update2.c中的程序如下：
代碼如下:
if (mysql_real_connect(&my_connection, "localhost",
"rick", "bar", "rick", 0, NULL, CLIENT_FOUND_ROWS)) {
如果我們在數據庫中復位數據,然后運行帶有這種修改的程序,則它報告的行數為4.
函數mysql_affected_rows還有最后一個奇怪之處,它發生在從數據庫中刪除數據時.如果使用WHERE子句,則mysql_affected_rows將按預期返回刪除行數.但是,如果沒有WHERE子句,則刪除所有行,報告受影響的行數卻為0.這是因為由于效率原因優化刪除整個表.這種行為不受CLIENT_FOUND_ROWS選項標志的影響.
返回數據的語句
現在是時候討論SQL的最普遍用法了,從數據庫檢索數據的SELECT語句.
MySQL 還支持返回結果的SHOW、DESCRIBE和EXPLAIN SQL語句,但是這里不考慮它們.按慣例,手冊中包含這些語句的說明.
您將會從PostgreSQL章記起,可以從PQexec中的SQL SELECT 語句檢索數據,這里馬上獲取所有數據,或者使用游標從數據庫中逐行檢索數據,以便搞定大數據.
由于完全相同的原因,MySQL的檢索方法幾乎完全相同,雖然它實際上不用游標的形式描述逐行檢索.但是,它提供了縮小這兩種方法間差異的API,如果需要,它通常使兩種方法的互換更加容易.
通常,從MySQL數據庫中檢索數據有4個階段：
發出查詢
檢索數據
處理數據
執行所需的任何整理
象以前一樣,我們使用mysql_query發出查詢.數據檢索是使用mysql_store_result或mysql_use_result完成的,這取決于想如何檢索數據,隨后使用mysql_fetch_row調用序列來處理數據.最后,必須調用mysql_free_result以允許MySQL執行任何所需的整理.
全部立即數據檢索的函數
可以從SELECT語句(或其他返回數據的語句)中檢索完所有數據,在單一調用中,使用mysql_store_result：
代碼如下:
MYSQL_RES *mysql_store_result(MYSQL *connection);
必須在mysql_query檢索數據后才能調用這個函數,以在結果集中存儲該數據.這個函數從服務器中檢索所有數據并立即將它存儲在客戶機中.它返回一個指向以前我們從未遇到過的結構(結果集結構)的指針.如果語句失敗,則返回NULL.
使用等價的PostgreSQL時,應該知道返回NULL意味著已經發生了錯誤,并且這與未檢索到數據的情況不同.即使,返回值不是NULL,也不意味著當前有數據要處理.
如果未返回NULL,則可以調用mysql_num_rows并且檢索實際返回的行數,它當然可能是0.
代碼如下:
my_ulonglong mysql_num_rows(MYSQL_RES *result);
它從mysql_store_result取得返回的結果結構,并且在該結果集中返回行數,行數可能為0.如果mysql_store_result成功,則mysql_num_rows也總是成功的.
這種mysql_store_result和mysql_num_rows的組合是檢索數據的一種簡便并且直接的方法.一旦mysql_store_result成功返回,則所有查詢數據都已經存儲在客戶機上并且我們知道可以從結果結構中檢索它,而不用擔心會發生數據庫或網絡錯誤,因為對于程序所有數據都是本地的.還可以立即發現返回的行數,它可以使編碼更簡便.如前所述,它將所有結果立即地發送回客戶機.對于大結果集,它可能耗費大量的服務器、網絡和客戶機資源.由于這些原因,使用更大的數據集時,最好僅檢索需要的數據.不久,我們將討論如何使用mysql_use_result函數來完成該操作.
一旦檢索了數據,則可以使用mysql_fetch_row來檢索它,并且使用mysql_data_seek、mysql_row_seek、mysql_row_tell操作結果集.在開始檢索數據階段之前,讓我們先討論一下這些函數.
代碼如下:
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
這個函數采用從存儲結果中獲取的結果結構,并且從中檢索單一行,在行結構中返回分配給您的數據.當沒有更多數據或者發生錯誤時,返回NULL.稍后,我們將回來處理這一行中的數據.
代碼如下:
void mysql_data_seek(MYSQL_RES *result, my_ulonglong offset);
這個函數允許您進入結果集,設置將由下一個獲取操作返回的行.offset是行號,它必須在從0到結果集中的行數減 1 的范圍內.傳遞0將導致在下一次調用mysql_fetch_row時返回第一行.
代碼如下:
MYSQL_ROW_OFFEST mysql_row_tell(MYSQL_RES *result);
這個函數返回一個偏移值,它表示結果集中的當前位置.它不是行號,不能將它用于mysql_data_seek.但是,可將它用于：
代碼如下:
MYSQL_ROW_OFFSET mysql_row_seek(MYSQL_RES *result, MYSQL_ROW_OFFSET offset);
它移動結果集中的當前位置,并返回以前的位置.
有時,這一對函數對于在結果集中的已知點之間跳轉很有用.請注意,不要將row tell和row seek使用的偏移值與data_seek使用的行號混淆.這些是不可交換的,結果將是您所希望看到的.
代碼如下:
void mysql_free_result(MYSQL_RES *result);
完成結果集時, 必須總是調用這個函數,以允許MySQL庫整理分配給它的對象.
檢索數據 現在開始編寫從數據庫中檢索數據的第一個程序.我們將選擇所有年齡大于5的行的內容.不幸的是我們還不知道如何處理這個數據,所以我們能做的只有循環檢索它.這便是 select1.c：
代碼如下:
#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;
}
檢索結果集并循環通過已檢索的數據的重要部分都已突出顯示.
一次檢索一行數據 要按需要逐行檢索數據,而不是立即獲取全部數據并將它存儲在客戶機中,可以將mysql_store_result調用替換成 mysql_use_result：
代碼如下:
MYSQL_RES *mysql_use_result(MYSQL *connection);
這個函數還取得一個連接對象并返回結果結合指針,或者出錯時返回NULL.與mysql_store_result相似,它返回指向結果集對象的指針；關鍵的不同點在于返回時,實際上沒有將任何數據檢索到結果集,只是初始化結果集以準備好檢索數據.
參考資料 您可以參閱本文在developerWorks全球站點上的英文原文.
本文章取自Wrox Press Ltd出版的Professional Linux一書的第5章.
關于作者 Rick Stones是一位系統設計師,他在一家大型泛歐制藥分銷和分配公司的IT部門工作.從1985年開始,他一直在使用各種形式的 UNIX,并且發現帶有早期 .99 CD-ROM發行版的Linux.他用各種語言編寫UNIX、Linux和其它平臺的軟件,同時還安裝并管理幾臺Linux服務器.在非常有限的業余時間,他努力提高他的鋼琴演奏技巧.
從大學時代開始接觸C和UNIX V6時起,Neil Matthew對于UNIX和Linux已經超過20年的經驗.從那時起他就在IT業工作,主要從事通信軟件的開發,一直保持對于深奧的編程語言和開發技術的熱情.現在,他作為系統設計師,對技術戰略和QA提出建議.他熱心于在公司企業內建立Linux商業案例.業余時間,寫作或騎馬為樂,Neil努力勸說他的妻子和兩個孩子與他一起在鄉間散步.Neil參與編寫了Wrox Press發行的好幾本書,最著名的是共同著作了Beginning Linux Programming和Professional Linux Programming.
轉載請注明本頁網址：
http://www.snjht.com/jiaocheng/1440.html
