MYSQL C CONNECT 预处理方式数据库访问

废话不多说, 直接上代码,我也是根据refman 文档编写的，在网上找了一圈，没找到相应的访问代码。

第一步： 首先要安装MYSQL相关开发包，主要安装如下两个包就能访问MySQL库了，linux下安装比较简单，直接执行如下命令即可：

rpm  -ivh  mysql-libs-5.1.61-4.el6.x86_64
rpm  -ivh  mysql-devel-5.1.61-4.el6.x86_64

第二步：编写访问mysql的C代码， 假设要访问 192.169.33.145 机器上的test 数据库的ttt表， 用户名 ， scott, tiger ， C代码文件名称为 mqtst.c

1. #include<stdio.h>
   
2. #include<mysql/mysql.h>
   
3. #include<string.h>
   
4. #define LEN_NAME 30
   
5. int main(int argc ,char** argv)
   
6. {
   
7.     MYSQL* mysql ;
   
8.     MYSQL_STMT* stmt;
   
9.     MYSQL_BIND bind[2];
   
10.     int i = 0 ;
    
11.     char sname[3][LEN_NAME+1]={"zhangsan","lisi","wangwu"};
    
12.     int tid[3] = {0,1,2} ;
    
13.     unsigned long ulname ;
    
14.     char rstmt[] = "insert into ttt(c0,c1)values(?,?)";
    
15. 
    
16.     mysql = mysql_init(NULL);
    
17.     if(mysql == NULL)
    
18.     {
    
19.         return -1 ;
    
20.     }
    
21.     if(! mysql_real_connect(mysql,"192.169.33.145","scott","tiger","test",0,0,0))
    
22.     {
    
23.         printf("connect database error [%d,%s]\n",mysql_errno(mysql),mysql_error(mysql));
    
24.         mysql_close(mysql);
    
25.         return -1;
    
26.     }
    
27.     //
    
28.     stmt = mysql_stmt_init(mysql);
    
29.     if(!stmt)
    
30.     {
    
31.         printf("init stmt error %s\n",mysql_error(mysql));
    
32.         mysql_close(mysql);
    
33.         return -1 ;
    
34.     }
    
35.     if( mysql_stmt_prepare(stmt,rstmt,strlen(rstmt)))
    
36.     {
    
37.         printf("mysql stmt prepare error (%d,%s)\n",mysql_errno(mysql),mysql_error(mysql));
    
38.         mysql_stmt_close(stmt);
    
39.         mysql_close(mysql);
    
40.         return -1 ;
    
41.     }
    
42.     memset(bind,0,sizeof(bind));
    
43.     for(i = 0 ; i < 3; ++i)
    
44.     {
    
45.         bind[0].buffer_type = MYSQL_TYPE_LONG ;
    
46.         bind[0].buffer = (char*)& tid[i];
    
47.         bind[0].is_null = 0 ;            
    
48.         
    
49.         bind[1].buffer_type = MYSQL_TYPE_STRING ;
    
50.         bind[1].buffer = (char*)sname[i];
    
51.         bind[1].buffer_length = LEN_NAME ;
    
52.         bind[1].length = &ulname;
    
53.         bind[1].is_null = 0 ;
    
54.         ulname = strlen(sname[i]);
    
55. 
    
56.         if(mysql_stmt_bind_param(stmt,bind))    
    
57.         {
    
58.             printf("mysql_stmt_bind_param error (%d,%s)\n",mysql_stmt_errno(stmt),mysql_stmt_error(stmt));
    
59.             mysql_stmt_close(stmt);
    
60.             mysql_close(mysql);
    
61.             return -1 ;
    
62.         }
    
63.         if(mysql_stmt_execute(stmt))
    
64.         {
    
65.             printf("mysql_stmt_execute error: %s\n",mysql_stmt_error(stmt));
    
66.             mysql_stmt_close(stmt);
    
67.             mysql_close(mysql);
    
68.             return -1 ;
    
69.         }
    
70.         printf("affect rows = %ld \n",mysql_affected_rows(mysql));
    
71.     }
    
72.     mysql_stmt_close(stmt);
    
73.     mysql_close(mysql);
    
74.     return 0 ;
    
75. }

第三步，编译代码，前提机器一定要安装编译器cc ，执行如下命令
-bash-4.1$ cc -o mqtst mqtst.c  -lmysqlclient 
-bash-4.1$ 

第四步，执行./mqtst 

第五步，检查是否已经插入数据

mysql> select * from ttt ;
+----+----------+
| c0 | c1       |
+----+----------+
|  0 | zhangsan |
|  1 | lisi     |
|  2 | wangwu   |
+----+----------+
3 rows in set


mysql>