MysqlC API 简单查询

// 源程序， 查询建立在已有的数据库 mytestbases。并需要输入密码 1 #include <stdio.h> 2 #include <string.h> 3 #include <mysql/mysql.h> 4 7 #pragma comment(lib, "libmySQL.lib") 8 9 int main() 10 { 11 MYSQL mysql; 12 MYSQL_RES *res; 13 MYSQL_ROW row; 14 MYSQL_FIELD *field; 15 const char *query; 16 int t; 17 mysql_init(&mysql); 18 19 if (!mysql_real_connect(&mysql, "localhost", 20 "root", "数据库密码", "mytestbases", 3306, NULL, 0 )) { 21 printf("connect error\n"); 22 return 0; 23 } else { 24 printf(" connect\n"); 25 } 26 27 query = "SET CHARACTER SET utf8"; 28 t = mysql_real_query(&mysql, query, (unsigned int)strlen(query)); 29 30 if (t) { 31 printf("utf8 set fail\n"); 32 } 33 34 query = "select * from information"; 35 36 t = mysql_real_query(&mysql, query, (unsigned int)strlen(query)); 37 if (t) { 38 printf("excute err %s", mysql_error(&mysql)); 39 } else { 40 printf("[%s] build success\n", query); 41 } 42 res = mysql_store_result(&mysql); 43 unsigned long num_fields; 44 num_fields = mysql_num_fields(res); 45 field = mysql_fetch_field(res); 46 for (int i = 0; i < num_fields; i++) { 47 printf("Field %u is %s\n", i, field[i].name); 48 } 51 printf("\n"); 52 while((row = mysql_fetch_row(res))) { 53 54 for (t = 0; t < mysql_num_fields(res); t++) { 55 printf(" %s\t", row[t]); 56 } 57 printf("\n"); 58 } 59 60 mysql_free_result(res); 61 62 printf("close connect\n"); 63 mysql_close(&mysql); 64 return 0; 65 }

此程序操作数据库中的数据是建立在已经创建了数据库mytestbase 的前提之下。

以下为基本步骤 1、建立数据库实例。 像基本数据类型一样使用MYSQL类型 MYSQL mysql ； 2、对实例进行初始化 ， 使用mysql_init(&mysql); 在完成使用后，需要使用mysql_close(&mysql) 来释放实例。 3、在初始化之后， 使用函数mysql_real_connect 连接数据库。

mysql_real_connect(&mysql, "localhost", "root", "数据库密码", "mytestbases", 3306, NULL, 0 )

需要在函数的参数中写上 mysql 实例的地址， 连接的主机， 用户 ，用户密码， 需要连接的数据库， 端口号 ， 套接字 和 客户端标志（通常为0） 详细信息可以进入以下地址探寻。 https://dev.mysql.com/doc/c-api/5.6/en/mysql-real-connect.html 4、连接到服务器上的数据库之后， 使用函数mysql_real_query将语句传送到数据库中执行。 语句是以字符串的形式传送的 const char * = " “SET CHARACTER SET utf8”;

t = mysql_real_query(&mysql, query, (unsigned int)strlen(query));

关于mysql_real_query的详细信息到mysql 官网查询。 https://dev.mysql.com/doc/c-api/5.6/en/mysql-real-query.html

在MySQL 数据库中查询时，需要自语句末尾添加分号或者 \g但是根据官网解释，在通过此函数访问时，不需要添加。 Normally, the string must consist of a single SQL statement without a terminating semicolon (😉 or \g.

查询成功则返回0； 非0 则出错。

5、在查询之后，通过数据库实例mysql 和 数据类型MYSQL_RES *res 指向查询后的结果地址。 res = mysql_store_result(&mysql);

至此获取到了查询的数据。可以通过各种函数将获取到的结果输出。

6、 num_fields = mysql_num_fields(res); 获取返回数据的列数。 row = mysql_fetch_row(res) 获取返回数据的行数据，重复调用，依次指向每一行数据的起始地址。 配合之前获取的列数， 可以将每一行数按照自己要求输出。 field = mysql_fetch_field(res); 获取每一列的信息。MYSQL_FIELD *field 有字段名，类型，大小等。 该函数返回的是一个指针，指向所有列的MYSQL_FIELD 的结构。 可以通过指针访问 ，也可以通过重复调用获取下一个来使用。

//重复调用函数，获取每一条数据 unsigned long num_fields; num_fields = mysql_num_fields(res); for (int i = 0; i < num_fields; i++) { field = mysql_fetch_field(res); printf("Field %u is %s\n", i, field.name); } // 通过指针调用 res = mysql_store_result(&mysql); unsigned long num_fields; num_fields = mysql_num_fields(res); field = mysql_fetch_field(res); for (int i = 0; i < num_fields; i++) { printf("Field %u is %s\n", i, field[i].name); }

函数的定义及返回值

MYSQL *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 client_flag)

int mysql_real_query (MYSQL *mysql, const char *stmt_str, unsigned long length) 执行成功返回0， 不然返回非0. 错误及原因 CR_COMMANDS_OUT_OF_SYNC 命令错误

CR_SERVER_GONE_ERROR 丢失服务器

CR_SERVER_LOST 在查询期间与数据库失去连接

CR_UNKNOWN_ERROR 一个未知错误 通过对返回的整型数据进行判断即可知道错误原因。

unsigned int mysql_num_fields(MYSQL_RES *result) （ int mysql_field_count(MYSQL *mysql) 可以代替使用， 参数不同，但是返回结果一致。） 在 mysql_store_result(&mysql) 使用之后，可以同过此函数获取返回集合的列数。

MYSQL_RES *mysql_store_result(MYSQL *mysql) 必须在mysql_real_query 使用之后，用来获取返回的结果。而且在返回的结果使用完成后，必须使用mysql_free_result() 来释放返回结果的内存。 详细信息参见mysql 文档。可以很快捷的查看相关实现接口及其要求。 在使用这些mysql 接口之前需要先下载MySQL 相关头文件和库。网上很容易查到。 且在编译时，需要添加 -lmysqlclient 。 如果有出错地方欢迎指正。