mysql C LINUX

在安装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
   
7. 
   
8. /*创建MYSQL变量*/
   
9. MYSQL conn;
   
10. 
    
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. }
    
25. 
    
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. }
    
36. 
    
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. }
    
45. 
    
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. }
    
55. 
    
56. 
    
57. int main (int argc, char *argv[]) {
    
58. 
    
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. // 相关函数：
   
2. 
   
3. // 这是在成功调用mysql_query之后使用此函数，这个函数将立刻保存在客户端中返回的所有数据。它返回一个指向结果集结构的指针，如果失败返回NULL
   
4. MYSQL_RES *mysql_store_result(MYSQL *connection);
   
5. 
   
6. // 这个函数接受由mysql_store_result返回的结果结构集，并返回结构集中的行数
   
7. my_ulonglong mysql_num_rows(MYSQL_RES *result);
   
8. 
   
9. 
   
10. // 这个函数从使用mysql_store_result得到的结果结构中提取一行，并把它放到一个行结构中。当数据用完或发生错误时返回NULL.
    
11. MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
    
12. 
    
13. 
    
14. // 这个函数用来在结果集中跳转，设置将会被下一个mysql_fetch_row操作返回的行。参数offset是一个行号，它必须是在0～结果总行数-1的范围内。传递
    
15. // 0将会导致下一个mysql_fetch_row调用返回结果集中的第一行。
    
16. void mysql_data_seek(MYSQL_RES *result, my_ulonglong offset);
    
17. 
    
18. 
    
19. // 返回一个偏移值，它用来表示结果集中的当前位置。它不是行号，不能把它用于mysql_data_seek
    
20. MYSQL_ROW_OFFSET mysql_row_tell(MYSQL_RES *result);
    
21. 
    
22. 
    
23. // 这将在结果集中移动当前的位置，并返回之前的位置
    
24. MYSQL_ROW_OFFSET mysql_row_seek(MYSQL_RES *result, MYSQL_ROW_OFFSET offset);
    
25. 
    
26. 
    
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
   
7. 
   
8. 
   
9. MYSQL conn;
   
10. MYSQL_RES *res_ptr;
    
11. MYSQL_ROW sqlrow;
    
12. 
    
13. void connection(const char* host, const char* user, const char* password, const char* database) {
    
14.     mysql_init(&conn); // 注意取地址符&
    
15. 
    
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. 
    
27. int main (int argc, char *argv[]) {
    
28. 
    
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. // 相关函数和定义：
   
2. 
   
3. 
   
4. // 返回结果集中的字段（列）数目
   
5. unsigned int mysql_field_count(MYSQL *connection);
   
6. 
   
7. // 将元数据和数据提取到一个新的结构中
   
8. MYSQL_FIELD *mysql_fetch_field(MYSQL *result);
   
9. 
   
10. // 这个函数用来覆盖当前的字段编号，该编号会随着每次mysql_fetch_field调用而自动增加。如果给offset传递0，那么将跳回第1列
    
11. MYSQL_FIELD_OFFSET mysql_field_seek(MYSQL *result, MYSQL_FIELD_OFFSET offset);
    
12. 
    
13. 
    
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;         // 小数点后的数字个数。
    
28. 
    
29. 
    
30. // 列类型相当广泛，完整的列表见头文件mysql_com.h,常见的有：
    
31. //    FIELD_TYPE_DECIMAL
    
32. //    FIELD_TYPE_LONG
    
33. //    FIELD_TYPE_STRING
    
34. //    FIELD_TYPE_VAR_STRING
    
35. 
    
36. //一个特别有用的预定义宏： IS_NUM,当字段类型为数字时，返回true

代码示例：

点击(此处)折叠或打开

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <string.h>
   
4. #include
   
5. #include
   
6. #include
   
7. 
   
8. 
   
9. MYSQL conn;
   
10. MYSQL_RES *res_ptr;
    
11. MYSQL_ROW sqlrow;
    
12. 
    
13. void connection(const char* host, const char* user, const char* password, const char* database) {
    
14.     mysql_init(&conn); // 注意取地址符&
    
15. 
    
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. }
    
66. 
    
67. int main (int argc, char *argv[]) {
    
68. 
    
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