bitscn.com
执行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 #include #include #include mysql.h#include errmsg.h#include mysqld_error.hmysql 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);}
返回数据的语句：selectsql最常见的用法是提取数据而不是插入或更新数据。数据是用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之后使用此函数，这个函数将立刻保存在客户端中返回的所有数据。它返回一个指向结果集结构的指针，如果失败返回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.hmysql 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 #include #include #include mysql.h#include errmsg.h#include mysqld_error.hmysql 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 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);}
bitscn.com