C代码  

1. #include <stdlib.h>  
2. #include <stdio.h>  
3. #include <mysql.h>  
4. int main() {  
5.     MYSQL *conn_ptr;  
6.   
7.     conn_ptr = mysql_init(NULL);  
8.     if (!conn_ptr) {  
9.         printf("mysql_init failed\n");  
10.         return EXIT_FAILURE;  
11.     }  
12.     conn_ptr = mysql_real_connect(conn_ptr, "localhost", "root", "123456", "test", 0, NULL, 0);  
13.     //root 为用户名 123456为密码 test为要连接的database  
14.   
15.     if (conn_ptr) {  
16.         printf("Connection success\n");  
17.     } else {  
18.         printf("Connection failed\n");  
19.     }  
20.     mysql_close(conn_ptr);  
21.     return EXIT_SUCCESS;  
22. }  

C代码  

1. #include <stdio.h>  
2. #include <stdlib.h>  
3. #include <mysql.h>  
4. int main() {  
5.     MYSQL *conn_ptr;  
6.     MYSQL_RES *res_ptr;  
7.     MYSQL_ROW sqlrow;  
8.     MYSQL_FIELD *fd;  
9.     int res, i, j;  
10.   
11.     conn_ptr = mysql_init(NULL);  
12.     if (!conn_ptr) {  
13.         return EXIT_FAILURE;  
14.     }  
15.     conn_ptr = mysql_real_connect(conn_ptr, "localhost", "root", "123456", "test", 0, NULL, 0);  
16.     if (conn_ptr) {  
17.         res = mysql_query(conn_ptr, "select name,age from user"); //查询语句  
18.         if (res) {         
19.             printf("SELECT error:%s\n",mysql_error(conn_ptr));     
20.         } else {        
21.             res_ptr = mysql_store_result(conn_ptr);             //取出结果集  
22.             if(res_ptr) {               
23.                 printf("%lu Rows\n",(unsigned long)mysql_num_rows(res_ptr));   
24.                 j = mysql_num_fields(res_ptr);          
25.                 while((sqlrow = mysql_fetch_row(res_ptr)))  {   //依次取出记录  
26.                     for(i = 0; i < j; i++)         
27.                         printf("%s\t", sqlrow[i]);              //输出  
28.                     printf("\n");          
29.                 }              
30.                 if (mysql_errno(conn_ptr)) {                      
31.                     fprintf(stderr,"Retrive error:s\n",mysql_error(conn_ptr));               
32.                 }        
33.             }        
34.             mysql_free_result(res_ptr);        
35.         }  
36.     } else {  
37.         printf("Connection failed\n");  
38.     }  
39.     mysql_close(conn_ptr);  
40.     return EXIT_SUCCESS;  
41. }  

C代码  

1. #include <stdlib.h>  
2. #include <stdio.h>  
3. #include <mysql.h>  
4. int main() {  
5.     MYSQL *conn_ptr;  
6.     int res;  
7.   
8.     conn_ptr = mysql_init(NULL);  
9.     if (!conn_ptr) {  
10.         printf("mysql_init failed\n");  
11.         return EXIT_FAILURE;  
12.     }  
13.     conn_ptr = mysql_real_connect(conn_ptr, "localhost", "root", "123456", "test", 0, NULL, 0);  
14.     if (conn_ptr) {  
15.         res = mysql_query(conn_ptr, "insert into user values(null,‘Ann‘,5)");   //可以把insert语句替换成delete或者update语句，都一样的  
16. //      res = mysql_query(conn_ptr, "delete from user where name = ‘Ann‘ and age < 10");  
17.         if (!res) {     //输出受影响的行数  
18.             printf("Inserted %lu rows\n",(unsigned long)mysql_affected_rows(conn_ptr));   
19.         }  else {       //打印出错误代码及详细信息  
20.             fprintf(stderr, "Insert error %d: %sn",mysql_errno(conn_ptr),mysql_error(conn_ptr));  
21.         }  
22.     } else {  
23.         printf("Connection failed\n");  
24.     }  
25.     mysql_close(conn_ptr);  
26.     return EXIT_SUCCESS;  
27. }  

用C语言操作MySQL数据库 

参考MYSQL的帮助文档整理

这里归纳了C API可使用的函数，并在下一节详细介绍了它们。请参见25.2.3节，“C API函数描述”。

