MySQL的C语言API接口
1、首先当然是连接数据库,函数原型如下:
MYSQL*STDCALLmysql_real_connect(MYSQL*mysql,constchar*host, constchar*user, constchar*passwd, constchar*db, unsignedintport, constchar*unix_socket, unsignedlongclientflag);
第一个参数MYSQL是Capi中一个非常重要的变量,里面内存非常丰富,有port,dbname,charset等连接基本参数。它也包含了一个叫st_mysql_methods的结构体变量,该变量里面保存着很多函数指针,这些函数指针将会在数据库连接成功以后的各种数据操作中被调用。mysql_real_connect函数中各参数,基本都是顾名思意。
2、连接数据库成功之后就可以执行sql语句了使用mysql_query
intSTDCALLmysql_query(MYSQL*mysql,constchar*q);
第一个参数上面已经介绍过,第二个参数为要执行的sql语句。
这个函数总体就两步:
(1)发送sql语句,其实就一个socket发送sql语句,加上mysql固定的协议头。懒的去看源码了,抓了下包,如下:
0000190000000373656c656374206170705f.....selectapp_
00106e616d652066726f6d20617070namefromapp
红色部分是协议,前面两位其实就是包的长度。具体协议没研究过。
(2)然后就是接受结果,这里将会调用MYSQL变量中的st_mysql_methods中的read_query_result函数指针
3、获取结果
sql执行完以后,如果是查询语句,我们当然还要读取数据,如果update,insert等语句,那么就看下操作成功与否即可。我们来看看如何获取查询结果:如果mysql_query返回成功,那么我们就通过mysql_store_result这个函数来读取结果。原型如下:
MYSQL_RES*STDCALLmysql_store_result(MYSQL*mysql);
该函数会调用MYSQL变量中的st_mysql_methods中的read_rows函数指针来获取查询的结果。同时该函数会返回MYSQL_RES这样一个变量,该变量主要用于保存查询的结果。同时该函数malloc了一片内存空间来存储查询过来的数据,所以我们一定要记的free(result),不然是肯定会造成内存泄漏的。执行完mysql_store_result以后,其实数据都已经在MYSQL_RES变量中了,下面的api基本就是读取MYSQL_RES中的数据。例如mysql_fetch_row这个函数,就是读去查询结果的一行。函数原型如下
MYSQL_ROWSTDCALLmysql_fetch_row(MYSQL_RES*result);
它会返回一个MYSQL_ROW变量,MYSQL_ROW其实就是char**.就当成一个二维数组来用吧。还有很多api,不再一一介绍,大部分信息都在MYSQL_RESMYSQL这两个结构体中。具体可以参考mysql官方网站:http://dev.mysql.com/doc/refman/5.1/en/c.html突然发现官方网站资料好全面,貌似比任何书都要好。
下面来个例子:
#include<stdio.h> #include<stdlib.h> #include<string.h> #include<mysql/mysql.h> #defineMAX_COLUMN_LEN32 intmain(intargc,char*argv[]) { MYSQLmy_connection; MYSQL_RES*result; MYSQL_ROWsql_row; MYSQL_FIELD*fd; charcolumn[MAX_COLUMN_LEN][MAX_COLUMN_LEN]; intres; mysql_init(&my_connection); if(mysql_real_connect(&my_connection,"127.0.0.1","用户","密码","数据名称",3306,NULL,0)) { perror("connect"); res=mysql_query(&my_connection,"select*fromapp");//查询 if(!res) { result=mysql_store_result(&my_connection);//保存查询到的数据到result if(result) { inti,j; printf("theresultnumberis%lu\n",(unsignedlong)mysql_num_rows(result)); for(i=0;fd=mysql_fetch_field(result);i++)//获取列名 { bzero(column[i],sizeof(column[i])); strcpy(column[i],fd->name); } j=mysql_num_fields(result); for(i=0;i<j;i++) { printf("%s\t",column[i]); } printf("\n"); while(sql_row=mysql_fetch_row(result))//获取具体的数据 { for(i=0;i<j;i++) { printf("%s\t",sql_row[i]); } printf("\n"); } } } else { perror("select"); } } else { perror("connect:error"); } mysql_free_result(MYSQL_RES*result);//释放结果资源 mysql_close(&my_connection);//断开连接 }
上面这个例子就是从一个表中查数据,然后输出。如果要insert或者update,只需要修改具体的sql既可。具体的操作都是通过mysql_query这个函数来搞定。现在来讲编译的方法吧,这里我们需要.h以及.so库。我们可以在http://dev.mysql.com/downloads/connector/c/6.0.html下载Connector/C。简单的方法就是:把里面include的东西拷贝到/usr/include/mysql/下面去,这样编译的时候就不需要加-I了,然后把lib下面的东西拷贝的/usr/lib/下去。
gcc具体的编译方法:gcc***.c-o***-lmysqlclient