php执行批量更新数据

1. <?php
   
2. /**
   
3. * 举例，我要更新goods表中id值在1,2,10,15且parent_id=10的记录的name值改为对应的值，按如下给的data数据即为传入的数据，实际生成的sql语句是：
   
4. UPDATE `goods` SET `name` = CASE `id` WHEN '1' THEN 'zhangsan' WHEN '2' THEN 'lisi' WHEN '3' THEN 'wangwu' WHEN '4' THEN 'zhaoliu' WHEN '10' THEN 'zhengqi' WHEN '15' THEN 'wangba' END,`parent_id` = CASE `id` WHEN '1' THEN '10' WHEN '2' THEN '11' WHEN '3' THEN '10' WHEN '4' THEN '10' WHEN '10' THEN '12' WHEN '15' THEN '10' END WHERE `id` IN ('1','2','3','4','10','15') AND `parent_id` = '10'
   
5. 
   
6. 然后使用框架提供的执行php更新的原生sql语句的方法，这里以thinkphp5框架为例
   
7. */
   
8. $data = [
   
9.         ['id' => 1, 'name' => 'zhangsan', 'parent_id' => 10],
   
10.         ['id' => 2, 'name' => 'lisi', 'parent_id' => 11],
    
11.         ['id' => 3, 'name' => 'wangwu', 'parent_id' => 10],
    
12.         ['id' => 4, 'name' => 'zhaoliu', 'parent_id' => 10],
    
13.         ['id' => 10, 'name' => 'zhengqi', 'parent_id' => 12],
    
14.         ['id' => 15, 'name' => 'wangba', 'parent_id' => 10],
    
15. ];
    
16. 
    
17. $sql = batchUpdate('goods', $data, 'id', ['parent_id' => 10]);
    
18. echo $sql;
    
19. // $result = Db::execute($sql);
    
20. 
    
21. 
    
22. 
    
23. /**
    
24. * 批量更新函数，返回批量更新执行的sql
    
25. * @param string $table 要更新的表名，例：goods表
    
26. * @param array $data 待更新的数据，二维数组格式，例：$data = [['id' => 1, 'name' => 'zhangsan'],['id' => 2, 'name' => 'lisi']];
    
27. * @param string $field string 值不同的条件，例：id
    
28. * @param array $params where条件的其他额外判断条件，键值对应的一维数组，例：['parent_id' => 1]
    
29. * @return bool|string
    
30. */
    
31. function batchUpdate($table = '', $data = [], $field = '', $params = [])
    
32. {
    
33.     if (!is_array($data) || !$field || !is_array($params)) {
    
34.         return false;
    
35.     }
    
36. 
    
37.     $updates = parseUpdate($data, $field);
    
38.     $where = parseParams($params);
    
39. 
    
40.     // 获取所有键名为$field列的值，值两边加上单引号，保存在$fields数组中
    
41.     $fields = array_column($data, $field);
    
42.     $fields = implode(',', array_map(function($value) {
    
43.         return "'".$value."'";
    
44.     }, $fields));
    
45. 
    
46.     $sql = sprintf("UPDATE `%s` SET %s WHERE `%s` IN (%s) %s", $table, $updates, $field, $fields, $where);
    
47.     return $sql;
    
48. }
    
49. 
    
50. /**
    
51. * 将二维数组转换成CASE WHEN THEN的批量更新条件
    
52. * @param $data array 二维数组
    
53. * @param $field string 列名
    
54. * @return string sql语句
    
55. */
    
56. function parseUpdate($data, $field)
    
57. {
    
58.     $sql = '';
    
59.     $keys = array_keys(current($data));
    
60.     foreach ($keys as $column) {
    
61.             if ($column == $field) {
    
62.                     continue;
    
63.             }
    
64.         $sql .= sprintf("`%s` = CASE `%s` \n", $column, $field);
    
65.         foreach ($data as $line) {
    
66.             $sql .= sprintf("WHEN '%s' THEN '%s' \n", $line[$field], $line[$column]);
    
67.         }
    
68.         $sql .= "END,";
    
69.     }
    
70.     return rtrim($sql, ',');
    
71. }
    
72. 
    
73. /**
    
74. * 解析where条件
    
75. * @param $params
    
76. * @return array|string
    
77. */
    
78. function parseParams($params = [])
    
79. {
    
80.     $where = [];
    
81.     if (!empty($params)) {
    
82.         foreach ($params as $key => $value) {
    
83.             $where[] = sprintf("`%s` = '%s'", $key, $value);
    
84.         }
    
85.     }
    
86.     return !empty($where) ? ' AND ' . implode(' AND ', $where) : '';
    
87. }

复制代码