|
Professional Linux Programming 的摘錄
<name></name>Neil Matthew 和 Richard Stones
Wrox Press Ltd
2001 年 1 月
與 PostgreSQL 相似，可使用許多不同的語言來訪問 MySQL，包括 C、C++、Java 和 Perl。從 Professional Linux Programming 中第 5 章有關 MySQL 的下列章節中，Neil Matthew 和 Richard Stones 使用詳盡的 MySQL C 接口向我們介紹了如何在 MySQL 數據庫中執行 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 <stdlib.h>
#include <stdio.h>
#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
2
3
4
5
6
7
8
9
10
11
|
Jenny
Andrew
Gavin
Duncan
Emma
Alex
Adrian
Ann
Ann
Ann
Ann
|
14
10
4
2
0
11
5
3
4
3
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_fetch_rowmysql_fetch_row
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
|
這個函數采用從存儲結果中獲取的結果結構，并且從中檢索單一行，在行結構中返回分配給您的數據。當沒有更多數據或者發生錯誤時，返回 NULL。稍后，我們將回來處理這一行中的數據。
mysql_data_seek
void mysql_data_seek(MYSQL_RES *result, my_ulonglong offset);
|
這個函數允許您進入結果集，設置將由下一個獲取操作返回的行。offset 是行號，它必須在從 0 到結果集中的行數減 1 的范圍內。傳遞 0 將導致在下一次調用 mysql_fetch_row 時返回第一行。
my_sql_row_tell, mysql_row_seek
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 使用的行號混淆。這些是不可交換的，結果將是您所希望看到的。
mysql_free_result
在迫不及待地使用這些新函數之前，我們需要知道的最后一個函數是 mysql_free_result。
void mysql_free_result(MYSQL_RES *result);
|
完成結果集時，
必須總是
調用這個函數，以允許 MySQL 庫整理分配給它的對象。
檢索數據
現在開始編寫從數據庫中檢索數據的第一個程序。我們將選擇所有年齡大于 5 的行的內容。不幸的是我們還不知道如何處理這個數據，所以我們能做的只有循環檢索它。這便是 select1.c：
#include <stdlib.h>
#include <stdio.h>
#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 相似，它返回指向結果集對象的指針；關鍵的不同點在于返回時，實際上沒有將任何數據檢索到結果集，只是初始化結果集以準備好檢索數據。
參考資料
關于作者
Rick Stones 是一位系統設計師，他在一家大型泛歐制藥分銷和分配公司的 IT 部門工作。從 1985 年開始，他一直在使用各種形式的 UNIX，并且發現帶有早期 .99 CD-ROM 發行版的 Linux。他用各種語言編寫 UNIX、Linux 和其它平臺的軟件，同時還安裝并管理幾臺 Linux 服務器。在非常有限的業余時間，他努力提高他的鋼琴演奏技巧。
從大學時代開始接觸 C 和 UNIX V6 時起，Neil Matthew 對于 UNIX 和 Linux 已經超過 20 年的經驗。從那時起他就在 IT 業工作，主要從事通信軟件的開發，一直保持對于深奧的編程語言和開發技術的熱情?，F在，他作為系統設計師，對技術戰略和 QA 提出建議。他熱心于在公司企業內建立 Linux 商業案例。業余時間，寫作或騎馬為樂，Neil 努力勸說他的妻子和兩個孩子與他一起在鄉間散步。 Neil 參與編寫了 Wrox Press 發行的好幾本書，最著名的是共同著作了 Beginning Linux Programming 和 Professional Linux Programming。
|
|