1. 程式人生 > >MySQL Connector/C++入門教程(上)

MySQL Connector/C++入門教程(上)

翻譯: DarkBull(www.darkbull.net) 譯者注:該教程是一篇介紹如何使用C++操作MySQL的入門教程,內容簡單易用。我對原文中的一些例子進行了修改,並新添加了部分例子,主要目標是更簡單明瞭的向讀者介紹如何操作MySQL資料庫。本人也是MySQL的初學者,錯誤也在所難免,歡迎拍磚!     這篇教程將一步一步引導您如何去構建和安裝MySql Connection/C++ Driver,同時提供幾個簡單的例子來演示如何連線MySQL資料庫,如何向MySQL新增、獲取資料。本教程關注如何在C++應用程式中操作MySQL,所以首先應該確定MySQL資料庫服務已經開啟並且在當前機器能夠訪問到。
    本教程面向的讀者是MySQL Connector/C++的初學者,如果您對C++語言或者MySQL資料庫不是很瞭解,請參考其他的教程。     教程使用了下面所列的一些工具和技術,來構建、編譯、執行例子程式(譯者注:這是原文作者使用的環境。筆者使用的環境是:WinXP,MySQL5.1,VS2008, ):
  • DatabaseMySQL Server 5.1.24-rc
  • C++ DriverMySQL Connector/C++ 1.0.5
  • MySQL Client LibraryMySQL Connector/C 6.0
  • CompilerSun Studio 12 C++ compiler
  • MakeCMake 2.6.3
  • Operating SystemOpenSolaris 2008.11 32-bit
  • CPU / ISAIntel Centrino / x86
  • HardwareToshiba Tecra M2 Laptop

目錄

MySQL C++ Driver的實現基於JDBC4.0規範 安裝MySQL Connector/C++ 執行時依賴 C++ IDE 為示例程式建立資料庫與資料表 使用Connector/C++測試資料庫連線 使用prepared Statements 使用事務 訪問Result Set Metadata 訪問Database Metadata 通過PreparedStatment物件訪問引數元資料 捕獲異常 除錯/跟蹤 MySQL Connector/C++ 更多資訊

MySQL C++ Driver的實現基於JDBC4.0規範

    MySQL Connector/C++是由Sun Microsystems開發的MySQL聯結器。它提供了基於OO的程式設計介面與資料庫驅動來操作MySQL伺服器。     與許多其他現存的C++介面實現不同,Connector/C++遵循了JDBC規範。也就是說,Connector/C++ Driver的API主要是基於Java語言的JDBC介面。JDBC是java語言與各種資料庫連線的標準工業介面。Connector/C++實現了大部分JDBC4.0規範。如果C++程式的開發者很熟悉JDBC程式設計,將很快的入門。     MySQL Connector/C++實現了下面這些類:
  • Driver
  • Connection
  • Statement
  • PreparedStatement
  • ResultSet
  • Savepoint
  • DatabaseMetaData
  • ResultSetMetaData
  • ParameterMetaData
    Connector/C++可用於連線MySQL5.1及其以後版本。
    在MySQL Connector/C++釋出之前,C++程式設計師可以使用MySQL C API或者MySQL++訪問MySQL。前者是非標準、過程化的C API,後者是對MySQL C API的C++封裝。

