Linux下C语言执行MySQL语句

标签: linux 语言 mysql | 发表时间:2013-12-28 07:14 | 作者:shuangde800
出处:http://blog.csdn.net


本文出自    http://blog.csdn.net/shuangde800



执行SQL语句的增、删、改、查的主要API函数为:

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

函数接收参数连接句柄和字符串形式的有效SQL语句(没有结束的分号,这与mysql工具不同)。如果成功,它返回0。

如果包含二进制数据的查询,要使用mysql_real_query.


检查受查询影响的行数:

my_ulonglong mysql_affected_rows(MYSQL *connection);
my_ulonglong是无符号长整形,为%lu格式
这个函数返回受之前执行update,insert或delete查询影响的行数。


例子

数据库中有一个student表

CREATE TABLE student (
		student_no varchar(12) NOT NULL PRIMARY KEY,
		student_name varchar(12) NOT NULL
		);





增、删、改代码:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "mysql.h"
#include "errmsg.h"
#include "mysqld_error.h"


MYSQL conn;

void connection(const char* host, const char* user, const char* password, const char* database) {
	mysql_init(&conn); // 注意取地址符&

	if (mysql_real_connect(&conn, host, user, password, database, 0, NULL, 0)) {
		printf("Connection success!\n");
	} else {
		fprintf(stderr, "Connection failed!\n");
		if (mysql_errno(&conn)) {
			fprintf(stderr, "Connection error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
		}
		exit(EXIT_FAILURE);
	}
}

void insert() {
	int res = mysql_query(&conn, "INSERT INTO student(student_no,student_name) VALUES('123465', 'Ann')");
	if (!res) {
		printf("Inserted %lu rows\n", (unsigned long)mysql_affected_rows(&conn));
	} else {
		fprintf(stderr, "Insert error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
	}
}

void update() {
	int res = mysql_query(&conn, "UPDATE student SET student_name='Anna' WHERE student_no='123465'");
	if (!res) {
		printf("Update %lu rows\n", (unsigned long)mysql_affected_rows(&conn));
	} else {
		fprintf(stderr, "Update error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
	}
}

void delete() {
	int res = mysql_query(&conn, "DELETE from student WHERE student_no='123465'");
	if (!res) {
		printf("Delete %lu rows\n", (unsigned long)mysql_affected_rows(&conn));
	} else {
		fprintf(stderr, "Delete error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
	}
}


int main (int argc, char *argv[]) {

	connection("localhost", "root", "shuang", "shuangde");
	delete();
	mysql_close(&conn);
	exit(EXIT_SUCCESS);
}


返回数据的语句:select


SQL最常见的用法是提取数据而不是插入或更新数据。数据是用select语句提取的

C应用程序提取数据一般需要4个步骤:

1、执行查询

2、提取数据

3、处理数据

4、必要的清理工作


就像之前的insert和update一样,使用mysql_query来发送SQL语句,然后使用mysql_store_result或mysql_use_result来提取数据,具体使用哪个语句取决于你想如何提取数据。接着,将使用一系列mysql_fetch_row来处理数据。最后,使用mysql_free_result释放查询占用的内存资源。


一次提取所有数据:mysql_store_result

// 相关函数:

// 这是在成功调用mysql_query之后使用此函数,这个函数将立刻保存在客户端中返回的所有数据。它返回一个指向结果集结构的指针,如果失败返回NULL
MYSQL_RES *mysql_store_result(MYSQL *connection);

// 这个函数接受由mysql_store_result返回的结果结构集,并返回结构集中的行数
my_ulonglong mysql_num_rows(MYSQL_RES *result);


// 这个函数从使用mysql_store_result得到的结果结构中提取一行,并把它放到一个行结构中。当数据用完或发生错误时返回NULL.
MYSQL_ROW mysql_fetch_row(MYSQL_RES *resutl);


// 这个函数用来在结果集中跳转,设置将会被下一个mysql_fetch_row操作返回的行。参数offset是一个行号,它必须是在0~结果总行数-1的范围内。传递
// 0将会导致下一个mysql_fetch_row调用返回结果集中的第一行。
void mysql_data_seek(MYSQL_RES *result, my_ulonglong offset);


// 返回一个偏移值,它用来表示结果集中的当前位置。它不是行号,不能把它用于mysql_data_seek
MYSQL_ROW_OFFSET mysql_row_tell(MYSQL_RES *result);


// 这将在结果集中移动当前的位置,并返回之前的位置
MYSQL_ROW_OFFSET mysql_row_seek(MYSQL_RES *result, MYSQL_ROW_OFFSET offset);


// 完成所有对数据的操作后,必须总是调用这个来善后处理
void mysql_free_result(MYSQL_RES *result);



示例代码:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "mysql.h"
#include "errmsg.h"
#include "mysqld_error.h"


MYSQL conn;
MYSQL_RES *res_ptr;
MYSQL_ROW sqlrow;

void connection(const char* host, const char* user, const char* password, const char* database) {
	mysql_init(&conn); // 注意取地址符&

	if (mysql_real_connect(&conn, host, user, password, database, 0, NULL, 0)) {
		printf("Connection success!\n");
	} else {
		fprintf(stderr, "Connection failed!\n");
		if (mysql_errno(&conn)) {
			fprintf(stderr, "Connection error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
		}
		exit(EXIT_FAILURE);
	}
}

int main (int argc, char *argv[]) {

	connection("localhost", "root", "shuang", "shuangde");
	int res = mysql_query(&conn, "SELECT * from student");
	if (res) {
		fprintf(stderr, "SELECT error: %s\n", mysql_error(&conn));
	} else {
		res_ptr = mysql_store_result(&conn);
		if (res_ptr) {
			printf("Retrieved %lu rows\n", (unsigned long)mysql_num_rows(res_ptr));	
			while ((sqlrow = mysql_fetch_row(res_ptr))) {
				printf("Fetched data...\n")	;
			}
			if (mysql_errno(&conn)) {
				fprintf(stderr, "Retrive error: %s\n", mysql_error(&conn));
			}
			mysql_free_result(res_ptr);
		} 
	}
	mysql_close(&conn);
	exit(EXIT_SUCCESS);
}


一次提取一行数据:mysql_use_result


使用方法和mysql_store_result完全一样,把上面代码的mysql_store_result改为mysql_use_result即可。

mysql_use_result具备资源管理方面的实质性好处,更好地平衡了网络负载,以及减少了可能非常大的数据带来的存储开销,但是不能与mysql_data_seek、mysql_row_seek、mysql_row_tell、mysql_num_rows一起使用。如果数据比较少,用mysql_store_result更好。



处理返回的数据

 
// 相关函数和定义:


// 返回结果集中的字段(列)数目
unsigned int mysql_field_count(MYSQL *connection);

// 将元数据和数据提取到一个新的结构中
MYSQL_FIELD *mysql_fetch_field(MYSQL *result);

// 这个函数用来覆盖当前的字段编号,该编号会随着每次mysql_fetch_field调用而自动增加。如果给offset传递0,那么将跳回第1列
MYSQL_FIELD_OFFSET mysql_field_seek(MYSQL *result, MYSQL_FIELD_OFFSET offset);


// MYSQL_FIELD定义在sql.h中,是指向字段结构数据的指针,有关于列的信息。有成员:
char *name;		// 列名,为字符串
char *table;	// 列所属表名
char *def;		// 如果调用mysql_list_fields,它将包含该列的默认值
enum enum_field_types type;  // 列类型
unsigned int length;		 // 列宽
unsigned int max_length;	 // 如果使用mysql_store_result,它将包含以字节为单位的提取的最长列值的长度,如果使用mysql_use_result,将不会被设置
unsigned int flags;			 // 关于列定义的标志,与得到的数据无关.常见的标志的含义有:
						     //	NOT_NULL_FLAG
							 // PRI_KEY_FLAG
						     //	UNSIGNED_FLAG
							 // AUTO_INCREMENT_FLAG
							 // BINARY_FLAG等
unsigned int decimals;		 // 小数点后的数字个数。


// 列类型相当广泛,完整的列表见头文件mysql_com.h,常见的有:
//	FIELD_TYPE_DECIMAL
//	FIELD_TYPE_LONG
//	FIELD_TYPE_STRING
//	FIELD_TYPE_VAR_STRING

//一个特别有用的预定义宏: IS_NUM,当字段类型为数字时,返回true


代码示例:

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include "mysql.h"
#include "errmsg.h"
#include "mysqld_error.h"


MYSQL conn;
MYSQL_RES *res_ptr;
MYSQL_ROW sqlrow;

void connection(const char* host, const char* user, const char* password, const char* database) {
	mysql_init(&conn); // 注意取地址符&

	if (mysql_real_connect(&conn, host, user, password, database, 0, NULL, 0)) {
		printf("Connection success!\n");
	} else {
		fprintf(stderr, "Connection failed!\n");
		if (mysql_errno(&conn)) {
			fprintf(stderr, "Connection error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
		}
		exit(EXIT_FAILURE);
	}
}

void display_row() {
	unsigned int field_count = mysql_field_count(&conn);
	int i = 0;
	while (i < field_count) {
		if (sqlrow[i]) printf("%s ", sqlrow[i]);
		else printf("NULL");
		i++;
	}
	printf("\n");
}

void display_header() {
	MYSQL_FIELD *field_ptr;
	printf("Column details:\n");
	while ((field_ptr = mysql_fetch_field(res_ptr)) != NULL) {
		printf("\t Name: %s\n", field_ptr->name);	
		printf("\t Table: %s\n", field_ptr->table);	
		printf("\t Type: ");
		if (IS_NUM(field_ptr->type)) {
			printf("Numeric field\n");	
		} else {
			switch(field_ptr->type) {
				case FIELD_TYPE_VAR_STRING:
					printf("VARCHAR\n");
					break;
				case FIELD_TYPE_LONG:
					printf("LONG");
					break;
				default:
					printf("Type is %d, check in msyql_com.h\n", field_ptr->type);
			}	
		}
		printf("\t Max width %ld\n", field_ptr->length);
		if (field_ptr->flags & AUTO_INCREMENT_FLAG)
			printf("\t Auto increments\n");
		printf("\n");
	}
}

int main (int argc, char *argv[]) {

	connection("localhost", "root", "shuang", "shuangde");
	int res = mysql_query(&conn, "SELECT * from student");
	if (res) {
		fprintf(stderr, "SELECT error: %s\n", mysql_error(&conn));
	} else {
		res_ptr = mysql_use_result(&conn);
		if (res_ptr) {
			int first = 1;
			while ((sqlrow = mysql_fetch_row(res_ptr))) {
				if (first) {
					display_header();
					first = 0;	
				}
				display_row();
			}
			if (mysql_errno(&conn)) {
				fprintf(stderr, "Retrive error: %s\n", mysql_error(&conn));
			}
			mysql_free_result(res_ptr);
		} 
	}
	mysql_close(&conn);
	exit(EXIT_SUCCESS);
}





作者:shuangde800 发表于2013-12-27 23:14:41 原文链接
阅读:91 评论:0 查看评论

相关 [linux 语言 mysql] 推荐:

Linux下C语言执行MySQL语句

- - CSDN博客数据库推荐文章
本文出自    http://blog.csdn.net/shuangde800. 执行SQL语句的增、删、改、查的主要API函数为:. 函数接收参数连接句柄和字符串形式的有效SQL语句(没有结束的分号,这与mysql工具不同). 如果包含二进制数据的查询,要使用mysql_real_query..

Linux Ksplice,MySQL and Oracle

- Syn - DBA Notes
Oracle 在 7 月份收购了 Ksplice. 使用了 Ksplice 的 Linux 系统,为 Kernel 打补丁无需重启动,做系统维护的朋友应该明白这是一个杀手级特性. 现在该产品已经合并到 Oracle Linux 中. 目前已经有超过 700 家客户,超过 10 万套系统使用了 Ksplice (不知道国内是否已经有用户了.

Linux 安装 MySQL / MySQL 主从备份

- - BlogJava-首页技术区
假定所有安装包均在 /share目录,安装目录为 /opt !!. ========================= 安装 MySQL =========================. $ vi /opt/mysql/my.cnf (参考下面配置). $ vi /etc/rc.d/init.d/mysql (参考下面配置).

linux 下mysql自启动

- - 数据库 - ITeye博客
如果你都是按照默认配置安装的那么只要按照如下步骤就可以了. 1、cp /usr/local/mysql/support-files/mysql.server /etc/init.d/mysql   将服务文件拷贝到init.d下,并重命名为mysql. 2、chmod +x /etc/init.d/mysql    赋予可执行权限.

Linux中对MySQL优化

- - 数据库 - ITeye博客
要求: MySQL数据库管理与维护. 1、熟悉Linux上安装、配置和优化MySQL数据库,. 2、熟悉 Mysql的AB复制以及读写分离的实现,能完成添加从库,从库变主库等操作;. 3、精通mysql数据库的查询、子查询、插入、更新等操作,以及建数据库、表和索引;. 4、掌握表的连接、视图,以为存储过程和函数的使用;.

linux 定期自动备份mysql的shell

- - OurMySQL
刚才有个玩家在站上玩游戏,提醒了我要及时备份数据啊,万一哪天服务器挂了把他们的数据丢了,我可就是罪人了. 一直打算放个自动备份的shell,都没有放. 安全起见,直接用Root执行的:. 以下是自动自动备份shell,只保留最新5天. AutoMySQLBackup — 轻量级MySQL备份方案. LINUX/win2003下mysql怎么定期自动备份数据库.

Linux安装mysql——源码安装

- - Linux - 操作系统 - ITeye博客
1.假设已经有mysql-5.5.10.tar.gz以及cmake-2.8.4.tar.gz两个源文件. (1)先安装cmake(mysql5.5以后是通过cmake来编译的). (2)创建mysql的安装目录及数据库存放目录. //安装mysql [[email protected] rhel5~]#mkdir -p /usr/local/mysql/data.

Linux上MySQL 优化三板斧

- - 乐无限-微信公众号内容聚合站
Linux上MySQL 优化三板斧. Linux上MySQL 优化三板斧. 现在MySQL运行的大部分环境都是在Linux上的,如何在Linux操作系统上根据MySQL进行优化,我们这里给出一些通用简单的策略. 这些方法都有助于改进MySQL的性能. 你仔细检查的话,有些服务器上会有的一个有趣的现象:你cat /proc/cpuinfo时,会发现CPU的频率竟然跟它标称的频率不一样:.

Linux、mysql、tomcat大并发下的配置

- - Linux - 操作系统 - ITeye博客
    因为之前一直没太接触过项目实现部署的问题,所以中间出现了N多问题,现在有时间了,做了一个整理,已备后用. 此处不包括上一层服务器的负载,如使用nginx/apache等. 配置项目中的连接池最大连接数 <= mysql的max_connections(如项目有集群,则乘N). 可解决出现:MySQL 提示 Too many connections ( 1040 ).

(转)针对MySQL的Linux性能调优技巧[翻译]

- - jackyrong
原文作者: Alexander Rubin,Percona 工程师. 原文连接:Linux performance tuning tips for MySQL. 为了方面阅读,我没依照原文按行逐句的进行翻译. 另外,我自己的扩充了一下基础知识点,很多知识点也是我第一次去学习,翻阅了一些资料. 原文中对Linux系统参数的优化主要分为文件系统、内存与swap、CPU三方面.