C语言操作MYSQL小例子

http://blog.csdn.net/small_qch/article/details/8180678

初学使用用C语言操作MYSQL，写了个小例子，帖上来献丢人一下，呵呵。

程序很简单，先连接数据库，然后向class1表中插入一条数据，最后获取并输出整个class1表的内容。

上代码：

[cpp] view plain copy 
 //test.c  
 //gcc test.c -o test -lmysqlclient  
 #include <stdio.h>  
 #include <stdlib.h>  
 #include <mysql/mysql.h>  
   
 //发生错误时，输出错误信息，关闭连接，退出程序  
 void error_quit(const char *str, MYSQL *connection)  
 {  
     fprintf(stderr, "%s : %d: %s\n",  
         str, mysql_errno(connection),  
         mysql_error(connection));  
     if( connection != NULL )  
         mysql_close(connection);  
     exit(1);  
 }  
   
 int main(int argc, char *argv[])   
 {  
     MYSQL *my_con = malloc( sizeof(MYSQL) );  
     MYSQL_RES *my_res;  
     MYSQL_FIELD *my_field;  
     MYSQL_ROW my_row;  
     int rows, i;  
     int res;  
   
     //连接数据库  
     mysql_init(my_con);   
     my_con = mysql_real_connect(my_con, "localhost", "test", "aaaaaaa",  
         "test1", 0, NULL, CLIENT_FOUND_ROWS);  
     if( NULL == my_con )   
         error_quit("Connection fail", my_con);  
     printf("Connection success\n");  
   
     //向数据库中插入一条记录  
     res = mysql_query(my_con,   
         "insert into class1(name, age, birthday) value('abc', 52, NOW());");  
     if( res != 0 )   
         error_quit("Insert fail", my_con);  
     //返回的是表中被影响的行数  
     res = mysql_affected_rows(my_con);  
     printf("Inserted %d rows\n", res);  
   
     //获取整个表的内容  
     res = mysql_query(my_con, "select * from class1;");  
     if( res != 0 )  
         error_quit("Select fail", my_con);  
     my_res = mysql_store_result(my_con);  
     if( NULL == my_res )  
         error_quit("Get result fail", my_con);  
   
     //获取表的列数  
     rows = mysql_num_fields(my_res);  
     //获取并输出表头  
     my_field = mysql_fetch_fields(my_res);  
     for(i=0; i<rows; i++)  
         printf("%s\t", my_field[i].name);  
     printf("\n-------------------------------------\n");  
   
     //输出整个表的内容  
     while( 1 )  
     {  
         my_row = mysql_fetch_row(my_res);  
         if( NULL == my_row )  
             break;  
         for(i=0; i<rows; i++)  
         {  
             if( my_row[i] == NULL )  
                 printf("NULL\t");  
             else  
                 printf("%s\t", (char*)my_row[i]);  
         }  
         printf("\n");  
     }  
   
     //释放空间，关闭连接  
     mysql_free_result(my_res);  
     mysql_close(my_con);  
     free(my_con);  
   
     return 0;  
 }  

运行结果：

[plain] view plain copy 
 Connection success  
 Inserted 1 rows  
 id  name    age birthday  
 -------------------------------------  
 49  ddd 43  2012-11-09 09:49:41  
 50  fff 31  0000-00-00 00:00:00  
 58  eee 32  NULL  
 59  qqq 43  NULL  
 78  abc 52  2012-11-13 14:47:55  