MySQL中遍历查询结果的常用API(c) 您所在的位置:网站首页 shell脚本遍历mysql结果集 MySQL中遍历查询结果的常用API(c)

MySQL中遍历查询结果的常用API(c)

2024-06-28 23:28| 来源: 网络整理| 查看: 265

本中所使用的table:

MySQL中的错误处理函数

 unsigned int mysql_errno(MYSQL *mysql) 

 const char *mysql_error(MYSQL *mysql) 

说明:一个函数是返回错误号,一个返回错误信息,两者都以MYSQL*为参数,很直观。

第一步:进行查询操作

用到的函数:

int mysql_query(MYSQL *mysql, const char *stmt_str) 

int mysql_real_query(MYSQL *mysql, const char *stmt_str, unsigned longlength) 

返回值:成功则返回0,失败返回非零,如果失败的话,可以利用错误处理函数来获得错误信息。

这两个函数的区别:当查询语句使用的是二进制数据时,只能用后者。

 

第二步:保存查询结果(仅select语句具有查询结果,update、delete、insert是没有查询结果的)

用到的函数:

 MYSQL_RES *mysql_store_result(MYSQL *mysql) 

 MYSQL_RES *mysql_use_result(MYSQL *mysql) 

返回值:如果执行成功,返回一个非空的MYSQL_RES指针,否则,返回NULL。注意,只要执行select语句成功,就算没有与该select语句匹配的表项,该函数的返回值也不应为NULL。

两个函数的区别:mysql_store_result将整个result set放进client中存储,假若select的查询结果有一百个表项,则调用mysql_store_result会将这一百个表项全都存在了内存中,而mysql_use_result仅仅从result set中取出一个表项存在内存中,使用mysql_fetch_row()函数时才从server中的result set中取出下一个表项。因此mysql_use_result占用的内存更少执行速度也更快。但如果你需要在client端对result set的数据进行一些处理的话,那还是用mysql_store_set吧。

总结:mysql_store_result将select语句在server中的执行结果全都存到了client的内存中,而mysql_use_result仅当需要用到数据时才从server中取出下一条数据存到client的内存中。

注意:结果用完之后,要用mysql_free_result()释放内存。该函数的原型为 void mysql_free_result(MYSQL_RES *result) 

 第三步:遍历结果

遍历结果可分为两个步骤:首先取出result set中的一行数据,然后再遍历该行数据中的每列数据。

遍历行时用到的函数:

 MYSQL_ROW mysql_fetch_row(MYSQL_RES *result) 

说明:它以上一步中的查询结果为参数,返回一个MYSQL_ROW结构体,这个结构体的内容为result set中的一行数据,可以理解为一个元素为字符指针的数组(char* row[elems]),当result set中的所有数据遍历完毕,该函数返回NULL。那么怎样使用这个结构体呢?首先得通过下面的函数(mysql_num_fields() / mysql_field_count())得到result set中的列数,然后从index从0开始,以(列数 - 1)结束,依此遍历就可以了。以col代指当前列,若当前列的值为NULL,MYSQL_ROW[col]的值也为NULL。

使用示例:

1 MYSQL_ROW row; 2 unsigned int cols = mysql_field_count(conn_ptr); 3 while ((row = mysql_fetch_row(res_ptr)) != NULL) 4 { 5 for (unsigned int i = 0; i < cols; ++i) 6 { 7 printf("%s ", row[i]); 8 } 9 printf("\n"); 10 }

 

输出结果如下:

其实正常情况下应该对row[i]是否为NULL进行判断的,这里让我有点疑惑,为何row[i]在为空的情况下,也行正常printf出结果,而不产生段错误。

1 MYSQL_ROW row; 2 unsigned int cols = mysql_field_count(conn_ptr); 3 while((row = mysql_fetch_row(res_ptr)) != NULL) 4 { 5 for(unsigned int i = 0;i < cols;++i) 6 { 7 if(row[i] == NULL) 8 printf("i am null"); 9 else 10 printf("%s ",row[i]); 11 } 12 printf("\n"); 13 }

结果:

遍历列时用到的函数:

 unsigned int mysql_num_fields(MYSQL_RES *result) 

 unsigned int mysql_field_count(MYSQL *mysql) 

 MYSQL_FIELD *mysql_fetch_field(MYSQL_RES *result) 

对于前面两个函数,它们的参数不同,但是效果却是相同的,都是返回当前查询的result set中的列数。

通过第三个函数可以得到列的属性(包括列的name,列的type等信息),它的用法与mysql_fetch_col()差不多,也需要用while不停地循环。当返回值为空时,就代表没有下一列了。

使用示例:

1 MYSQL_RES* res_ptr = mysql_store_result(conn_ptr); 2 if(res_ptr) 3 { 4 printf("use result successful\n"); 5 6 MYSQL_FIELD* field; 7 while((field = mysql_fetch_field(res_ptr))) 8 { 9 printf("%s ",field->name); 10 } 11 printf("\n"); 12 13 }

结果: 

 全部代码

1 #include 2 3 #include 4 #include 5 6 int main() 7 { 8 //MYSQL* mysql_init(MYSQL *mysql) 9 MYSQL* conn_ptr = mysql_init(NULL); 10 if(conn_ptr == NULL) 11 { 12 fprintf(stderr,"mysql_init() failed\n"); 13 return -1; 14 } 15 //MYSQL* mysql_real_connect(MYSQL *mysql, const char *host, 16 //const char *user,const char *passwd, const char *db, 17 //unsigned int port, const char *unix_socket, unsigned long clientflag) 18 mysql_real_connect(conn_ptr,"localhost", 19 "rick","secretpassword","rick", 20 0,NULL,0); 21 if(conn_ptr) 22 { 23 printf("connect successfully\n"); 24 int query_ret = mysql_query(conn_ptr,"SELECT * FROM children;"); 25 if(query_ret == 0) 26 { 27 printf("query successful\n"); 28 29 MYSQL_RES* res_ptr = mysql_store_result(conn_ptr); 30 if(res_ptr) 31 { 32 printf("use result successful\n"); 33 34 MYSQL_FIELD* field; 35 while((field = mysql_fetch_field(res_ptr))) 36 { 37 printf("%s ",field->name); 38 } 39 printf("\n"); 40 41 MYSQL_ROW row; 42 unsigned int cols = mysql_field_count(conn_ptr); 43 while((row = mysql_fetch_row(res_ptr)) != NULL) 44 { 45 for(unsigned int i = 0;i < cols;++i) 46 { 47 printf("%s ",row[i]); 48 } 49 printf("\n"); 50 } 51 } 52 else 53 { 54 fprintf(stderr,"use result failed %d : %s\n",mysql_errno(conn_ptr),mysql_error(conn_ptr)); 55 } 56 mysql_free_result(res_ptr); 57 } 58 else 59 { 60 fprintf(stderr,"query failed %d : %s\n",mysql_errno(conn_ptr),mysql_error(conn_ptr)); 61 } 62 63 } 64 else 65 { 66 printf("connect failed\n"); 67 } 68 //void mysql_close(MYSQL *sock) 69 mysql_close(conn_ptr); 70 return 0; 71 }

 



【本文地址】

公司简介

联系我们

今日新闻

    推荐新闻

    专题文章
      CopyRight 2018-2019 实验室设备网 版权所有