PHP+MYSQL批量UPDATE循环拼接语句

cqwcns 发表于 2019-10-3 22:37

新菜一枚，这两天在研究大批量数据UPDATE到MYSQL的问题，多得本论坛smldhz大哥的指点（原帖https://www.52pojie.cn/thread-1032696-1-1.html），对自己写的代码进行了优化，由逐条执行改为串接SQL语句集中执行，效率确实显著（等全套代码完成再贴出来大家分享、指教）。
INSERT和DELETE语句结构简单，直接拼接即可，已经解决。
问题是UPDATE语句，结构较复制，自己弄了从下午到晚上折腾了大半天还是没搞掂。
需要UPDATE的数据源是一个数组，是字段名称，后面是要UPDATE的值（结构如下），求大神帮忙写一下循环拼接UPDATE语句的代码，感谢{:1_893:}{:1_893:}{:1_893:}。
$arrUPDATE = array
(
array("ziduanA","zhiA1","zhiA2"),
array("ziduanB","zhiB1","zhiB2"),
array("ziduanC","zhiC1","zhiC2"),
array("ziduanD","zhiD1","zhiD2"),
array("ziduanE","zhiE1","zhiE2")
);

smldhz大哥提供的语句示例：
UPDATE xx
SET a = CASE c
   WHEN 1 THEN 'a'
   WHEN 2 THEN 'b'
   WHEN 3 THEN 'c'
END,
b = CASE c
   WHEN 1 THEN '1111'
   WHEN 2 THEN '2222'
   WHEN 3 THEN '3333'
END
WHERE c IN (1,2,3)

cqwcns 发表于 2019-10-4 14:48

问题已解决：

$data = [
['id' => 1, 'parent_id' => 100, 'title' => 'A', 'sort' => 1],
['id' => 2, 'parent_id' => 100, 'title' => 'A', 'sort' => 3],
['id' => 3, 'parent_id' => 100, 'title' => 'A', 'sort' => 5],
['id' => 4, 'parent_id' => 100, 'title' => 'B', 'sort' => 7],
['id' => 5, 'parent_id' => 101, 'title' => 'A', 'sort' => 9],
];

/**
* 批量更新函数
* @Param $data array 待更新的数据，二维数组格式
* @param array $params array 值相同的条件，键值对应的一维数组
* @param string $field string 值不同的条件，默认为id
* @Return bool|string
*/
function batchUpdate($data, $field, $params = [])
{
if (!is_array($data) || !$field || !is_array($params)) {
   return false;
}

$updates = parseUpdate($data, $field);
$where = parseParams($params);

// 获取所有键名为$field列的值，值两边加上单引号，保存在$fields数组中
// array_column()函数需要PHP5.5.0+，如果小于这个版本，可以自己实现，
// 参考地址：http://php.net/manual/zh/function.array-column.php#118831
$fields = array_column($data, $field);
$fields = implode(',', array_map(function($value) {
   return "'".$value."'";
}, $fields));

$sql = sprintf("UPDATE `%s` SET %s WHERE `%s` IN (%s) %s", 'post', $updates, $field, $fields, $where);

return $sql;
}

/**
* 将二维数组转换成CASE WHEN THEN的批量更新条件
* @param $data array 二维数组
* @param $field string 列名
* @return string sql语句
*/
function parseUpdate($data, $field)
{
$sql = '';
$keys = array_keys(current($data));
foreach ($keys as $column) {

   $sql .= sprintf("`%s` = CASE `%s` \n", $column, $field);
   foreach ($data as $line) {
         $sql .= sprintf("WHEN '%s' THEN '%s' \n", $line[$field], $line[$column]);
   }
   $sql .= "END,";
}

return rtrim($sql, ',');
}

/**
* 解析where条件
* @param $params
* @return array|string
*/
function parseParams($params)
{
$where = [];
foreach ($params as $key => $value) {
   $where[] = sprintf("`%s` = '%s'", $key, $value);
}

return $where ? ' AND ' . implode(' AND ', $where) : '';
}

页: [1]

吾爱破解 - 52pojie.cn's Archiver

PHP+MYSQL批量UPDATE循环拼接语句