mysql linux C test.c

点击(此处)折叠或打开

1. #include <stdio.h>
   
2. #include <string.h>
   
3. #include <stdlib.h>
   
4. #include <mysql.h>
   
5. /* int main(int argc, char* argv[]) {
   
6.     MYSQL mysql;
   
7.     MYSQL_RES *rs=NULL;
   
8.     MYSQL_ROW row;
   
9. 
   
10.     if (connect_mysql(&mysql)) {
    
11.         return 1;
    
12.     }
    
13. 
    
14.     if (getSection(&mysql)) {
    
15.         mysql_close(&mysql);
    
16.         return 1;
    
17.     }
    
18. 
    
19.     getChannelList(&mysql,&rs,1);
    
20.     
    
21.     while(row=mysql_fetch_row(rs))
    
22.     {
    
23.         printf("%d %d %d\n", atoi(row[0]),atoi(row[1]),atoi(row[2]));
    
24.     }
    
25.     
    
26.      mysql_free_result(rs);    
    
27. 
    
28.     mysql_close(&mysql);
    
29.     return 0;
    
30. }
    
31.  */
    
32.  /*connect    mysql*/
    
33. int connect_mysql(MYSQL* mysql) {
    
34.     printf("Initializing mysql.................");
    
35.     if (!mysql_init(mysql)) {
    
36.         return 1;
    
37.     }
    
38.     printf("Connectiong to mysql...............");
    
39.     if (!mysql_real_connect(mysql, "localhost", "root", "1qazXSW2", "temperature4001", 0, NULL,0)) {
    
40.         fprintf(stderr, "Error: %s\r\n", mysql_error(mysql));
    
41.         return 1;
    
42.     }
    
43.     //设置mysql连接的字符集
    
44.     mysql_query(mysql, "SET NAMES 'utf8'");    
    
45.     return 0;
    
46. }
    
47. /*accept  DISTINCT  sectionID*/
48. int getSection(MYSQL *mysql) {
    
49.     int ret, field_count, row_count, i;
    
50.     int *lengths;
    
51.     char *query = "select DISTINCT sectionID from baseinfo";
    
52.     MYSQL_RES *result;
    
53.     MYSQL_ROW row;
    
54.     ret = mysql_real_query(mysql, query, strlen(query));
    
55.     if (ret != 0) {
    
56.         printf("加载不了users的数据。\n");
    
57.         return 1;
    
58.     }
    
59.     result = mysql_store_result(mysql);
    
60.     row_count = (int) mysql_num_rows(result);
    
61.     field_count = (int) mysql_num_fields(result);
    
62. //    printf("the count is %d ,the field count %d\n",row_count,field_count);
    
63.     if (result == NULL && field_count == 0) {
    
64.         printf("无数据");
    
65.         return 1;
    
66.     }
    
67. 
    
68.     while(row = mysql_fetch_row(result))
    
69.     {
    
70.          printf("%d \n", atoi(row[0]));
    
71.     }
    
72. 
    
73. //    for (i = 0; i < row_count; i++) {
    
74. //        row = mysql_fetch_row(result);
    
75. //        printf("%d \n", atoi(row[0]));
    
76. //    }
    
77.     mysql_free_result(result);
    
78.     return 0;
    
79. }
    
80. /*获取函数*/
81. int getChannelList(MYSQL *mysql,MYSQL_RES **result,int sectionID)
    
82. {
    
83.     char sql[500];
    
84. 
    
85.     int ret;
    
86.     
    
87.         memset(sql,0x00,500);
    
88. 
    
89.     sprintf(sql,"select a.baseID,a.deviceID,a.channelID,b.param3,b.param2,b.param1,b.param0 from baseinfo a,baseParam b where a.baseID=b.baseID AND a.flag=1 AND a.sectionID=%d order by a.deviceID, a.channelID,a.baseID ;",sectionID);
    
90. 
    
91. //    printf("[INFO]: SQL is %s\n",sql);
    
92.     
    
93.     ret = mysql_real_query(mysql,sql, strlen(sql));    
    
94.     if (ret != 0) {
    
95.                 printf("exec sql %s error!\n",sql);
    
96.                 return -1;
    
97.         }
    
98. 
    
99.     *result = mysql_store_result(mysql);
    
100. 
     
101.     return 0;
     
102. 
     
103. }
     
104. /*插入数据*/
105. int insertTempData(MYSQL *mysql,int baseID,double temperature)
     
106. {
     
107.     char sql[500];
     
108.     
     
109.     int ret;
     
110.     
     
111.        memset(sql,0x00,500);
     
112.     
     
113.     sprintf(sql,"INSERT INTO tempData(baseID,temperature) VALUES(%d,%f);",baseID,temperature);
     
114.     
     
115.     printf("[INFO]: SQL is %s\n",sql);
     
116.     
     
117.     ret = mysql_real_query(mysql,sql, strlen(sql));    
     
118.     if (ret != 0) {
     
119.                 printf("exec sql %s error!\n",sql);
     
120.                 return -1;
     
121.         }
     
122. 
     
123.     
     
124.     return 0;
     
125. }