如何在 Dapper 中使用一条 sql 语句传递多条记录进行更新

2024-01-08

我正在尝试使用一个 Update 语句来更新具有不同值的多个记录(我并没有尝试更新许多行以具有相同的值,这非常简单)。这就是我现在正在尝试的:

    using (var cn = GetOpenConnection()) {

        // get items where we need to set calculated fields that will now be persisted in the DB
        var items = cn.Query<MaintenanceItem>("select TOP 500 * from [Maintenance] where Tolerance IS NOT NULL");

        foreach (var mi in maintItems)
        {
            // Set calculated fields on multiple recrods
            logic.CalculateToleranceFields(mi, true);
        }


        var updateInput = items.Select(a => new {a.ToleranceMonths, a.ToleranceDays, a.ToleranceHours, a.ToleranceLandings, a.ToleranceCycles, a.ToleranceRIN }).ToList();

       // THIS DOESN'T WORK - attempting to update multiple rows with different values
       var numResults = cn.Execute(@"UPDATE rm 
                SET rm.ToleranceMonths=ur.ToleranceMonths, 
                rm.ToleranceDays=ur.ToleranceDays, 
                rm.ToleranceHours=ur.ToleranceHours, 
                rm.ToleranceLandings=ur.ToleranceLandings, 
                rm.ToleranceCycles=ur.ToleranceCycles, 
                rm.ToleranceRIN=ur.ToleranceRIN 
            from [RoutineItems] rm
            Inner Join @UpdatedRecords ur ON rm.AircraftId=ur.AircraftId AND rm.ItemNumber=ur.ItemNumber", updateInput);

        Assert.IsTrue(numResults == maintItems.Count());

    }

Dapper是否可以使用这种批量更新?我宁愿进行批量更新,而不是使用for循环将数据推入数据库。


看起来目前 Dapper 中的一项声明无法实现这一点。当考虑到需要在幕后做什么才能实现这一目标时,这是完全可以理解的。

我最终做的是使用 3 条语句创建一个临时表,填充需要更新的数据,然后通过内部联接调用临时表的更新:

cn.Execute(@"create table #routineUpdatedRecords
                        (
                            AircraftId int, 
                            ItemNumber int,
                            ToleranceMonths int,
                            ToleranceDays int,
                            ToleranceLandings int,
                            ToleranceCycles decimal(12,2),
                            ToleranceRIN decimal(12,2),
                            ToleranceHours decimal(12,2)
                        );");


cn.Execute(@"Insert INTO #routineUpdatedRecords 
    VALUES(@AircraftId, @ItemNumber, @ToleranceMonths, @ToleranceDays, 
@ToleranceLandings, @ToleranceCycles, @ToleranceRIN, @ToleranceHours)", updateInput);

var numResults = cn.Execute(@"UPDATE rm 
                                SET rm.ToleranceMonths=ur.ToleranceMonths, 
                                rm.ToleranceDays=ur.ToleranceDays, 
                                rm.ToleranceHours=ur.ToleranceHours, 
                                rm.ToleranceLandings=ur.ToleranceLandings, 
                                rm.ToleranceCycles=ur.ToleranceCycles, 
                                rm.ToleranceRIN=ur.ToleranceRIN 
                            from [RoutineItems] rm
                            Inner Join #routineUpdatedRecords ur ON rm.AircraftId=ur.AircraftId AND rm.ItemNumber=ur.ItemNumber");

我相信这比循环调用 update 更快,因为我更新了大约 600K 行。

本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)

如何在 Dapper 中使用一条 sql 语句传递多条记录进行更新 的相关文章

随机推荐

  • cin >> i 输入符号 + 时出错

    在 C 程序中 我尝试处理由散布有运算符 的整数操作数组成的用户输入 我可以要求用户在每个运算符之前和之后添加空格 我的方法是假设任何不是 int 的东西都是运算符 因此 一旦流上出现非 eof 错误 我就会调用 cin clear 并将下
  • Node.js + Joi 如何显示自定义错误消息?

    在 Node js REST api 中验证用户的输入似乎非常简单Joi 但问题是我的应用程序不是用英语编写的 这意味着我需要向前端用户发送自定义的书面消息 我用谷歌搜索过这个 只发现了问题 也许有人可以为此提供解决方案 这是我用来验证的代
  • 如何在python中强制使用默认参数

    TLDR 我想将一个参数传递给一个函数 强制该函数使用它的默认值 就好像我没有提供任何参数一样 例如 def foo string DEFAULT PARAM print string def bar string None foo str
  • 如何在嵌套列表中执行条件搜索

    我有一个嵌套列表 如下所示 list c Oesophagus irregular z line as previously quad biopsies at m c Normal examination cardia mild infla
  • Django Rest-auth 注册。使用令牌认证时如何返回带有密钥的user_id

    我正在使用 Django rest auth registration 我在 urls py 中对应的条目是 url r rest auth registration include rest auth registration urls
  • 创建多屏支持应用android

    我正在 Android 中创建一个必须支持多个屏幕的应用程序 为此 我阅读了很多答案 其中我最喜欢的一个是我可以在其中创建不同的文件夹res按以下名称命名的文件夹 对于小屏幕小布局 适用于大屏幕布局大 对于超大屏幕布局 xlarge 我必须
  • 如何使用 DataContractJsonSerializer 将类类型而不是命名空间序列化为 Json 字符串

    我正在尝试使用将类层次结构序列化为 Json 字符串DataContractJsonSerializer 在 WCF 服务中 序列化派生类的默认行为是将以下键值对添加到对象 type ClassName Namespace 我的问题是命名空
  • 保存单个实体而不是整个上下文

    我遇到了一种情况 我本质上需要将一对多关联的子实体的更改写入数据库 但不保存对父实体所做的任何更改 实体框架当前处理上下文范围内的数据库提交 EntityContext SaveChanges 这对于强制执行关系等有意义 但我想知道是否有一
  • 如何检查dojo.datagrid加载完成? [复制]

    这个问题在这里已经有答案了 我的其中一个页面中有一个 dojo datagrid Datagrid 及其存储 通过调用 URL 是通过声明性方法创建的 不是通过动态 程序化 我需要执行一个 javascript 方法 该方法在我的数据网格下
  • 从两个相交的链表中查找相交的节点

    假设有两个单链表 它们在某个点相交并成为单链表 两个列表的头或起始指针已知 但相交节点未知 此外 每个列表在相交之前的节点数量是未知的 并且两个列表可能有所不同 即 List1 在到达相交点之前可能有 n 个节点 而 List2 在到达相交
  • 从 LazyLoadCollection 获取元素

    我已经发现Doctrine Common Collections Criteria如果它们对我有用的话 这是一个非常有用的概念 在 symfony 控制器中 我调用以下代码 criteria Criteria create gt where
  • 我对 SOAP 命名空间感到困惑

    我正在学习 SOAP 实现 并且对 SOAP 1 2 Envelope 的适当名称空间 URI 感到有些困惑 The SOAP 的 w3c 规范 http www w3 org TR soap12 part1指的是 http www w3
  • Ecto 查询 - 日期 + Postgres 间隔 + 查询插值

    我想创建一个 Ecto 查询来过滤 a 中的记录children按年龄排列的表格 即 最小年龄 月 gt 最大年龄 月 一种简单的方法是使用 Ectodate add特征 from c in Child where c birthday g
  • 如何仅选择 OData 子元素

    我正在构建一个 OData 应用程序 并且正在努力了解如何检索结果并且仅包含某些 子属性 首先 让我向您展示在我的构建器中的注册 builder EntitySet
  • Ng 服务抛出 @angular/core/core 没有导出成员“eeFactoryDe​​f”

    我收到了大约 50 个错误 这些错误都说 Angular core core 没有导出成员 eeFactoryDe f 它们来自不同的node modules 例如 Angular cdk ng bootstrap ngx pipes ng
  • 有没有比 Html.fromHtml() 更快的方法将 html 字符解码为字符串?

    我正在使用 Html fromHtml STRING toString 将可能包含或不包含 html 和 或 html 实体的字符串转换为纯文本字符串 这相当慢 我想我最后的计算是平均花费了大约 22 毫秒 对于大量的这些 它可以在一分钟内
  • 如何隐藏所有表单odoo中的“创建和编辑”按钮以及每行中的“搜索更多”按钮

    我想隐藏所有表单中的 创建和编辑 按钮 我还想以所有形式显示 搜索更多 按钮 目前我使用 odoo 10 让我们看看这个插件 https apps openerp com apps modules 9 0 web m2x options h
  • 如何在按下按钮后延迟删除课程?

    我的网站上有完整的页面导航 为了确保打开导航时页面无法滚动 正文采用隐藏溢出的 无滚动 类 当导航打开时 这也会删除滚动条 当再次按下导航按钮并且导航关闭时 类 no scroll 将从主体中删除 立即显示滚动条 导航栏需要 1 05 秒才
  • 使用适用于 iOS 的 Google Analytics API v3 进行会话控制?

    我刚刚用 API v3 替换了 GA 实现 并发现了这个有用的会话管理功能 https developers google com analytics devguides collection ios v3 sessions https d
  • 如何在 Dapper 中使用一条 sql 语句传递多条记录进行更新

    我正在尝试使用一个 Update 语句来更新具有不同值的多个记录 我并没有尝试更新许多行以具有相同的值 这非常简单 这就是我现在正在尝试的 using var cn GetOpenConnection get items where we