用户名:
密 码: 记住
您当前的位置:首页 > 网络编程 > mysql教程

c语言操作mysql 简介

时间:2015-04-02  来源:  作者:

 用C语言做数据库操作还真不多,一般都选择文件操作来搞定。 

最近一个项目需要用到MYSQL,就去看了下mysql之c api. 
基本上都是一样的,说白了就是一个应用层的协议。正因为做的机会不多,所以要写下来,免得以后忘记了。 

1.首先当然是连接,函数原型如下: 

MYSQL *		STDCALL mysql_real_connect(MYSQL *mysql, const char *host,
					   const char *user,
					   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函数中各参数,基本都是顾名思意。 

连接成功以后就需要执行sql语句。 

函数如下原型如下: 

int		STDCALL mysql_query(MYSQL *mysql, const char *q);


第一个参数上面已经介绍过,第二个参数为要执行的sql语句。 
这个函数总体就两步 
(1).发送sql语句,其实就一个socket发送sql 语句,加上mysql固定的协议头。懒的去看源码了,抓了下包,如下: 
0000   19 00 00 00 03 73 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函数指针 

获取结果 
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);


它会返回一个MYSQL_ROW变量,MYSQL_ROW其实就是char **.就当成一个二维数组来用吧。 

例如: 

sql_row=mysql_fetch_row(result)
printf("%sn",sql_row[0]);



还有很多api,不再一一介绍,大部分信息都在MYSQL_RES MYSQL这两个结构体中。 
具体可以参考mysql官方网站: 
http://dev.mysql.com/doc/refman/5.1/en/c.html 
突然发现官方网站资料好全面,貌似比任何书都要好。 

下面来个例子吧。 

#include #include #include #include #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 %lun ",(unsigned long)mysql_num_rows(result)); 				for(i=0;fd=mysql_fetch_field(result);i++)//获取列名 				{ 					bzero(column,sizeof(column)); 					strcpy(column,fd->name); 				} 				j=mysql_num_fields(result); 				for(i=0;i



上面这个例子就是从一个表中查数据,然后输出。 

如果要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 

 

数据库购买地址:http://www.xibushuju.com/services/webhosting/database.asp

来顶一下
返回首页
返回首页
推荐资讯
新媒体传播让柴静环保视频火了,让国人关注环保 新媒体传播让柴静环保视频火了,让新媒体传播让柴静环保视频火了,让国人关注环保
西部数码虚拟主机选购常识全攻略 西部数码虚拟主机选购常识全攻略西部数码虚拟主机选购常识全攻略
相关文章
    无相关信息
栏目更新
栏目热门