Chinaunix首页 | 论坛 | 博客

adustdu2015的ChinaUnix博客

首页　| 　博文目录　| 　关于我

adustdu2015

  • 博客访问： 275658
  • 博文数量： 113
  • 博客积分： 0
  • 博客等级： 民兵
  • 技术积分： 1044
  • 用 户 组： 普通用户
  • 注册时间： 2015-02-15 16:09
文章分类

全部博文（113）

文章存档

2016年（5）

2015年（108）

我的朋友
最近访客
推荐博文
相关博文
mysql C LINUX

分类： C/C++

2015-08-29 17:23:48

在安装xampp的情况下，只需要
sudo apt-get install mysql-client-core-5.5
mysql -u root -p 即可登录。

/*注意：mysql_query在执行成功时返回0，否则返回1*/
Linux下C语言执行MySQL语句
执行SQL语句的增、删、改、查的主要API函数为：

点击(此处)折叠或打开

  1. int mysql_query(MYSQL *connection, const char *query)
函数接收参数连接句柄和字符串形式的有效SQL语句（没有结束的分号，这与mysql工具不同）。如果成功，它返回0。
如果包含二进制数据的查询，要使用mysql_real_query.

检查受查询影响的行数:

点击(此处)折叠或打开

  1. my_ulonglong mysql_affected_rows(MYSQL *connection)
my_ulonglong是无符号长整形，为%lu格式
这个函数返回受之前执行update,insert或delete查询影响的行数。
例子
数据库中有一个student表

点击(此处)折叠或打开

  1. CREATE TABLE student (
  2.         student_no varchar(12) NOT NULL PRIMARY KEY,
  3.         student_name varchar(12) NOT NULL
  4.         );

增、删、改代码：

