PDF (美国字母) - 1.4Mb
PDF (A4) - 1.4Mb
默认情况下，mysql_real_query() 和 mysql_query() 将其语句字符串参数解释为要执行的单个语句，并且您根据该语句是否产生结果集（一组行，例如 SELECT）或受影响的行数（例如 INSERT、UPDATE 等等）来处理结果。
MySQL 还支持执行包含多个以分号 (;) 字符分隔的语句的字符串。此功能通过在您使用 mysql_real_connect() 连接到服务器时或连接后通过调用 mysql_set_server_option() 指定的特殊选项启用。
执行多语句字符串可能会产生多个结果集或行计数指示器。处理这些结果涉及与单语句情况不同的方法：在处理第一个语句的结果后，有必要检查是否还有更多结果，并在存在的情况下依次处理它们。为了支持多结果处理，C API 包括 mysql_more_results() 和 mysql_next_result() 函数。这些函数在循环结束时使用，该循环只要有更多结果可用就迭代。 如果未以这种方式处理结果，可能会导致与服务器的连接断开。
如果您执行 CALL 语句以调用存储过程，也需要进行多结果处理。存储过程的结果具有以下特点
-
过程中的语句可能会产生结果集（例如，如果它执行
SELECT语句）。这些结果集按过程执行时产生的顺序返回。一般来说，调用者无法知道过程将返回多少个结果集。过程执行可能取决于循环或条件语句，这些语句会导致执行路径在一次调用到另一次调用之间发生变化。因此，您必须准备好检索多个结果。
来自过程的最终结果是一个状态结果，其中不包含结果集。该状态指示过程是成功还是发生了错误。
多语句和多结果功能只能与 mysql_real_query() 或 mysql_query() 一起使用。它们不能与准备好的语句接口一起使用。准备好的语句句柄被定义为仅适用于包含单个语句的字符串。请参见 第 6 章，C API 准备好的语句接口。
要启用多语句执行和多结果处理，可以使用以下选项
-
mysql_real_connect()函数有一个flags参数，其中两个选项值是相关的CLIENT_MULTI_RESULTS使客户端程序能够处理多个结果。如果您执行CALL语句以调用产生结果集的存储过程，则 必须启用此选项。否则，此类过程会导致错误Error 1312 (0A000): PROCEDURE。proc_namecan't return a result set in the given contextCLIENT_MULTI_RESULTS默认情况下启用。CLIENT_MULTI_STATEMENTS使mysql_real_query()和mysql_query()能够执行包含以分号分隔的多个语句的语句字符串。此选项还会隐式启用CLIENT_MULTI_RESULTS，因此将flags参数CLIENT_MULTI_STATEMENTS传递给mysql_real_connect()等效于传递CLIENT_MULTI_STATEMENTS | CLIENT_MULTI_RESULTS的参数。也就是说，CLIENT_MULTI_STATEMENTS足以启用多语句执行和所有多结果处理。
在与服务器建立连接后，您可以使用
mysql_set_server_option()函数通过传递MYSQL_OPTION_MULTI_STATEMENTS_ON或MYSQL_OPTION_MULTI_STATEMENTS_OFF的参数来启用或禁用多语句执行。使用此函数启用多语句执行也能够处理多语句字符串的 “简单” 结果，其中每个语句产生单个结果，但 不足以允许处理产生结果集的存储过程。
以下步骤概述了建议的多语句处理策略
将
CLIENT_MULTI_STATEMENTS传递给mysql_real_connect()，以完全启用多语句执行和多结果处理。在调用
mysql_real_query()或mysql_query()并验证其成功后，进入一个循环，您将在其中处理语句结果。对于循环的每次迭代，都处理当前语句结果，检索结果集或受影响的行数。如果发生错误，则退出循环。
在循环结束时，调用
mysql_next_result()以检查是否还有更多结果，并在存在的情况下启动对它的检索。如果没有更多结果可用，则退出循环。
以下显示了对先前策略的一种可能的实现。循环的最后部分可以简化为对 mysql_next_result() 是否返回非零值的简单测试。按照编写的方式，代码区分了没有更多结果和错误，这使得能够为后一种情况打印一条消息。
Press CTRL+C to copy/* connect to server with the CLIENT_MULTI_STATEMENTS option */ if (mysql_real_connect (mysql, host_name, user_name, password, db_name, port_num, socket_name, CLIENT_MULTI_STATEMENTS) == NULL) { printf("mysql_real_connect() failed\n"); mysql_close(mysql); exit(1); } /* execute multiple statements */ status = mysql_query(mysql, "DROP TABLE IF EXISTS test_table;\ CREATE TABLE test_table(id INT);\ INSERT INTO test_table VALUES(10);\ UPDATE test_table SET id=20 WHERE id=10;\ SELECT * FROM test_table;\ DROP TABLE test_table"); if (status) { printf("Could not execute statement(s)"); mysql_close(mysql); exit(0); } /* process each statement result */ do { /* did current statement return data? */ result = mysql_store_result(mysql); if (result) { /* yes; process rows and free the result set */ process_result_set(mysql, result); mysql_free_result(result); } else /* no result set or error */ { if (mysql_field_count(mysql) == 0) { printf("%lld rows affected\n", mysql_affected_rows(mysql)); } else /* some error occurred */ { printf("Could not retrieve result set\n"); break; } } /* more results? -1 = no, >0 = error, 0 = yes (keep looping) */ if ((status = mysql_next_result(mysql)) > 0) printf("Could not execute statement\n"); } while (status == 0); mysql_close(mysql);