安裝MySQL Connector/C++

    此處略。(譯者注:使用者可以到MySQL的官網[http://dev.mysql.com/downloads/connector/cpp/1.0.html]去下載MySQL Connector/C++的安裝程式,或者只下載dll,或者下載原始碼自己編譯。筆者在Window平臺上使用MySQL,下載了mysql-connector-c++-noinstall-1.0.5-win32這個版本用於除錯。)

執行時依賴

    MySQL Connector/C++ Driver依賴MySQL的客戶端庫,在MySQL安裝目錄下的lib/opt/libmysql.dll。如果是通過安裝程式來安裝MySQL Connector/C++,libmysql會一併安裝,如果從官網只下載了dll或原始碼,在使用時,程式必須連結到libmysql.dll。

C++ IDE

    此處略。(譯者注:原文作者使用NetBean作為C++的IED。筆者使用VS2008)

為示例程式建立資料庫與資料表

    (譯者注:此節略掉許多不太重要的內容。)在MySQL中建立test資料庫,使用下面語句建立資料表:City:
  1. CreateTableCREATETABLE `City` ( `CityName` varchar(30) DEFAULTNULL ) ENGINE=InnoDB DEFAULT CHARSET=ascii   
然後向City表中新增一些資料。最後表的內容為:
mysql> SELECT * FROM City;   +--------------------+   | CityName           |   +--------------------+   | Hyderabad, India   |   | San Francisco, USA |  | Sydney, Australia  |  +--------------------+  3 rows in set (0.17 sec) 

使用Connector/C++測試資料庫連線

    下面的程式碼演示如何使用Connector/C++連線到MySQL伺服器:

  •     連線到test資料庫;
  •     執行一個查詢獲取City表中的資料,顯示在控制檯上; 
  •     使用Prepared Statements向City表插入資料;
  •     使用savepoints演示事務;
  •     獲取結果集和資料庫的元資訊;
    例子程式碼僅僅用於演示,不建議讀者在實際開發中使用這種樣式的程式碼。(譯者注:例子程式碼很長,如果看不太明白,沒關係,等閱讀完全文之後再回過頭來看)
  1.                 #include <iostream>
  2. #include <map>
  3. #include <string>
  4. #include <memory>
  5. #include "mysql_driver.h"
  6. #include "mysql_connection.h"
  7. #include "cppconn/driver.h"
  8. #include "cppconn/statement.h"
  9. #include "cppconn/prepared_statement.h"
  10. #include "cppconn/metadata.h"
  11. #include "cppconn/exception.h"
  12. #define DBHOST "tcp://127.0.0.1:3306"
  13. #define USER "root"
  14. #define PASSWORD "000000"
  15. #define DATABASE "test"
  16. #define NUMOFFSET 100
  17. #define COLNAME 200
  18. usingnamespace std;  
  19. usingnamespace sql;  
  20. #pragma comment(lib, "mysqlcppconn.lib")
  21. void Demo();  
  22. int main(int argc, char *argv[])  
  23. {  
  24.     Demo();  
  25.     return 0;  
  26. }  
  27. /* 獲取資料庫資訊 */
  28. staticvoid GetDBMetaData(Connection *dbcon)   
  29. {  
  30.     if (dbcon->isClosed())   
  31.     {  
  32.         throw runtime_error("DatabaseMetaData FAILURE - database connection closed");  
  33.     }  
  34.     cout << "/nDatabase Metadata" << endl;  
  35.     cout << "-----------------" << endl;  
  36.     cout << boolalpha;  
  37.     /* The following commented statement won't work with Connector/C++ 1.0.5 and later */
  38.     //auto_ptr < DatabaseMetaData > dbcon_meta (dbcon->getMetaData());
  39.     DatabaseMetaData *dbcon_meta = dbcon->getMetaData();  
  40.     cout << "Database Product Name: " << dbcon_meta->getDatabaseProductName() << endl;  
  41.     cout << "Database Product Version: " << dbcon_meta->getDatabaseProductVersion() << endl;  
  42.     cout << "Database User Name: " << dbcon_meta->getUserName() << endl << endl;  
  43.     cout << "Driver name: " << dbcon_meta->getDriverName() << endl;  
  44.     cout << "Driver version: " << dbcon_meta->getDriverVersion() << endl << endl;  
  45.     cout << "Database in Read-Only Mode?: " << dbcon_meta->isReadOnly() << endl;  
  46.     cout << "Supports Transactions?: " << dbcon_meta->supportsTransactions() << endl;  
  47.     cout << "Supports DML Transactions only?: " << dbcon_meta->supportsDataManipulationTransactionsOnly() << endl;  
  48.     cout << "Supports Batch Updates?: " << dbcon_meta->supportsBatchUpdates() << endl;  
  49.     cout << "Supports Outer Joins?: " << dbcon_meta->supportsOuterJoins() << endl;  
  50.     cout << "Supports Multiple Transactions?: " << dbcon_meta->supportsMultipleTransactions() << endl;  
  51.     cout << "Supports Named Parameters?: " << dbcon_meta->supportsNamedParameters() << endl;  
  52.     cout << "Supports Statement Pooling?: " << dbcon_meta->supportsStatementPooling() << endl;  
  53.     cout << "Supports Stored Procedures?: " << dbcon_meta->supportsStoredProcedures() << endl;  
  54.     cout << "Supports Union?: " << dbcon_meta->supportsUnion() << endl << endl;  
  55.     cout << "Maximum Connections: " << dbcon_meta->getMaxConnections() << endl;  
  56.     cout << "Maximum Columns per Table: " << dbcon_meta->getMaxColumnsInTable() << endl;  
  57.     cout << "Maximum Columns per Index: " << dbcon_meta->getMaxColumnsInIndex() << endl;  
  58.     cout << "Maximum Row Size per Table: " << dbcon_meta->getMaxRowSize() << " bytes" << endl;  
  59.     cout << "/nDatabase schemas: " << endl;  
  60.     auto_ptr < ResultSet > rs ( dbcon_meta->getSchemas());  
  61.     cout << "/nTotal number of schemas = " << rs->rowsCount() << endl;  
  62.     cout << endl;  
  63.     int row = 1;  
  64.     while (rs->next()) {  
  65.         cout << "/t" << row << ". " << rs->getString("TABLE_SCHEM") << endl;  
  66.         ++row;  
  67.     } // while
  68.     cout << endl << endl;  
  69. }  
  70. /* 獲取結果集資訊 */
  71. staticvoid GetResultDataMetaBata(ResultSet *rs)   
  72. {  
  73.     if (rs -> rowsCount() == 0)   
  74.     {  
  75.         throw runtime_error("ResultSetMetaData FAILURE - no records in the result set");  
  76.     }  
  77.     cout << "ResultSet Metadata" << endl;  
  78.     cout << "------------------" << endl;  
  79.     /* The following commented statement won't work with Connector/C++ 1.0.5 and later */
  80.     //auto_ptr < ResultSetMetaData > res_meta ( rs -> getMetaData() );
  81.     ResultSetMetaData *res_meta = rs -> getMetaData();  
  82.     int numcols = res_meta -> getColumnCount();  
  83.     cout << "/nNumber of columns in the result set = " << numcols << endl << endl;  
  84.     cout.width(20);  
  85.     cout << "Column Name/Label";  
  86.     cout.width(20);  
  87.     cout << "Column Type";  
  88.     cout.width(20);  
  89.     cout << "Column Size" << endl;  
  90.     for (int i = 0; i < numcols; ++i)   
  91.     {  
  92.         cout.width(20);  
  93.         cout << res_meta -> getColumnLabel (i+1);  
  94.         cout.width(20);   
  95.         cout << res_meta -> getColumnTypeName (i+1);  
  96.         cout.width(20);   
  97.         cout << res_meta -> getColumnDisplaySize (i+1) << endl << endl;  
  98.     }  
  99.     cout << "/nColumn /"" << res_meta -> getColumnLabel(1);  
  100.     cout << "/" belongs to the Table: /"" << res_meta -> getTableName(1);  
  101.     cout << "/" which belongs to the Schema: /"" << res_meta -> getSchemaName(1) << "/"" << endl << endl;  
  102. }  
  103. /* 列印結果集中的資料 */
  104. staticvoid RetrieveDataAndPrint(ResultSet *rs, int type, int colidx, string colname)   
  105. {  
  106.     /* retrieve the row count in the result set */
  107.     cout << "/nRetrieved " << rs->rowsCount() << " row(s)." << endl;  
  108.     cout << "/nCityName" << endl;  
  109.     cout << "--------" << endl;  
  110.     /* fetch the data : retrieve all the rows in the result set */
  111.     while (rs->next())   
  112.     {  
  113.         if (type == NUMOFFSET)   
  114.         {  
  115.             cout << rs -> getString(colidx) << endl;  
  116.         } elseif (type == COLNAME)   
  117.         {  
  118.             cout << rs -> getString(colname) << endl;  
  119.         } // if-else
  120.     } // while
  121.     cout << endl;  
  122. }  
  123. void Demo()   
  124. {  
  125.     Driver *driver;  
  126.     Connection *con;  
  127.     Statement *stmt;  
  128.     ResultSet *res;  
  129.     PreparedStatement *prep_stmt;  
  130.     Savepoint *savept;  
  131.     int updatecount = 0;  
  132.     /* initiate url, user, password and database variables */
  133.     string url(DBHOST);  
  134.     const string user(USER);  
  135.     const string password(PASSWORD);  
  136.     const string database(DATABASE);  
  137.     try
  138.     {  
  139.         driver = get_driver_instance();  
  140.         /* create a database connection using the Driver */
  141.         con = driver -> connect(url, user, password);  
  142.         /* alternate syntax using auto_ptr to create the db connection */
  143.         //auto_ptr  con (driver -> connect(url, user, password));
  144.         /* turn off the autocommit */
  145.         con -> setAutoCommit(0);  
  146.         cout << "/nDatabase connection/'s autocommit mode = " << con -> getAutoCommit() << endl;  
  147.         /* select appropriate database schema */
  148.         con -> setSchema(database);  
  149.         /* retrieve and display the database metadata */
  150.         GetDBMetaData(con);  
  151.         /* create a statement object */
  152.         stmt = con -> createStatement();  
  153.         cout << "Executing the Query: /"SELECT * FROM City/" .." << endl;  
  154.         /* run a query which returns exactly one result set */
  155.         res = stmt -> executeQuery ("SELECT * FROM City");  
  156.         cout << "Retrieving the result set .." << endl;  
  157.         /* retrieve the data from the result set and display on stdout */
  158.         RetrieveDataAndPrint (res, NUMOFFSET, 1, string("CityName"));  
  159.         /* retrieve and display the result set metadata */
  160.         GetResultDataMetaBata (res);  
  161.         cout << "Demonstrating Prepared Statements .. " << endl << endl;  
  162.         /* insert couple of rows of data into City table using Prepared Statements */
  163.         prep_stmt = con -> prepareStatement ("INSERT INTO City (CityName) VALUES (?)");  
  164.         cout << "/tInserting /"London, UK/" into the table, City .." << endl;  
  165.         prep_stmt -> setString (1, "London, UK");  
  166.         updatecount = prep_stmt -> executeUpdate();  
  167.         cout << "/tCreating a save point /"SAVEPT1/" .." << endl;  
  168.         savept = con -> setSavepoint ("SAVEPT1");  
  169.         cout << "/tInserting /"Paris, France/" into the table, City .." << endl;  
  170.         prep_stmt -> setString (1, "Paris, France");  
  171.         updatecount = prep_stmt -> executeUpdate();  
  172.         cout << "/tRolling back until the last save point /"SAVEPT1/" .." << endl;  
  173.         con -> rollback (savept);  
  174.         con -> releaseSavepoint (savept);  
  175.         cout << "/tCommitting outstanding updates to the database .." << endl;  
  176.         con -> commit();  
  177.         cout << "/nQuerying the City table again .." << endl;  
  178.         /* re-use result set object */
  179.         res = NULL;  
  180.         res = stmt -> executeQuery ("SELECT * FROM City");  
  181.         /* retrieve the data from the result set and display on stdout */
  182.         RetrieveDataAndPrint(res, COLNAME, 1, string ("CityName"));  
  183.         cout << "Cleaning up the resources .." << endl;  
  184.         /* Clean up */
  185.         delete res;  
  186.         delete stmt;  
  187.         delete prep_stmt;  
  188.         con -> close();  
  189.         delete con;  
  190.     } catch (SQLException &e) {  
  191.         cout << "ERROR: " << e.what();  
  192.         cout << " (MySQL error code: " << e.getErrorCode();  
  193.         cout << ", SQLState: " << e.getSQLState() << ")" << endl;  
  194.         if (e.getErrorCode() == 1047) {  
  195.             /* 
  196.             Error: 1047 SQLSTATE: 08S01 (ER_UNKNOWN_COM_ERROR) 
  197.             Message: Unknown command 
  198.             */
  199.             cout << "/nYour server does not seem to support Prepared Statements at all. ";  
  200.             cout << "Perhaps MYSQL < 4.1?" << endl;  
  201.         }  
  202.         return;  
  203.     } catch (std::runtime_error &e) {  
  204.         cout << "ERROR: " << e.what() << endl;  
  205.         return;  
  206.     }  
  207.     return;  
  208. }  
建立資料庫連線
    sql::Connection代表到資料庫的連線,可以通過sql::Driver來建立。sql::mysql::get_mysql_driver_instance()方法用於獲取sql::Driver,通過呼叫sql::Driver::connect方法來建立sql::Connection物件。(譯者注:筆者使用的Connector/C++版本與作者使用的版本不一樣,介面方面也有點細微的差別。這裡根據筆者使用的最新版本mysql-connector-c++-noinstall-1.0.5-win32來說明。)     下面是get_mysql_driver_instance與connect這兩個方法的簽名:
  1. /* mysql_driver.h */
  2. MySQL_Driver *sql::mysql::get_mysql_driver_instance()  
  3. /* mysql_driver.h */
  4. sql::Connection * connect(const std::string& hostName, const std::string& userName, const std::string& password);  
  5. sql::Connection * connect(std::map<std::string, sql::ConnectPropertyVal> & options);  
    Driver類過載了connect方法,一個接收資料庫地址的url、使用者名稱和密碼的字串,後一個接收一個map,map中以key/value的形式包含資料庫地址、使用者名稱與密碼。使用TCP/IP連線到MySql伺服器的url字串的格式如下:"tcp://[hostname[:port]][/schemaname]"。例如:tcp://127.0.0.1:5555/some_scehma。hostname和埠號是可選的,如果省略,預設是127.0.0.1與3306。如果hostname為"localhost",會被自動轉換為"127.0.0.1"。schemaname也是可選的,如果連線字串中沒有設定schema,需要在程式中通過Connection::setSchema方法手動設定。     在unix系統上,可以通過UNIX domain socket連線執行在本地的MySQL服務,連線字串格式為:"unix://path/to/unix_socket_file",例如:unix:///tmp/mysql.sock.     在windows系統上,可以以命名管道的方式連線到執行在本地的MySQL資料庫,連線字串格式為:"pipe://path/to/the/pipe"。MySQL服務必須啟動允許命名管道連線,可以在啟動MySQL伺服器的時候,通過--enable-named-pipe命令列選項來啟動該功能。如果沒有通過--socket=name選項設定命名管道的名稱,系統預設使用MySQL。在windows上,管道的名稱是區別大小寫的。
    下面的程式碼片斷嘗試連線到本地的MySQL伺服器,通過3306埠,使用者名稱為root,密碼是000000,schema為test.
  1.                     sql::mysql::MySQL_Driver *driver = 0;  
  2. sql::Connection *conn = 0;  
  3. try
  4. {  
  5.     driver = sql::mysql::get_mysql_driver_instance();  
  6.     conn = driver->connect("tcp://localhost:3306/test""root""000000");  
  7.     cout << "連線成功" << endl;  
  8. }  
  9. catch (...)  
  10. {  
  11.     cout << "連線失敗" << endl;  
  12. }  
  13. if (conn != 0)  
  14. {  
  15.     delete conn;  
  16. }  
也可以通過connection的第二個過載方法連線MySQL。ConnectPropertyVal是union型別,在connection.h中定義。
  1.                     sql::mysql::MySQL_Driver *driver = 0;  
  2. sql::Connection *conn = 0;  
  3. std::map<std::string, ConnectPropertyVal> connProperties;   
  4. ConnectPropertyVal tmp;   
  5. tmp.str.val = "tcp://127.0.0.1:3306/test";   
  6. connProperties[std::string("hostName")] = tmp;   
  7. tmp.str.val = "root";   
  8. connProperties[std::string("userName")] = tmp;   
  9. tmp.str.val = "000000";   
  10. connProperties[std::string("password")] = tmp;   
  11. try
  12. {   
  13.     driver = sql::mysql::get_mysql_driver_instance();  
  14.     conn = driver -> connect(connProperties);   
  15.     cout << "連線成功" << endl;  
  16. }   
  17. catch(...)   
  18. {   
  19.     cout << "連線失敗" << endl;  
  20. }  
  21. if (conn != 0)  
  22. {  
  23.     delete conn;  
  24. }  
    上面的連線字串可以將協議與路徑分開寫(譯者注:C++會把兩個連在一起的字串合併成一個字串),如:mp.str.val = "unix://" "/tmp/mysql.sock"     當建立與伺服器之間的連線後,通過Connection::setSessionVariable方法可以設定像sql_mode這樣的選項。
C++細節注意點
    像Connection這樣的物件,必須在用完之後,顯式的delete,例如:
  1.                 sql::Connection *conn = driver -> connect("tcp://127.0.0.1:3306""root""000000");  
  2. // do something
  3. delete conn  
    使用使用auto_ptr來維護連線物件的清理, 如:
  1.                 use namespace std;  
  2. use namespace sql;  
  3. auto_ptr < Connection > con ( driver -> connect("tcp://127.0.0.1:3306""root""000000") );  
獲取Statement物件
    Statement物件用於向MySQL伺服器傳送SQL語句。該物件可以通過呼叫Connection::createStatement方法獲得。Statement向MySQL傳送一個靜態的SQL語句,然後從MySQL獲取操作的結果,我們無法向它提供sql引數。如果要向它傳遞引數,可以使用PreparedStatemenet類。如果相同的SQL語句(只SQL引數不同)要被執行多次,建議使用PreparedStatement類。
    Connection::createStatement的簽名如下(關於Connection類所提供的方法列表,可以檢視connection.h標頭檔案):
  1. /* connection.h */
  2. ment* Connection::createStatement();  
    下面的的程式碼段通過呼叫Connection物件的createStatemenet來獲取一個Statement物件:
  1.                     Connection *conn;  // Connection物件的引用
  2. Statement *stat;   
  3. Statement stat = conn -> createStatement();   
執行SQL語句
    在執行SQL語句之前應該通過Connection物件的setSchema方法設定相應的Schema(如果沒有在資料庫地址URL中指定schema)。     Statement::executeQuery用於執行一個Select語句,它返回ResultSet物件。Statement::executeUpdate方法主要用於執行INSERT, UPDATE, DELETE語句(executeUpdate可以執行所有的SQL語句,如DDL語句,像建立資料表。),該方法返回受影響記錄的條數。     如果你不清楚要執行的是像select這樣的查詢語句還是像update/insert/delete這樣的操作語句,可以使用execute方法。對於查詢語句,execute()返回True,然後通過getResultSet方法獲取查詢的結果;對於操作語句,它返回False,通過getUpdateCount方法獲取受影響記錄的數量。     在一些特殊的情況下,單條SQL語句(如執行儲存過程),可能會返回多個結果集 和/或 受影響的記錄數量。如果你不想忽略這些結果,通過getResultSet或getUpdateCount方法第一個結果後,再通過getMoreResults()來獲取其他的結果集。     下面是這些方法的簽名,可以在statement.h標頭檔案中查閱Statement的完整方法列表。
  1. /* connection.h */
  2. void Connection::setSchema(const std::string& catalog);   
  3. /* statement.h */
  4. ResultSet* Statement::executeQuery (const std::string& sql);   
  5. int Statement::executeUpdate (const std::string& sql);   
  6. bool Statement::execute (const std::string& sql);   
  7. ResultSet* Statement::getResultSet();   
  8. uint64_t Statement::getUpdateCount();  
    這些方法出錯時都會丟擲SQLException異常,所以在你的程式碼中應該使用try...catch語句塊來捕獲這些異常。     現在回顧上面那個完全的例子,你會發現獲取City表的所有記錄是如此的簡單:
  1.                 Statement *stmt;  
  2. ResultSet *res;  
  3. res = stmt -> executeQuery ("SELECT * FROM City");  
    executeQuery方法返回ResultSet物件,它包含了查詢的結果。在以下情況下,executeQuery會丟擲SQLException異常:資料庫在執行查詢時出錯;在一個關閉的Statement物件上呼叫executeQuery;給出的SQL語句返回的不是一個簡單的結果集;     上面的程式碼可以用Statement::execute()重寫:
  1. bool retvalue = stmt -> execute ("SELECT * FROM City");  
  2. if (retvalue)   
  3. {  
  4.     res = stmt -> getResultSet();  
  5. }   
  6. else
  7. {  
  8.     ...  
  9. }  
    execute()返回True表示操作的結果是一個ResultSet物件,否則結果是受影響記錄的數量或沒有結果。當返回True時,通過getResultSet方法獲取結果集,在返回False的情況下呼叫getResultSet方法,將返回NULL。     當資料庫在執行時發生錯誤或者在一個已關閉的Statement物件上執行execute與getResultSet方法,都會丟擲SQLException異常。     如果要往資料庫裡新增一條新的記錄,可以像下面的例子一樣簡單的呼叫executeUpdate方法:
  1. int updateCount = stmt -> executeUpdate ("INSERT INTO City (CityName) VALUES ('Napier, New Zealand')");  
    如果executeUpdate執行的是像INSERT, UPDATE或DELETE這樣的資料操作語句(DML),它返回受影響的記錄的數量;如果執行的是資料定義語句(DDL),它返回0。在資料庫操作失敗,或者在一個已經關閉的Statement上呼叫該方法,或者給出的SQL語句是一個查詢語句(會返回結果集),該方法會丟擲SQLException異常。     下面的程式碼使用execute和getUpdateCount方法來生寫上面的例子:
  1. int updateCount = 0;  
  2. bool retstatus = stat->execute("INSERT INTO City (CityName) VALUES ('Napier, New Zealand')");  
  3. if (!retstatus)   
  4. {  
  5.     updateCount = stat->getUpdateCount();  
  6. }   
  7. else
  8. {  
  9.     ...  
  10. }  
從ResultData中獲取資料

    上面的段落介紹了執行SQL查詢的方法:executeQuery和execute,用於獲取ResultSet物件。我們可以通過ResultSet訪問查詢的結果。每一個ResultSet都包含一個遊標(cursor),它指向資料集中的當前記錄行。ResultSet中排列的記錄是有序的(譯者注:只能按順序一條一條獲取,不能跳躍式獲取)。(但)在同一行中,列值的訪問卻是隨意的:可以通過列的位置或者名稱。通過列的名稱訪問列值讓程式碼更清晰,而通過位置訪問列值則更高效。

    列的名稱通過SQL語句的AS子名設定,如果SQL語句中沒有使用AS子名,列的名稱預設為資料表中對應的列名。例如對於"SELECT CityName AS CN FROM City",CN就是結果集中列的名稱。
    在ResultSet中的資料,可以通過getXX系列方法來獲取,例如:getString(), getInt(),"XX"取決於資料的型別。next()與previous()使遊標移到結果集中的下一條或上一條記錄。     Statement執行SQL語句返回ResultSet物件後,ResultSet就變成一個獨立的物件,與原先的Statement再也沒有聯絡,即使Statement物件關閉,重新執行其他sql語句,或者獲取多個結果集中的下一個。ResultSet將一直有效,除非顯式或隱式地將其關閉。
    在撰寫本文時,對於Statement物件,MySQL Connector/C++總是返回快取結果,這些結果在客戶端快取。不管結果集資料量大小,MySQLConnector/C++ Driver總是獲取所有的資料。希望以後的版本中,Statement物件能夠返回快取和非快取的結果集。     下面是資料獲取方法的簽名,可以在resultset.h標頭檔案中檢視所有ResultSet類支援的方法。
  1. /* resultset.h */
  2. size_t ResultSet::rowsCount() const;  
  3. void ResultSet::close();  
  4. bool ResultSet::next();  
  5. bool ResultSet::previous();  
  6. bool ResultSet::last();  
  7. bool ResultSet::first();  
  8. void ResultSet::afterLast();  
  9. void ResultSet::beforeFirst();  
  10. bool ResultSet::isAfterLast() const;  
  11. bool ResultSet::isBeforeFirst()const;  
  12. bool ResultSet::isClosed() const;  
  13. bool ResultSet::isNull(uint32_t columnIndex) const;  
  14. bool ResultSet::isNull(const std::string& columnLabel) const;  
  15. bool ResultSet::wasNull() const;  
  16. std::string ResultSet::getString(uint32_t columnIndex) const;  
  17. std::string ResultSet::getString(const std::string& columnLabel) const;  
  18. int32_t ResultSet::getInt(uint32_t columnIndex) const;  
  19. int32_t ResultSet::getInt(const std::string& columnLabel) const;  
    在下面的簡單示例中,查詢語句"SELECT * FROM City"返回的ResultSet中只包含一列:CityName,資料型別為String,對應MySQL中的VARCHAR型別。這個例子通過next方法迴圈從結果集中獲取CityName值,並顯示在控制檯上:
  1. while (res -> next())  
  2. cout << rs -> getString("CityName") << endl;  

    也可以通過位置來獲取列值(位置從1開始而非從0開始),下面的程式碼產生相同的結果:

  1. while (res -> next())   
  2.     cout << rs -> getString(1) << endl;  
    如果資料庫中該欄位的值為NULL,getString將返回一個空的字串。Result::isNull用於判斷指定列在資料庫中的值是否為NULL。Result::wasNULL()用於判斷最近讀取的列的值是否為空。     下面的例子演示了通過cursor(遊標)倒序讀取結果集中的資料:
  1. /* Move the cursor to the end of the ResultSet object, just after the last row */
  2. res -> afterLast();  
  3. if (!res -> isAfterLast())   
  4. {  
  5.     throw runtime_error("Error: Cursor position should be at the end of the result set after the last row.");  
  6. }  
  7. /* fetch the data : retrieve all the rows in the result set */
  8. while (res -> previous())   
  9. {  
  10.     cout << rs->getString("CityName") << endl;  
  11. }  

    getString方法在以下情況下會丟擲SQLException異常:指定列名或位置不存在;資料庫在執行操作時失敗;在一個關閉的cursor上執行呼叫該方法。