Linux下C语言执行MySQL语句_MySQL

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

my_ulonglong mysql_affected_rows(MYSQL *connection);

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

#include #include #include #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);}

// 相关函数：// 这是在成功调用mysql_query之后使用此函数，这个函数将立刻保存在客户端中返回的所有数据。它返回一个指向结果集结构的指针，如果失败返回NULLMYSQL_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_seekMYSQL_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 #include #include #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);}

// 相关函数和定义：// 返回结果集中的字段（列）数目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 #include #include #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);}