点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include
  5. #include
  6. #include

  8. /*创建MYSQL变量*/
  9. MYSQL conn;

  11. void connection(const char* host, const char* user, const char* password, const char* database) {
  12.     /*初始化MYSQL变量*/  
  13.  mysql_init(&conn); // 注意取地址符&
  14.         /*调用mysql_real_connect函数连接Mysql数据库*/
  15.     if (mysql_real_connect(&conn, host, user, password, database, 0, NULL, 0)) {
  16.         printf("Connection success!\n");
  17.     } else {
  18.         fprintf(stderr, "Connection failed!\n");
  19.         if (mysql_errno(&conn)) {
  20.             fprintf(stderr, "Connection error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
  21.         }
  22.         exit(EXIT_FAILURE);
  23.     }
  24. }

  26. void insert() {
  27.     /*调用mysql_query函数进行数据库查询*/
  28.     int res = mysql_query(&conn, "INSERT INTO student(student_no,student_name) VALUES('123465', 'Ann')");
  29.     if (!res) {
  30.     /**/
  31.         printf("Inserted %lu rows\n", (unsigned long)mysql_affected_rows(&conn));
  32.     } else {
  33.         fprintf(stderr, "Insert error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
  34.     }
  35. }

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

  46. void delete() {
  47.     int res = mysql_query(&conn, "DELETE from student WHERE student_no='123465'");
  48.     if (!res) {
  49.     /*查询影响的行数*/
  50.         printf("Delete %lu rows\n", (unsigned long)mysql_affected_rows(&conn));
  51.     } else {
  52.         fprintf(stderr, "Delete error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
  53.     }
  54. }


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

  59.     connection("localhost", "root", "shuang", "shuangde");
  60.     delete();
  61.     mysql_close(&conn);
  62.     exit(EXIT_SUCCESS);
  63. }
编译gcc -o bin_name hello.c -I /usr/include/mysql -L /usr/lib/mysql -lmysqlclient -lz -lm

返回数据的语句：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


点击(此处)折叠或打开

  1. // 相关函数：

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

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


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


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


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


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


  27. // 完成所有对数据的操作后，必须总是调用这个来善后处理
  28. void mysql_free_result(MYSQL_RES *result)
示例代码：

点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include
  5. #include
  6. #include


  9. MYSQL conn;
  10. MYSQL_RES *res_ptr;
  11. MYSQL_ROW sqlrow;

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

  16.     if (mysql_real_connect(&conn, host, user, password, database, 0, NULL, 0)) {
  17.         printf("Connection success!\n");
  18.     } else {
  19.         fprintf(stderr, "Connection failed!\n");
  20.         if (mysql_errno(&conn)) {
  21.             fprintf(stderr, "Connection error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
  22.         }
  23.         exit(EXIT_FAILURE);
  24.     }
  25. }

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

  29.     connection("localhost", "root", "123", "TEST");
  30.     int res = mysql_query(&conn, "SELECT * from student");
  31.     if (res) {
  32.         fprintf(stderr, "SELECT error: %s\n", mysql_error(&conn));
  33.     } else {
  34.         /*通过调用mysql_store_result或mysql_use_result函数返回的MYSQL_RES变量获取查询结果数据*/
  35.         res_ptr = mysql_store_result(&conn);
  36.         if (res_ptr) {
  37.             printf("Retrieved %lu rows\n", (unsigned long)mysql_num_rows(res_ptr));   
  38.                 /*调用mysql_fetch_row函数读取结果集数据*/
  39.             while ((sqlrow = mysql_fetch_row(res_ptr))) {
  40.         // 重复读取行，并输出第一个字段的值，直到row为NULL
  41.                 printf("Fetched data...\n");
  42.                 /*

    // 存储结果集

    res = mysql_store_result（&mysql）;

    if （NULL == res）

    {

    cout << “mysql_store_result failure！” << endl;

    return 0;

    }

    // 重复读取行，并输出第一个字段的值，直到row为NULL

    while （row = mysql_fetch_row（res））

    {

    cout << row［0］ << endl;

    }

    */
  43.             }
  44.             if (mysql_errno(&conn)) {
  45.                 fprintf(stderr, "Retrive error: %s\n", mysql_error(&conn));
  46.             }
  47.         /*结果集用完后，调用mysql_free_result函数释放结果集，以防内存泄露*/
  48.             mysql_free_result(res_ptr);
  49.         }
  50.     }
  51.     /*不再查询Mysql数据库时，调用mysql_close函数关闭数据库连接*/
  52.     mysql_close(&conn);
  53.     exit(EXIT_SUCCESS);
  54. }
gcc -o bin_name hello.c -I /usr/include/mysql -L /usr/lib/mysql -lmysqlclient -lz -lm

一次提取一行数据：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更好。

处理返回的数据


点击(此处)折叠或打开

  1. // 相关函数和定义：


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

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

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


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


  30. // 列类型相当广泛，完整的列表见头文件mysql_com.h,常见的有：
  31. //    FIELD_TYPE_DECIMAL
  32. //    FIELD_TYPE_LONG
  33. //    FIELD_TYPE_STRING
  34. //    FIELD_TYPE_VAR_STRING

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

代码示例：


点击(此处)折叠或打开

  1. #include <stdio.h>
  2. #include <stdlib.h>
  3. #include <string.h>
  4. #include
  5. #include
  6. #include


  9. MYSQL conn;
  10. MYSQL_RES *res_ptr;
  11. MYSQL_ROW sqlrow;

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

  16.     if (mysql_real_connect(&conn, host, user, password, database, 0, NULL, 0)) {
  17.         printf("Connection success!\n");
  18.     } else {
  19.         fprintf(stderr, "Connection failed!\n");
  20.         if (mysql_errno(&conn)) {
  21.             fprintf(stderr, "Connection error %d: %s\n", mysql_errno(&conn), mysql_error(&conn));
  22.         }
  23.         exit(EXIT_FAILURE);
  24.     }
  25. }
  26. /*display_row */
  27. void display_row() {
  28.     unsigned int field_count = mysql_field_count(&conn);
  29.     int i = 0;
  30. /*打印这组数据的全部数据，这里i表示不同的列*/
  31.     while (i < field_count) {
  32.         if (sqlrow[i]) printf("%s ", sqlrow[i]);
  33.         else printf("NULL");
  34.         i++;
  35.     }
  36.     printf("\n");
  37. }
  38. /*display _header*/
  39. void display_header() {
  40.     MYSQL_FIELD *field_ptr;
  41.     printf("Column details:\n");
  42.     while ((field_ptr = mysql_fetch_field(res_ptr)) != NULL) {
  43.         printf("\t Name: %s\n", field_ptr->name);    
  44.         printf("\t Table: %s\n", field_ptr->table);    
  45.         printf("\t Type: ");
  46.         if (IS_NUM(field_ptr->type)) {
  47.             printf("Numeric field\n");    
  48.         } else {
  49.             switch(field_ptr->type) {
  50.                 case FIELD_TYPE_VAR_STRING:
  51.                     printf("VARCHAR\n");
  52.                     break;
  53.                 case FIELD_TYPE_LONG:
  54.                     printf("LONG");
  55.                     break;
  56.                 default:
  57.                     printf("Type is %d, check in msyql_com.h\n", field_ptr->type);
  58.             }    
  59.         }
  60.         printf("\t Max width %ld\n", field_ptr->length);
  61.         if (field_ptr->flags & AUTO_INCREMENT_FLAG)
  62.             printf("\t Auto increments\n");
  63.         printf("\n");
  64.     }
  65. }

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

  69.     connection("localhost", "root", "shuang", "shuangde");
  70.     /*选择名字不是Anna的一组数据 */
  71.     int res = mysql_query(&conn, "SELECT * from student WHERE student_name!='Anna'");
  72.     if (res) {
  73.         fprintf(stderr, "SELECT error: %s\n", mysql_error(&conn));
  74.     } else {
  75.         res_ptr = mysql_use_result(&conn);
  76.         if (res_ptr) {
  77.             int first = 1;
  78.             while ((sqlrow = mysql_fetch_row(res_ptr))) {
  79.                 if (first) {
  80.             /*display_header*/
  81.                     display_header();
  82.                     first = 0;    
  83.                 }/*display_row*/
  84.                 display_row();
  85.             }
  86.             if (mysql_errno(&conn)) {
  87.                 fprintf(stderr, "Retrive error: %s\n", mysql_error(&conn));
  88.             }
  89.             mysql_free_result(res_ptr);
  90.         }
  91.     }
  92.     mysql_close(&conn);
  93.     exit(EXIT_SUCCESS);
  94. }
gcc -o bin_name hello.c -I /usr/include/mysql -L /usr/lib/mysql -lmysqlclient -lz -lm




阅读(1572) | 评论(0) | 转发(0) |
0

上一篇：C linux 多线程的实现机制

下一篇：mysql linux C test.c

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6