int mysql_stmt_fetch (MYSQL_STMT *支撑)
mysql_stmt_fetch ()
返回结果集中的下一行。它只能在结果集存在时被调用;也就是说,打了电话以后mysql_stmt_execute ()
对于这样的语句选择
它生成一个结果集。
mysql_stmt_fetch ()
使用绑定的缓冲区返回行数据mysql_stmt_bind_result ()
.它为当前行集中的所有列返回这些缓冲区中的数据,并将长度返回到长度
指针。在调用之前,应用程序必须绑定所有列mysql_stmt_fetch ()
.
mysql_stmt_fetch ()
通常发生在循环中,以确保获取所有结果集行。例如:
int状态;While (1) {status = mysql_stmt_fetch(stmt);if (status == 1 || status == MYSQL_NO_DATA);/*在这里处理当前行*/}/*如果需要,在这里处理status == 1 case和显示错误*/
默认情况下,每次从服务器获取无缓冲的一行结果集。要在客户机上缓冲整个结果集,请调用mysql_stmt_store_result ()
在绑定数据缓冲区之后和调用之前mysql_stmt_fetch ()
.
如果获取的数据值是零
值时,* is_null
对应的值MYSQL_BIND
结构包含TRUE(1)。否则,数据及其长度将在*缓冲
而且*长度
基于应用程序指定的缓冲区类型的元素。每个数值和时态类型都有固定的长度,如下表所示。字符串类型的长度取决于实际数据值的长度,如data_length
.
类型 | 长度 |
---|---|
MYSQL_TYPE_TINY |
1 |
MYSQL_TYPE_SHORT |
2 |
MYSQL_TYPE_LONG |
4 |
MYSQL_TYPE_LONGLONG |
8 |
MYSQL_TYPE_FLOAT |
4 |
MYSQL_TYPE_DOUBLE |
8 |
MYSQL_TYPE_TIME |
sizeof (MYSQL_TIME) |
MYSQL_TYPE_DATE |
sizeof (MYSQL_TIME) |
MYSQL_TYPE_DATETIME |
sizeof (MYSQL_TIME) |
MYSQL_TYPE_STRING |
数据长度 |
MYSQL_TYPE_BLOB |
data_length |
在某些情况下,您可能希望在用获取列值之前确定列值的长度mysql_stmt_fetch ()
.例如,值可以是一个长字符串或团
值,您希望知道必须为其分配多少空间。要做到这一点,可以使用以下策略之一:
在调用之前
mysql_stmt_fetch ()
要检索单个行,请传递STMT_ATTR_UPDATE_MAX_LENGTH
来mysql_stmt_attr_set ()
,然后调用mysql_stmt_store_result ()
在客户端缓冲整个结果。设置STMT_ATTR_UPDATE_MAX_LENGTH
属性将导致列值的最大长度由max_length
返回的结果集元数据的成员mysql_stmt_result_metadata ()
.调用
mysql_stmt_fetch ()
有一个零长度的缓冲区用于指定的列,一个指针用于存储实际长度。然后用实长度mysql_stmt_fetch_column ()
.real_length = 0;绑定[0]。缓冲= 0;绑定[0]。buffer_length = 0;绑定[0]。长度= &real_length mysql_stmt_bind_result(stmt, bind); mysql_stmt_fetch(stmt); if (real_length > 0) { data= malloc(real_length); bind[0].buffer= data; bind[0].buffer_length= real_length; mysql_stmt_fetch_column(stmt, bind, 0, 0); }
返回值 | 描述 |
---|---|
0 | 成功后,数据已被提取到应用程序数据缓冲区。 |
1 | 错误发生。通过调用可以获取错误码和消息mysql_stmt_errno () 而且mysql_stmt_error () . |
MYSQL_NO_DATA |
如果成功,则不再有数据存在 |
MYSQL_DATA_TRUNCATED |
数据截断发生 |
MYSQL_DATA_TRUNCATED
在启用截断报告时返回。若要确定在返回此值时截断了哪些列值,请检查错误
的成员MYSQL_BIND
用于获取值的结构。截断报告默认情况下是启用的,但是可以通过调用来控制mysql_options ()
与MYSQL_REPORT_DATA_TRUNCATION
选择。
命令的执行顺序不正确。
虽然
mysql_stmt_fetch ()
能产生这种错误,它更有可能发生为后C API调用mysql_stmt_fetch ()
调用的次数是否足够读取整个结果集(也就是说,返回的次数是否足够?MYSQL_NO_DATA
).内存不足。
MySQL服务器已经离开。
查询过程中与服务器的连接丢失。
发生了未知错误。
缓冲区类型为
MYSQL_TYPE_DATE
,MYSQL_TYPE_TIME
,MYSQL_TYPE_DATETIME
,或MYSQL_TYPE_TIMESTAMP
,但数据类型不是日期
,时间
,DATETIME
,或时间戳
.返回所有其他不支持的转换错误
mysql_stmt_bind_result ()
.
下面的示例演示如何使用mysql_stmt_result_metadata ()
,mysql_stmt_bind_result ()
,mysql_stmt_fetch ()
.(此示例期望检索中所示示例插入的两行部分6.4.10”mysql_stmt_execute ())。的mysql
变量被假定为有效的连接处理程序。
#define STRING_SIZE 50 # SELECT_SAMPLE "SELECT col1, col2, col3, col4 \ FROM test_table" MYSQL_STMT *stmt;MYSQL_BIND绑定[4];MYSQL_RES * prepare_meta_result;MYSQL_TIME ts;无符号长长度[4];Int param_count, column_count, row_count;短small_data;int int_data;char str_data [STRING_SIZE];bool is_null [4]; bool error[4]; /* Prepare a SELECT query to fetch data from test_table */ stmt = mysql_stmt_init(mysql); if (!stmt) { fprintf(stderr, " mysql_stmt_init(), out of memory\n"); exit(0); } if (mysql_stmt_prepare(stmt, SELECT_SAMPLE, strlen(SELECT_SAMPLE))) { fprintf(stderr, " mysql_stmt_prepare(), SELECT failed\n"); fprintf(stderr, " %s\n", mysql_stmt_error(stmt)); exit(0); } fprintf(stdout, " prepare, SELECT successful\n"); /* Get the parameter count from the statement */ param_count= mysql_stmt_param_count(stmt); fprintf(stdout, " total parameters in SELECT: %d\n", param_count); if (param_count != 0) /* validate parameter count */ { fprintf(stderr, " invalid parameter count returned by MySQL\n"); exit(0); } /* Execute the SELECT query */ if (mysql_stmt_execute(stmt)) { fprintf(stderr, " mysql_stmt_execute(), failed\n"); fprintf(stderr, " %s\n", mysql_stmt_error(stmt)); exit(0); } /* Fetch result set meta information */ prepare_meta_result = mysql_stmt_result_metadata(stmt); if (!prepare_meta_result) { fprintf(stderr, " mysql_stmt_result_metadata(), \ returned no meta information\n"); fprintf(stderr, " %s\n", mysql_stmt_error(stmt)); exit(0); } /* Get total columns in the query */ column_count= mysql_num_fields(prepare_meta_result); fprintf(stdout, " total columns in SELECT statement: %d\n", column_count); if (column_count != 4) /* validate column count */ { fprintf(stderr, " invalid column count returned by MySQL\n"); exit(0); } /* Bind the result buffers for all 4 columns before fetching them */ memset(bind, 0, sizeof(bind)); /* INTEGER COLUMN */ bind[0].buffer_type= MYSQL_TYPE_LONG; bind[0].buffer= (char *)&int_data; bind[0].is_null= &is_null[0]; bind[0].length= &length[0]; bind[0].error= &error[0]; /* STRING COLUMN */ bind[1].buffer_type= MYSQL_TYPE_STRING; bind[1].buffer= (char *)str_data; bind[1].buffer_length= STRING_SIZE; bind[1].is_null= &is_null[1]; bind[1].length= &length[1]; bind[1].error= &error[1]; /* SMALLINT COLUMN */ bind[2].buffer_type= MYSQL_TYPE_SHORT; bind[2].buffer= (char *)&small_data; bind[2].is_null= &is_null[2]; bind[2].length= &length[2]; bind[2].error= &error[2]; /* TIMESTAMP COLUMN */ bind[3].buffer_type= MYSQL_TYPE_TIMESTAMP; bind[3].buffer= (char *)&ts; bind[3].is_null= &is_null[3]; bind[3].length= &length[3]; bind[3].error= &error[3]; /* Bind the result buffers */ if (mysql_stmt_bind_result(stmt, bind)) { fprintf(stderr, " mysql_stmt_bind_result() failed\n"); fprintf(stderr, " %s\n", mysql_stmt_error(stmt)); exit(0); } /* Now buffer all results to client (optional step) */ if (mysql_stmt_store_result(stmt)) { fprintf(stderr, " mysql_stmt_store_result() failed\n"); fprintf(stderr, " %s\n", mysql_stmt_error(stmt)); exit(0); } /* Fetch all rows */ row_count= 0; fprintf(stdout, "Fetching results ...\n"); while (!mysql_stmt_fetch(stmt)) { row_count++; fprintf(stdout, " row %d\n", row_count); /* column 1 */ fprintf(stdout, " column1 (integer) : "); if (is_null[0]) fprintf(stdout, " NULL\n"); else fprintf(stdout, " %d(%ld)\n", int_data, length[0]); /* column 2 */ fprintf(stdout, " column2 (string) : "); if (is_null[1]) fprintf(stdout, " NULL\n"); else fprintf(stdout, " %s(%ld)\n", str_data, length[1]); /* column 3 */ fprintf(stdout, " column3 (smallint) : "); if (is_null[2]) fprintf(stdout, " NULL\n"); else fprintf(stdout, " %d(%ld)\n", small_data, length[2]); /* column 4 */ fprintf(stdout, " column4 (timestamp): "); if (is_null[3]) fprintf(stdout, " NULL\n"); else fprintf(stdout, " %04d-%02d-%02d %02d:%02d:%02d (%ld)\n", ts.year, ts.month, ts.day, ts.hour, ts.minute, ts.second, length[3]); fprintf(stdout, "\n"); } /* Validate rows fetched */ fprintf(stdout, " total rows fetched: %d\n", row_count); if (row_count != 2) { fprintf(stderr, " MySQL failed to return all rows\n"); exit(0); } /* Free the prepared result metadata */ mysql_free_result(prepare_meta_result); /* Close the statement */ if (mysql_stmt_close(stmt)) { /* mysql_stmt_close() invalidates stmt, so call */ /* mysql_error(mysql) rather than mysql_stmt_error(stmt) */ fprintf(stderr, " failed while closing the statement\n"); fprintf(stderr, " %s\n", mysql_error(mysql)); exit(0); }