laravel 批量更新:‌INSERT ... ON DUPLICATE KEY UPDATE

在SQL批量更新时可通过INSERT ... ON DUPLICATE KEY UPDATE 语句进行批量更新,具体做法是,在插入数据时处理唯一索引或主键冲突,不执行插入操作,而是执行指定的更新操作。

INSERT INTO table_name(column1, column2, ...) VALUES(value1, value2, ...) ON DUPLICATE KEY UPDATE column1=value1, column2=value2, ...

例如我们可以通过传主键id来进行插入数据冲突,从而实现批量更新数据,具体用laravel实现的话,我们可以用原生语句 + 绑定参数来进行实现,代码具体实现为

    /**
     * @param Model|mixed $model 需要更新数据模型类 如: new App\Models\User ()
     * @param array $attributesList 更新数据内容,如:[['id' => 1, 'name' => "小王"], ['id' => 2, 'name' => "小刘"]]
     * @param array $updateKey 需要更新的字段,必须是表中包含的字段 ['id', 'name']
     * @param string $id 主键名称,默认为 id
     * @param int $size 批量分批更新数量 默认100条数据
     * @return void
     * @throws \Exception
     */
    public static function batchUpdate($model, array $attributesList, array $updateKey, string $id = 'id', int $size = 100): void
    {
        //更新内容空直接返回
        if (!$attributesList) {
            return;
        }
        // 判断id是否为主键
        if ($id !== $model->getKeyName()) {
            throw new \RuntimeException($id . '不为主键不能进行批量更新');
        }
        // 主键需存在 更新字段中
        if (!in_array($id, $updateKey, false)) {
            throw new RuntimeException('主键必须存在更新的字段中');
        }
        
        // 更新字段在模型表中
        $columns = Schema::getColumnListing($model->getTable());
        if ($columns && is_array($columns)) {
            foreach ($updateKey as $updateItem) {
                if (!in_array($updateItem, $columns, false)) {
                    throw new RuntimeException($updateItem . '不存在表中,无法进行更新');
                }
            }
        }
        
        //更新字段要存在与更新内容中
        $primaryIds = [];
        foreach ($attributesList as $item) {
            if ($item[$id]) {
                $primaryIds[] = $item[$id];
            } else {
                throw new RuntimeException('存在' . $id, '为空');
            }
            foreach ($updateKey as $column) {
                if (!isset($item[$column])) {
                    throw new RuntimeException("批量更新失败!传入的数据中不存在字段{$column}!", 500);
                }
            }
        }
        //更新的内容必须存在于表中
        if (count($primaryIds) !== $model::query()->whereIn($id, $primaryIds)->count()) {
            throw new RuntimeException('存在不在记录中的数据');
        }

        
        DB::beginTransaction();
        try {
            //分批进行更新
            //更新语句 如:INSERT INTO user(`id`,`name`) values(:id_0,:name_0),(:id_1,:name_1) ON DUPLICATE KEY UPDATE `id`=values(`id`),`name`=values(`name`)
            //绑定参数 如 ['id_0' => 1, 'name_0' => '小王', 'id_1' => 1, 'name_1' => '小刘']
            foreach (array_chunk(array_values($attributesList), $size) as $dataChunkList) {
                $dataChunkList = array_values($dataChunkList);
                $sql = 'INSERT';
                $sql .= ' INTO ' . $model->getTable() . '(`' . implode('`,`', $updateKey) . '`) values';
                foreach ($dataChunkList as $key => $data) {
                    $sql .= '(';
                    foreach ($updateKey as $column) {
                        $sql .= ":{$column}_{$key},";
                    }
                    $sql = substr($sql, 0, -1) . '),';
                }
                $sql = substr($sql, 0, -1);
                $sql .= ' ON DUPLICATE KEY UPDATE ';
                foreach ($updateKey as $column) {
                    $sql .= "`{$column}`=values(`{$column}`),";
                }
                $sql = substr($sql, 0, -1);

                $bindParam = [];
                foreach ($dataChunkList as $key => $data) {
                    foreach ($updateKey as $column) {
                        //更新字段要存在与更新内容中
                        $bindParam["{$column}_{$key}"] = $data[$column];
                    }
                }
                $bool = DB::insert($sql, $bindParam);
                if (!$bool) {
                    throw new RuntimeException("更新异常");
                }
            }
            DB::commit();
        } catch (\Exception $exception) {
            DB::rollBack();
            throw $exception;
        }
    }

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/949562.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

