Easywoole框架实战_封装批量更新数据ORM-Eswlnk Blog
智能摘要 AI
本文介绍了作者在使用EasySwoole框架开发项目时，因框架未提供批量更新功能而自行扩展的方法。EasySwoole是一个基于Swoole的高性能PHP框架，支持HTTP、TCP和UDP协议的混合监控。作者通过修改ORM包中的`AbstractModel.php`文件，添加了`upDataInfo`等方法，实现了批量更新功能。该方法通过构建动态SQL语句，根据指定字段批量更新数据库记录。尽管功能已实现，但作者仍建议官方在后续版本中加入此功能，以减少用户手动修改代码的需求。

最近在承接一个项目时用到了Easywoole框架，为此特意学习了解了一下有关该框架的信息。它是一个基于 swoole 服务器开发的内存驻留分布式 PHP 框架。该框架为 Api 设计的，摆脱了传统 PHP 运行模式在进程调用和文件加载中造成的性能损失。Easysoole 高度封装了 swoole 服务器，并且仍然保持了 swoole 服务器的原始特性。它同时支持 HTTP、自定义 TCP 和 UDP 协议的混合监控，允许开发人员以最低的学习成本和精力编写多进程、异步和高可用的应用程序服务。

Easywoole框架实战_封装批量更新数据ORM-Eswlnk Blog
框架

前言

在写一个项目时用了easyswoole框架，需要用到批量更新方法，但是easyswoole没有去实现方法，只能自己封装了。

实现代码

找到ORM包的src/AbstractModel.php文件，在文件最后添加上下面代码就可以实现了。

    /**
     * 批量更新数据
     * 根据$field 字段 更新数据
     **/
    public function upDataInfo($data, $field = null, $where = [])
    {
        //主键没有定义自动寻找主键
        if (is_null($field)) {
            $field = $this->schemaInfo()->getPkFiledName();
            if (empty($field)) {
                throw new Exception('upDataInfo needs primaryKey for model ');
            }
        }
        //语句组装
        $updates = $this->parseUpdate($data, $field);
        $where = $this->parseParams($where);
        $fields_c = array_map(function ($v) use ($field) {
            return $v["$field"];
        }, $data);
        $fields = implode(',', array_map(function ($value) {
            return "'" . $value . "'";
        }, $fields_c));
        $sql = sprintf("UPDATE `%s` SET %s WHERE `%s` IN (%s) %s", $this->tableName, $updates, $field, $fields, $where);
        return $sql;
    }

    /**
     * Function parseUpdate
     * 将二维数组转换成CASE WHEN THEN的批量更新条件
     */
    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, ',');
    }

    /**
     * Function parseParams
     * 解析where条件
     */
    function parseParams($params)
    {
        $where = [];
        foreach ($params as $key => $value) {
            $where[] = sprintf("`%s` = '%s'", $key, $value);
        }
        return $where ? ' AND ' . implode(' AND ', $where) : '';
    }

使用

$model = new UploadModel();
        echo $model->upDataInfo([
            ['id' => 1, 'name' => '教书先生', 'email' => '599928887@qq.com'],
            ['id' => 2, 'name' => '教书先生2', 'email' => '599928887@qq.com']
        ], 'id');

运行结果

UPDATE `upload_list` SET `id` = CASE `id` 
WHEN '1' THEN '1' 
WHEN '2' THEN '2' 
END,`name` = CASE `id` 
WHEN '1' THEN '教书先生' 
WHEN '2' THEN '教书先生2' 
END,`email` = CASE `id` 
WHEN '1' THEN '599928887@qq.com' 
WHEN '2' THEN '599928887@qq.com' 
END WHERE `id` IN ('1','2')

最后

还是希望官方下次更新可以实现下批量更新数据方法，每次拉框架还要修改文件。