多进程访问mysql数据库的问题

wang_guang_ping

现在有多个进程，当它们连接同一个数据库的时候，该怎么做？
比如：是让每个进程都创建数据库连接？
还是多个进程创建一个数据库连接？
哪个方法更好一些？
有没有更好的方法？
另外，多个进程创建一个数据库连接，多进程访问数据库用加锁保护吗

hellioncu

当然是多个进程每个都创建数据库连接，换成线程也应该这么做。
数据库自己会解决锁的问题

bestscw

楼主，我的一个多进程插入数据库
看下,会开启18个进程，同时插

1. 
   
2. #include <stdio.h>  
   
3. #include <stdlib.h>  
   
4. #include <string.h>
   
5. #include <sys/time.h>
   
6. #include <unistd.h>
   
7. #include <mysql/mysql.h>
   
8. #include<sys/types.h>
   
9. #include<sys/wait.h>
   
10. 
    
11. #define DB_HOST "127.0.0.1"
    
12. #define DB_USER "root"
    
13. #define DB_PASS ""
    
14. #define DB_NAME "test"
    
15. #define DB_PORT 3307
    
16. 
    
17. int main(int argc, char **argv)
    
18. {
    
19.         MYSQL mysql;
    
20. 
    
21.         unsigned int i;
    
22.         int rtn; /*子进程的返回数值*/
    
23.         unsigned int process_no;
    
24.         unsigned int userId;
    
25.         unsigned int type;
    
26.         unsigned int itemCate;
    
27.         unsigned int itemType;
    
28.         unsigned int itemNum;
    
29.         unsigned int totalCost;
    
30.         unsigned int consumeTime;
    
31.         unsigned int leftBalance;
    
32.         char itemName[1000] ;
    
33.         char sql[20000] ;
    
34. 
    
35.     struct timeval time_start,time_end;
    
36.     float execute_time;
    
37.        
    
38.     //srand(time(0));
    
39. 
    
40.         for(process_no = 1; process_no < 18; process_no++)
    
41.         {
    
42.                 if(fork() == 0)
    
43.                 {
    
44.                     // 开始执行时间
    
45.                     gettimeofday(&time_start,NULL);
    
46. 
    
47.                         mysql_init(&mysql);
    
48. 
    
49.                         if(!mysql_real_connect(&mysql,DB_HOST,DB_USER,DB_PASS,DB_NAME,DB_PORT,NULL,0))
    
50.                         {
    
51.                                 fprintf(stderr, "Failed to connect to database: Error: %s\n",mysql_error(&mysql));
    
52.                         }
    
53. 
    
54.                         mysql_query(&mysql,"SET NAMES utf8");
    
55. 
    
56.                         for(i = 0; i < 444444; i++)
    
57.                         {
    
58.                                 sprintf(itemName,"%s","");
    
59. 
    
60.                                 userId = rand()%19071388 + 1;
    
61.                                 type = rand()%4 + 1;
    
62.                                 itemCate = rand()%15 + 1;
    
63.                                 itemType = rand()%100 + 1;
    
64.                                 itemNum = rand()%100 + 1;
    
65.                                 totalCost = rand()%10000 + 1;
    
66.                                 consumeTime = rand()%1309120853 + 1;
    
67.                                 leftBalance = rand()%10000 + 1;
    
68. 
    
69.                                 sprintf(sql,"insert into user_consume1(userId,type,itemCate,itemType,itemNum,totalCost,consumeTime,leftBalance,itemName)values(%d,%d,%d,%d,%d,%d,%d,%d,'')",
    
70.                                         userId,type,itemCate,itemType,itemNum,totalCost,consumeTime,leftBalance);
    
71. 
    
72.                                 if(mysql_query(&mysql,sql))
    
73.                                 {
    
74.                                         fprintf(stderr,"query failed:%s",mysql_error(&mysql));
    
75.                                 }
    
76.                         }
    
77. 
    
78.                         mysql_close(&mysql);
    
79. 
    
80.                         // 结束执行时间
    
81.                         gettimeofday(&time_end,NULL);
    
82. 
    
83.                         execute_time = (time_end.tv_sec - time_start.tv_sec) + (time_end.tv_usec - time_start.tv_usec)/1000000;
    
84.                         printf("execute time:%f\n",execute_time);
    
85. 
    
86.                         exit(0);
    
87.                 }
    
88.                 else
    
89.                 {
    
90.                         /* 父进程， 等待子进程结束，并打印子进程的返回值 */
    
91.                         //wait ( &rtn );
    
92.                         //printf("child process return %d\n",rtn);
    
93.                         //return 0;
    
94.                         //printf("execute child process return %d\n",process_no);
    
95.                 }
    
96.         }
    
97. 
    
98. 
    
99. 
    
100. 
     
101. 
     
102.         return 0;
     
103. }
     
104. 
     
105. 
     
106. 
     
107. 
     

复制代码

mysql_insert.rar (1.06 KB, 下载次数: 54)

2011-05-16 16:51 上传

点击文件名下载附件