执行sql语句后的数据处理api

链接上mysql之后可以使用一些api对数据库进行一些操作

int mysql_query(MYSQL * connection, const char * query)

这是执行sql语句的函数，成功的话返回0

1.不返回数据的sql语句

对于update,delete,insert等操作

my_ulonglong mysql_affected_rows(MYSQL *connection);

这个函数返回受到影响的行数

2.发现插入的内容

select LAST_INSERT_ID();

可以找到最后一次影响的auto_increment的值

3.返回数据的语句
c程序中的数据处理的四个步骤是
    1）执行查询
    2）提取数据
    3）处理数据
    4）必要的清理

这里提取数据的函数是
mysql_use_result    //一次返回一行数据
mysql_store_result    //一次返回所有数据

这里处理数据的函数是
mysql_fetch_row

这里释放查询占用的内存资源的函数是

mysql_free_result>>>void mysql_free_result(MYSQL_RES * result);

 
    ***mysql_store_result函数

MYSQL_RES * mysql_store_result(MYSQL * connection);//成功返回指向结果集的指针，失败返回NULL
my_ulonglong mysql_num_rows(MYSQL_RES * result);//可以得到结果集中的行数
MYSQL_ROW mysql_fetch_row(MYSQL_RES * result);//得到结果集中的一行，放到一个行结构中
void mysql_data_seek(MYSQL_RES * reslut, my_ulonglong offset);//设置下次mysql_fetch_row的位置
//0的时候是下次从第一行开始取行，n-1意味着下次从第n行开始取行结构
MYSQL_ROW_OFFSET mysql_row_tell(MYSQL_RES * result);//返回一个偏移值表示结果集中的当前位置
//不能用于mysql_data_seek中，但是可以用到myslq_row_seek中，如下
MYSQL_ROW_OFFSET mysql_row_seek(MYSQL_RES * result, MYSQL_ROW_OFFSET offset);
//移动当前的位置到offste，返回的是之前的位置

    ***mysql_use_result函数

MYSQL_RES * mysql_use_result(MYSQL * connection);//一次返回一行数据，所以不能使用mysql_num_rows了

4.处理返回的数据
mysql提供两种类型的数据
    1）从表格中提取的信息，就是列数据
    2）关于数据的数据，也就是元数据（metadata），例如列名和类型

unsigned int mysql_field_count(MYSQL * connection);//接受连接对象，返回结果集中的字段（列）数目
MYSQL_FIELD * mysql_fetch_field(MYSQL_RES * result);//接受结果集，将元数据和数据提取到一个新的结构中
MYSQL_FIELD_OFFST mysql_field_seek(MYSQL_RES * result, MYSQL_FIELD_OFFSET offset);
//这个函数会随着mysql_fetch_field调用而自动增加，要是给参数offste传递值0，将跳回第一列

下面是一个综合使用上面的api的例子

#include <stdlib.h>
#include <stdio.h>

#include "mysql.h"

MYSQL my_connection;//定义链接结构
MYSQL_RES *res_ptr;//定义指向结果集的指针
MYSQL_ROW sqlrow;//定义行结构

void display_header();//定义类型打印函数
void display_row();//定义行打印函数


int main(int argc, char *argv[]) 
{
   int res;
   int first_row = 1;

   mysql_init(&my_connection);//初始化连接  
   if (mysql_real_connect(&my_connection, "localhost", "root", "", "foo", 0, NULL, 0)) 
   {//建立和数据库的连接
      printf("Connection success
");
   
      res = mysql_query(&my_connection, "SELECT childno, fname, age FROM children WHERE age > 5");
    //执行一条查询语句，针对的是当前的连接
      if (res) 
      {
         fprintf(stderr, "SELECT error: %s
", mysql_error(&my_connection));
      } else 
      {//指定sql语句成功的话
         res_ptr = mysql_use_result(&my_connection);//一次一行返回到指向结果集结构的指针
         if (res_ptr) 
         {//成功的话
            display_header();//进入子函数打印相应的结构信息
            while ((sqlrow = mysql_fetch_row(res_ptr))) //获取结果集中一行，放到行结构中
            {
               if (first_row) 
               {//恒执行
                  display_header();//进入子函数打印相应的结构信息
                  first_row = 0;//给整型值赋值为0
               }
               display_row();//进入子函数打印行信息
            }
            if (mysql_errno(&my_connection)) 
            {//失败的话，打印失败的信息
             fprintf(stderr, "Retrive error: %s
",mysql_error(&my_connection));
            }
         }
         mysql_free_result(res_ptr);//释放查询占用的内存资源
      }
      mysql_close(&my_connection);//关闭连接
   } 
   else 
   {//连接失败处理
      fprintf(stderr, "Connection failed
");
      if (mysql_errno(&my_connection)) {
        fprintf(stderr, "Connection error %d: %s
",
                                mysql_errno(&my_connection),
                                mysql_error(&my_connection));
        }
    }
   
   return EXIT_SUCCESS;
}


void display_header() {
   MYSQL_FIELD *field_ptr;

   printf("Column details:
");
 
   while ((field_ptr = mysql_fetch_field(res_ptr)) != NULL) //传入指向结果集指针，提取元数据和数据到一个新结构中
   {
      printf("	 Name: %s
", field_ptr->name);//打印列名
      printf("	 Type: ");//打印类型
      if (IS_NUM(field_ptr->type)) 
      {
         printf("Numeric field
");//类型是数值型情况
      } else 
      {//其他情况
         switch(field_ptr->type) 
         {
            case FIELD_TYPE_VAR_STRING:
               printf("VARCHAR
");
            break;
            case FIELD_TYPE_LONG: 
               printf("LONG
");
            break;
            default:
              printf("Type is %d, check in mysql_com.h
", field_ptr->type);
         } /* switch */
      } /* else */

      printf("	 Max width %ld
", field_ptr->length); /* Note on versions of MySQL before 4.0 the f
ormat should be %d, rather than %ld */
      if (field_ptr->flags & AUTO_INCREMENT_FLAG) 
         printf("	 Auto increments
");
      printf("
");
   } /* while */
}


void display_row() {
   unsigned int field_count;

   field_count = 0;
   while (field_count < mysql_field_count(&my_connection)) //列数目个打印
   {
      if (sqlrow[field_count]) printf("%s ", sqlrow[field_count]);//对行结构打印
      else printf("NULL");
      field_count++;
   }
   printf("
");
}

执行的结果

jason@t61:~/c_program/544977-blp3e/chapter08$ gcc -I/usr/include/mysql select4.c -L/usr/lib/mysql -lmysqlclient -o select4
jason@t61:~/c_program/544977-blp3e/chapter08$ ./select4 
Connection success
Column details:
     Name: childno
     Type: Numeric field
     Max width 11
     Auto increments

     Name: fname
     Type: VARCHAR
     Max width 30

     Name: age
     Type: Numeric field
     Max width 11

Column details:
1 Jenny 17 
2 Andrew 13 
6 Alex 11 
jason@t61:~/c_program/544977-blp3e/chapter08$