设为首页 收藏本站
查看: 607|回复: 0

[经验分享] MySQL实现一条sql完成多条数据的更新

[复制链接]

尚未签到

发表于 2018-10-15 07:46:00 | 显示全部楼层 |阅读模式
$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],
  ];
  例如,我们想让parent_id为100、title为A的记录依据不同id批量更新:
  /**
  * 批量更新函数
  * @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、欢迎大家加入本站运维交流群:群②:261659950 群⑤:202807635 群⑦870801961 群⑧679858003
2、本站所有主题由该帖子作者发表,该帖子作者与运维网享有帖子相关版权
3、所有作品的著作权均归原作者享有,请您和我们一样尊重他人的著作权等合法权益。如果您对作品感到满意,请购买正版
4、禁止制作、复制、发布和传播具有反动、淫秽、色情、暴力、凶杀等内容的信息,一经发现立即删除。若您因此触犯法律,一切后果自负,我们对此不承担任何责任
5、所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其内容的准确性、可靠性、正当性、安全性、合法性等负责,亦不承担任何法律责任
6、所有作品仅供您个人学习、研究或欣赏,不得用于商业或者其他用途,否则,一切后果均由您自己承担,我们对此不承担任何法律责任
7、如涉及侵犯版权等问题,请您及时通知我们,我们将立即采取措施予以解决
8、联系人Email:admin@iyunv.com 网址:www.yunweiku.com

所有资源均系网友上传或者通过网络收集,我们仅提供一个展示、介绍、观摩学习的平台,我们不对其承担任何法律责任,如涉及侵犯版权等问题,请您及时通知我们,我们将立即处理,联系人Email:kefu@iyunv.com,QQ:1061981298 本贴地址:https://www.yunweiku.com/thread-621679-1-1.html 上篇帖子: 关闭sql server 2005远程连接 下篇帖子: SQl server 收缩事务日志
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

扫码加入运维网微信交流群X

扫码加入运维网微信交流群

扫描二维码加入运维网微信交流群,最新一手资源尽在官方微信交流群!快快加入我们吧...

扫描微信二维码查看详情

客服E-mail:kefu@iyunv.com 客服QQ:1061981298


QQ群⑦:运维网交流群⑦ QQ群⑧:运维网交流群⑧ k8s群:运维网kubernetes交流群


提醒:禁止发布任何违反国家法律、法规的言论与图片等内容;本站内容均来自个人观点与网络等信息,非本站认同之观点.


本站大部分资源是网友从网上搜集分享而来,其版权均归原作者及其网站所有,我们尊重他人的合法权益,如有内容侵犯您的合法权益,请及时与我们联系进行核实删除!



合作伙伴: 青云cloud

快速回复 返回顶部 返回列表