本文实例讲述了PHP优化之批量操作MySQL，分享给大家供大家参考，具体如下：

设计一个数据表如下:

1. create table optimization( 
2.   id INT NOT NULL AUTO_INCREMENT, 
3.   value VARCHAR(10) NOT NULL, 
4.   PRIMARY KEY(id) 
5. ); 

现在有一个业务需求需要批量插入数据。

先来看看下面这一段代码：

1. <?php 
2.   $dsn = 'mysql:dbname=test;host=127.0.0.1'; 
3.   $user = 'root'; 
4.   $password = 'root'; 
5.  
6.   try { 
7.     $dbh = new PDO($dsn, $user, $password); 
8.   } catch(PDOException $e) { 
9.     echo 'Connection failed: ' , $e->getMessage(); 
10.   } 
11.   $begin = microtime(true) * 1000; 
12.  
13.   $count = 100; 
14.   $stmt = $dbh->prepare('INSERT INTO `optimization` (id, value) VALUES(:id, :value)'); 
15.   $stmt->bindParam(':id', $id); 
16.   $stmt->bindParam(':value', $value); 
17.   for ($i = 0; $i < $count; $i++) 
18.   { 
19.     $id = ''; 
20.     $value = $i; 
21.     $stmt->execute(); 
22.   } 
23.  
24.   $end = microtime(true) * 1000; 
25.   echo 'excuted : ' , ($end - $begin) , ' ms'; 

经过测试，上面代码运行结果如下：

1、excuted : 7601.4348144531 ms

2、excuted : 7476.4270019531 ms

3、excuted : 7674.4387207031 ms

平均：7584.100179036433 ms

再来看看第二段代码：

1. <?php 
2.   $dsn = 'mysql:dbname=test;host=127.0.0.1'; 
3.   $user = 'root'; 
4.   $password = 'root'; 
5.  
6.   try { 
7.     $dbh = new PDO($dsn, $user, $password); 
8.   } catch(PDOException $e) { 
9.     echo 'Connection failed: ' , $e->getMessage(); 
10.   } 
11.  
12.   $begin = microtime(true) * 1000; 
13.   $dbh->beginTransaction(); 
14.   try { 
15.     $count = 100; 
16.     $sql = 'INSERT INTO `optimization` (id, value) VALUES '; 
17.     $sql_arr = array(); 
18.     $sql_str = ''; 
19.     for ($i = 0; $i < $count; $i++) 
20.     { 
21.       $sql_arr[] = ("('', $i)"); 
22.     } 
23.     $sql_str = implode(',', $sql_arr); 
24.     $sql .= $sql_str; 
25.     $stmt = $dbh->prepare($sql); 
26.     $stmt->execute(); 
27.     $dbh->commit(); 
28.   } catch(Exception $e) { 
29.     $dbh->rollBack(); 
30.     echo $e->getMessage() . '<br>'; 
31.   } 
32.  
33.   $end = microtime(true) * 1000; 
34.   echo 'excuted : ' , ($end - $begin) , ' ms'; 

上面这段代码的运行结果如下：

1、excuted : 99.005859375 ms

2、excuted : 103.00610351562 ms

3、excuted : 68.00390625 ms

平均：90.00528971354 ms

##分析 可以看出，在第二段代码中，使用了批量插入，此时的效率比第一段提高了84%，原因如下：

使用第一段代码的时候，因为每一次循环里都执行了一个mysql语句，此时php需要与mysql获得连接，然后再执行mysql语句，然后再断开。这就是第一段代码最主要的时间开销–PHP与MySQL连接的网络传输IO

第一段代码SQL语句解析的次数更多

因此，在第二段代码中，通过合并SQL语句来实现减少SQL语句解析的次数以及PHP与MySQL连接的次数来达到减少网络传输IO的开销。

注意： 1、SQL语句是有长度限制的，因此，在进行SQL语句合并时务必不能超过SQL长度限制，通过设置max_allowed_packet可以修改，默认是1M，测试时修改为8M。

##总结

在进行对数据库的批量操作（如：插入、更新、修改）时，应当尽可能将SQL语句合并后再执行而不是在循环中依次执行。

记录下最近在项目中犯下的一个比较大的错误，以后不能再犯了，以前一直都没有注意到，直到现在真正参与到企业项目中，自己的代码被老大指出错误后才发现自己的错误，学习了。

Tags: PHP优化 PHP批量操作MySQL

分享到：