MySQL的C语⾔API接⼝
1、⾸先当然是连接数据库,函数原型如下:
MYSQL * STDCALL mysql_real_connect(MYSQL *mysql, const char *host,
const char *user,
百度api接口const char *passwd,
const char *db,
unsigned int port,
const char *unix_socket,
unsigned long clientflag);
第⼀个参数 MYSQL是 C api中⼀个⾮常重要的变量,⾥⾯内存⾮常丰富,有port,dbname,charset等连接基本参数。它也包含了⼀个叫 st_mysql_methods的结构体变量,该变量⾥⾯保存着很多函数指针,这些函数指针将会在数据库连接成功以后的各种数据操作中被调⽤。mysql_real_connect函数中各参数,基本
都是顾名思意。
2、连接数据库成功之后就可以执⾏sql语句了使⽤mysql_query
int STDCALL mysql_query(MYSQL *mysql, const char *q);
第⼀个参数上⾯已经介绍过,第⼆个参数为要执⾏的sql语句。
这个函数总体就两步:
(1)发送sql语句,其实就⼀个socket发送sql 语句,加上mysql固定的协议头。懒的去看源码了,抓了下包,如下:
0000 19 00 00 00 0373 65 6c 65 63 74 20 61 70 70 5f .....select app_
0010 6e 61 6d 65 20 66 72 6f 6d 20 61 70 70 name from app
红⾊部分是协议,前⾯两位其实就是包的长度。具体协议没研究过。
(2)然后就是接受结果,这⾥将会调⽤MYSQL变量中的st_mysql_methods中的read_query_result函数指针
3、获取结果
sql执⾏完以后,如果是查询语句,我们当然还要读取数据,如果update,insert等语句,那么就看下操作成功与否即可。我们来看看如何获取查询结果:如果mysql_query返回成功,那么我们就通过mysql_store_result这个函数来读取结果。原型如下:
MYSQL_RES * STDCALL mysql_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_ROW STDCALL mysql_fetch_row(MYSQL_RES *result);
下⾯来个例⼦:
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<mysql/mysql.h>
#define MAX_COLUMN_LEN  32
int main(int argc , char *argv[])
{
MYSQL my_connection;
MYSQL_RES *result;
MYSQL_ROW sql_row;
MYSQL_FIELD *fd;
char column[MAX_COLUMN_LEN][MAX_COLUMN_LEN];
int res;
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 * from app");//查询
if(!res)
{
result=mysql_store_result(&my_connection);//保存查询到的数据到result
if(result)
{
int i,j;
printf("the result number is %lu\n ",(unsigned long)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);//断开连接
}
gcc具体的编译⽅法:gcc ***.c -o *** -lmysqlclient

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。