与MySQL交互时，应用程序应使用该一般性原则：

1.    通过调用mysql_library_init()，初始化MySQL库。库可以是mysqlclient C客户端库，或mysqld嵌入式服务器库，具体情况取决于应用程序是否与“-libmysqlclient”或“-libmysqld”标志链接。

2.    通过调用mysql_init()初始化连接处理程序，并通过调用mysql_real_connect()连接到服务器。

3.    发出SQL语句并处理其结果。（在下面的讨论中，详细介绍了使用它的方法）。

4.    通过调用mysql_close()，关闭与MySQL服务器的连接。

5.    通过调用mysql_library_end()，结束MySQL库的使用。

介绍常用到的MYSQL相关的C变量类型。这些类型在我们后面定义变量的时候会用到

1、MYSQL

       要连接MYSQL，必须建立MYSQL实例，通过mysql_init初始化方能开始进行连接

示例：

MYSQL mysql;                    #创建MYSQL实例

mysql_init(&mysql);             #初始化开始进行连接

2、MYSQL_RES

这个结构代表返回行的一个查询的(SELECT, SHOW, DESCRIBE, EXPLAIN)的结果。返回的数据称为“数据集”。 从数据库读取数据，最后就是从MYSQL_RES中读取数据。

PS：类似于JAVA里面的ResultSet变量一样，将结果集存入到此变量中再从它里面去读数据。

3、MYSQL_ROW

这是一个行数据的类型安全(type-safe)的表示。当前它实现为一个计数字节的字符串数组。行通过调用mysql_fetch_row()获得

4、MYSQL_FIELD

你可以通过重复调用mysql_fetch_field()对每一列获得MYSQL_FIELD结构。这个结构包含字段信息，例如字段名、类型和大小。

PS：此变量定义的是列的相关属性问题！

示例一：实现遍历查询select * from table-name 操作

#include "windows.h"

#include "mysql.h"

#pragma comment(lib,"libmySQL.lib")

int main()

{

      MYSQL mysql;     //mysql连接

      MYSQL_RES *res; //这个结构代表返回行的一个查询结果集

      MYSQL_ROW row; //一个行数据的类型安全(type-safe)的表示

      char *query;   //查询语句     

      int t,r;

      mysql_init(&mysql);

         if (!mysql_real_connect(&mysql,"localhost", "root", "123", "test",3306,NULL,0))

      {

         printf( "Error connecting to database: %s",mysql_error(&mysql));

      } else

         printf("Connected...");

         query="SET CHARACTER SET utf8"; //设置编码

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

      if(t)

      {

           printf("编码设置失败");

      }

         query=" select * from a ";

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

      if(t)

      {

          printf("执行查询时出现异常: %s",mysql_error(&mysql));

      }else

          printf("[%s] 构建成功",query);

      res=mysql_store_result(&mysql);

      while(row=mysql_fetch_row(res))

      {                             

          /*

                for(t=0;t<mysql_num_fields(res);t++)

           {

               printf("%s" " ",row[t]);

           }

                 */

                printf("%s",row[1]);         表示查询的第几个字段的！也还可以遍历全部字段信息

          printf("\n");

      }

      mysql_free_result(res);

mysql_close(&mysql);

         return 0;

}

示例二：执行插入、更新、删除操作

#include "windows.h"

#include "mysql.h"

#pragma comment(lib,"libmySQL.lib")

int main()

{

      MYSQL mysql;     //mysql连接

      MYSQL_RES *res; //这个结构代表返回行的一个查询结果集

      MYSQL_ROW row; //一个行数据的类型安全(type-safe)的表示

      char *query;   //查询语句     

      int t,r;

      mysql_init(&mysql);

         if (!mysql_real_connect(&mysql,"localhost", "root", "123", "test",3306,NULL,0))

      {

         printf( "Error connecting to database: %s",mysql_error(&mysql));

      } else

         printf("Connected...");

         query="SET CHARACTER SET utf8"; //设置编码

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

      if(t)

      {

           printf("编码设置失败");

      }

         query="insert into a(name,age) values(‘w‘,9)";

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

      if(t)

      {

          printf("执行查询时出现异常: %s",mysql_error(&mysql));

      }else

          printf("[%s] 构建成功",query);

      mysql_close(&mysql);

      return 0;

}