Windows课程设计如何连接数据库？求大神解答。

RenZhiYuansa

Windows课程设计如何连接数据库？求大神解答。

人造人

1. #include <stdio.h>
   
2. #include <stdlib.h>
   
3. #include <unistd.h>
   
4. #include <sys/wait.h>
   
5. #include <mysql/mysql.h>
   
6. 
   
7. typedef struct {
   
8.     size_t test_id, t1, t2, t3;
   
9. } test_data_t;
   
10. 
    
11. void print_mysql_res(MYSQL_RES *mysql_res) {
    
12.     MYSQL_ROW row;
    
13.     unsigned int num_fields = mysql_num_fields(mysql_res);
    
14.     MYSQL_FIELD *field = mysql_fetch_fields(mysql_res);
    
15.     for(size_t i = 0; i < num_fields; ++i) {
    
16.         printf("%-10s", field[i].name);
    
17.     }
    
18.     printf("\n");
    
19.     while((row = mysql_fetch_row(mysql_res))) {
    
20.         for(size_t i = 0; i < num_fields; ++i) {
    
21.             printf("%-10s", row[i]);
    
22.         }
    
23.         printf("\n");
    
24.     }
    
25. }
    
26. 
    
27. void get_test_data(MYSQL *mysql, test_data_t *data) {
    
28.     MYSQL_ROW row;
    
29.     mysql_query(mysql, "select * from test_table");
    
30.     MYSQL_RES *mysql_res = mysql_store_result(mysql);
    
31.     unsigned int num_fields = mysql_num_fields(mysql_res);
    
32.     size_t *array[] = {&data->test_id, &data->t1, &data->t2, &data->t3};
    
33.     if((row = mysql_fetch_row(mysql_res))) {
    
34.         for(size_t i = 0; i < num_fields; ++i) {
    
35.             sscanf(row[i], "%lu", array[i]);
    
36.         }
    
37.     }
    
38.     mysql_free_result(mysql_res);
    
39. }
    
40. 
    
41. void set_test_data(MYSQL *mysql, const test_data_t *data) {
    
42.     char buff[1024];
    
43.     snprintf(buff, 1024, "update test_table set test_id = %lu, t1 = %lu, t2 = %lu, t3 = %lu where test_id = 0", \
    
44.         data->test_id, data->t1, data->t2, data->t3);
    
45.     mysql_query(mysql, buff);
    
46. }
    
47. 
    
48. void task1(void) {
    
49.     MYSQL mysql;
    
50.     mysql_init(&mysql);
    
51.     mysql_real_connect(&mysql, "localhost", "name1", "password1", "test_database", 0, NULL, 0);
    
52.     for(size_t i = 0; i < 1000; ++i) {
    
53.         test_data_t data;
    
54.         usleep(200);
    
55.         mysql_query(&mysql, "lock tables test_table write");
    
56.         get_test_data(&mysql, &data);
    
57.         ++data.t1;
    
58.         set_test_data(&mysql, &data);
    
59.         mysql_query(&mysql, "unlock tables");
    
60.     }
    
61.     mysql_close(&mysql);
    
62.     exit(0);
    
63. }
    
64. 
    
65. void task2(void) {
    
66.     MYSQL mysql;
    
67.     mysql_init(&mysql);
    
68.     mysql_real_connect(&mysql, "localhost", "name2", "password2", "test_database", 0, NULL, 0);
    
69.     for(size_t i = 0; i < 1000; ++i) {
    
70.         test_data_t data;
    
71.         mysql_query(&mysql, "lock tables test_table write");
    
72.         get_test_data(&mysql, &data);
    
73.         usleep(10);
    
74.         ++data.t2;
    
75.         set_test_data(&mysql, &data);
    
76.         mysql_query(&mysql, "unlock tables");
    
77.     }
    
78.     mysql_close(&mysql);
    
79.     exit(0);
    
80. }
    
81. 
    
82. void task3(void) {
    
83.     MYSQL mysql;
    
84.     mysql_init(&mysql);
    
85.     mysql_real_connect(&mysql, "localhost", "name3", "password3", "test_database", 0, NULL, 0);
    
86.     for(size_t i = 0; i < 1000; ++i) {
    
87.         test_data_t data;
    
88.         mysql_query(&mysql, "lock tables test_table write");
    
89.         get_test_data(&mysql, &data);
    
90.         ++data.t3;
    
91.         set_test_data(&mysql, &data);
    
92.         usleep(200);
    
93.         mysql_query(&mysql, "unlock tables");
    
94.     }
    
95.     mysql_close(&mysql);
    
96.     exit(0);
    
97. }
    
98. 
    
99. int main(void) {
    
100.     MYSQL mysql;
     
101.     mysql_init(&mysql);
     
102.     mysql_real_connect(&mysql, "localhost", "root", "Bdj0=3)MpqsF", NULL, 0, NULL, 0);
     
103.     mysql_query(&mysql, "create database if not exists test_database");
     
104.     mysql_query(&mysql, "drop table if exists test_database.test_table");
     
105.     mysql_query(&mysql, "create table if not exists test_database.test_table(test_id integer, \
     
106.         t1 integer, t2 integer, t3 integer)");
     
107.     mysql_query(&mysql, "insert into test_database.test_table(test_id, t1, t2, t3) select 0, 0, 0, 0 from dual \
     
108.         where not exists(select * from test_database.test_table)");
     
109.     mysql_query(&mysql, "create user if not exists 'name1'@'localhost' identified by 'password1'");
     
110.     mysql_query(&mysql, "create user if not exists 'name2'@'localhost' identified by 'password2'");
     
111.     mysql_query(&mysql, "create user if not exists 'name3'@'localhost' identified by 'password3'");
     
112.     mysql_query(&mysql, "grant all on *.* to 'name1'@'localhost'");
     
113.     mysql_query(&mysql, "grant all on *.* to 'name2'@'localhost'");
     
114.     mysql_query(&mysql, "grant all on *.* to 'name3'@'localhost'");
     
115. 
     
116.     void (*data[3])(void) = {task1, task2, task3};
     
117.     for(size_t i = 0; i < 3; ++i) {
     
118.         if(!fork()) data[i]();
     
119.     }
     
120.     int child_stat[3];
     
121.     for(size_t i = 0; i < 3; ++i)  wait(&child_stat[i]);
     
122. 
     
123.     mysql_query(&mysql, "select * from test_database.test_table");
     
124.     MYSQL_RES *mysql_res = mysql_store_result(&mysql);
     
125.     print_mysql_res(mysql_res);
     
126.     mysql_free_result(mysql_res);
     
127.     mysql_close(&mysql);
     
128.     return 0;
     
129. }
     

复制代码