selenium无法定位元素的几种解决方案

🍅 点击文末小卡片,免费获取软件测试全套资料,资料在手,涨薪更快 1、frame/iframe表单嵌套 WebDriver只能在一个页面上对元素识别与定位,对于frame/iframe表单内嵌的页面元素无法直接定位。 解决方法: d…

SSM-Spring-IOC/DI注解开发

目录 IOC/DI注解开发 1 注解开发定义bean 2 纯注解开发模式 步骤 Bean的作用范围 Bean生命周期 3 注解开发依赖注入 Autowired 注解实现按照名称注入 简单数据类型注入 注解读取properties配置文件 4 IOC/DI 注解开发管理第三方bean 4.1 步骤(以管理第三…

深入探讨 Android 中的 AlarmManager:定时任务调度及优化实践

引言 在 Android 开发中,AlarmManager 是一个非常重要的系统服务,用于设置定时任务或者周期性任务。无论是设置一个闹钟,还是定时进行数据同步,AlarmManager 都是不可或缺的工具之一。然而,随着 Android 系统的不断演…

接口开发完后,个人对于接下来接口优化的一些思考

优化点 入参的合法性和长度范围&#xff0c;必填项的检查验证 因为没有入参&#xff0c;所以不需要考虑。 批量思想解决N1问题 // 假设要查询100个订单及其对应的用户信息 List<Order> orders orderMapper.selectList(new QueryWrapper<>().last("limit …

Redis内存碎片

什么是内存碎片? 你可以将内存碎片简单地理解为那些不可用的空闲内存。 举个例子&#xff1a;操作系统为你分配了 32 字节的连续内存空间&#xff0c;而你存储数据实际只需要使用 24 字节内存空间&#xff0c;那这多余出来的 8 字节内存空间如果后续没办法再被分配存储其他数…

小程序租赁系统开发的优势与应用前景分析

内容概要 小程序租赁系统是一种新兴的数字化解决方案&#xff0c;旨在为用户提供更加便捷与高效的租赁服务。它通常包括一系列功能&#xff0c;如在线浏览、即时预定、支付功能以及用户反馈机制。这些系统在使用上极为友好&#xff0c;让用户能够轻松选择所需的商品或服务&…

25年1月更新。Windows 上搭建 Python 开发环境:PyCharm 安装全攻略(文中有安装包不用官网下载)

python环境没有安装的可以点击这里先安装好python环境&#xff0c;python环境安装教程 安装 PyCharm IDE 获取 PyCharm PyCharm 提供两种主要版本——社区版&#xff08;免费&#xff09;和专业版&#xff08;付费&#xff09;。对于初学者和个人开发者而言&#xff0c;社区…

RedisTemplate执行lua脚本及Lua 脚本语言详解

使用RedisTemplate执行lua脚本 在开发中&#xff0c;我们经常需要与Redis数据库进行交互&#xff0c;而Redis是一个基于内存的高性能键值存储数据库&#xff0c;它支持多种数据结构&#xff0c;并提供了丰富的命令接口。在某些情况下&#xff0c;我们可能需要执行一些复杂的逻…

基于Python 的宠物管理系统(源码+部署)

博主介绍&#xff1a;✌程序员徐师兄、7年大厂程序员经历。全网粉丝12w、csdn博客专家、掘金/华为云/阿里云/InfoQ等平台优质作者、专注于Java技术领域和毕业项目实战✌ &#x1f345;文末获取源码联系&#x1f345; &#x1f447;&#x1f3fb; 精彩专栏推荐订阅&#x1f447;…

stm32第一次烧录或者上电运行卡死问题分析

问题描述 单片机烧录代码&#xff08;刚上电&#xff09;无法立即运行&#xff0c;必须要复位一次或多次才能运行&#xff1b;跟踪调试会进入HardFault_Handler中断。 问题分析 烧录配置如下图&#xff0c;首先排除配置问题那么该问题就比较让人头大了&#xff0c;理论上&am…

ESP32-C3 AT WiFi AP 启 TCP Server 被动接收模式 + BLE 共存

TCP 被动接收模式&#xff0c;每次发的数据会先存到缓冲区&#xff0c;参见&#xff1a;ATCIPRECVTYPE 指令说明。 即每包数据不会实时报告 IPD 接收情况&#xff0c;如果需要查询缓冲区的数据&#xff0c;先用 ATCIPRECVLEN? 指令查询被动接收模式下套接字数据的长度 。获取…

【LeetCode Hot100 二分查找】搜索插入位置、搜索二维矩阵、搜索旋转排序数组、寻找两个正序数组的中位数

二分查找 搜索插入位置搜索二维矩阵在排序数组中查找元素的第一个和最后一个位置寻找旋转排序数组中的最小值搜索旋转排序数组寻找两个正序数组的中位数&#xff08;hard&#xff09; 搜索插入位置 给定一个排序数组和一个目标值&#xff0c;在数组中找到目标值&#xff0c;并…

ChatGPT 主流模型GPT-4/GPT-4o mini的参数规模是多大?

微软论文又把 OpenAI 的机密泄露了&#xff1f;&#xff1f;在论文中明晃晃写着&#xff1a; o1-preview 约 300B&#xff1b;o1-mini 约 100BGPT-4o 约 200B&#xff1b;GPT-4o-mini 约 8BClaude 3.5 Sonnet 2024-10-22 版本约 175B微软自己的 Phi-3-7B&#xff0c;这个不用约…

Docker 安装Elasticsearch搜索引擎 搜索优化 词库挂载 拼音分词 插件安装

介绍 允许用户快速索引和搜索大量的文本数据。通过使用倒排索引&#xff0c;它能够在海量数据中高效检索相关信息。提供灵活的查询语言&#xff0c;可以做全文搜索、模糊搜索、数据统计等&#xff0c;用来代替MYSQL的模糊搜索&#xff0c;MYSQL的模糊搜索不支持使用索引从而导…

Scala_【5】函数式编程

第五章 函数式编程函数和方法的区别函数声明函数参数可变参数参数默认值 函数至简原则匿名函数高阶函数函数作为值传递函数作为参数传递函数作为返回值 函数闭包&柯里化函数递归控制抽象惰性函数友情链接 函数式编程 面向对象编程 解决问题时&#xff0c;分解对象&#xff…

jenkins入门7 --发送邮件1

jenkins发送邮件配置&#xff08;全局配置&#xff09;_jenkins 怎么发送邮件-CSDN博客 本文通过163发送邮件 1、首先163设置选择pop3/smtp/imap,开启服务&#xff0c;获取授权码 2、jenkins下载邮件插件 登录Jenkins管理界面&#xff0c;点击“Manage Jenkins”。 选择“Man…

git 常用命令和本地合并解决冲突

目录 一、常用命令 二、本地可视化合并分支解决冲突 一、常用命令 最近&#xff0c;使用mac电脑&#xff0c;无法直接使用小乌龟进行可视化操作&#xff0c;现在记录一些常用命令。 拉取&#xff1a; git clone <git url> 仅拉起某个单独分支&#xff1a; git clo…

彻底学会Gradle插件版本和Gradle版本及对应关系

看完这篇&#xff0c;保你彻底学会Gradle插件版本和Gradle版本及对应关系&#xff0c;超详细超全的对应关系表 需要知道Gradle插件版本和Gradle版本的对应关系&#xff0c;其实就是需要知道Gradle插件版本对应所需的gradle最低版本&#xff0c;详细对应关系如下表格&#xff0…

我的创作纪念日——《惊变128天》

我的创作纪念日——《惊变128天》 机缘收获日常成就憧憬 机缘 时光飞逝&#xff0c;转眼间&#xff0c;我已在这条创作之路上走过了 128 天。回顾起 2024 年 8 月 29 日&#xff0c;我满怀忐忑与期待&#xff0c;撰写了第一篇技术博客《讲解LeetCode第1题&#xff1a;两数之和…

医学图像分析工具02:3D Slicer || 医学影像可视化与分析工具 支持第三方插件

3D Slicer 是一款功能全面的开源医学影像分析软件&#xff0c;广泛应用于影像处理、三维建模、影像配准和手术规划等领域。它支持多种医学影像格式&#xff08;如 DICOM、NIfTI&#xff09;和丰富的插件扩展&#xff0c;是神经科学、放射学和生物医学研究中不可或缺的工具。 在…