Spring JdbcTemplate 错误处理批量更新

2024-01-20

我正在尝试使用batchUpdate 更新表中的数千行。我的要求是:

1)假设一个批次有1000条记录。 235 号记录导致错误。如何找出导致错误的记录。

2) 假设记录 600 没有导致更新(原因可能是没有记录匹配 where 子句)。如何找出未更新的记录。

3)在上述两种情况下,我如何继续处理剩余的记录。


经过长时间的搜索和调试后,唯一的解决方案是转到 BatchUpdateException 类并找到负元素并从 MAP 中推断出错误插入的值。

import java.sql.BatchUpdateException;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.List;
import java.util.Map;


import org.springframework.jdbc.core.BatchPreparedStatementSetter;
import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;


@Transactional(propagation = Propagation.REQUIRED, rollbackFor = Exception.class)
@Repository("dao_")
public class YouDao extends CommunDao implements IyouDao {

    public void bulkInsert(final List<Map<String, String>> map)
            throws BusinessException { 
        try {

            String sql = " insert into  your_table " + "(  aa,bb  )"
                    + "values " + "(  ?,? )";
            BatchPreparedStatementSetter batchPreparedStatementSetter = new BatchPreparedStatementSetter() {
                @Override
                public void setValues(PreparedStatement ps, int i)
                        throws SQLException {
                    Map<String, String> bean = map.get(i);

                    ps.setString(1, bean.get("aa"));
                    ps.setString(2, bean.get("bb")); 
                    //..
                    //..

                }

                @Override
                public int getBatchSize() {
                    return map.size();
                }
            };

             getJdbcTemplate().batchUpdate(sql, batchPreparedStatementSetter);

        }

        catch (Exception e) {
            if (e.getCause() instanceof BatchUpdateException) {
                BatchUpdateException be = (BatchUpdateException) e.getCause();
                int[] batchRes = be.getUpdateCounts();
                if (batchRes != null && batchRes.length > 0) {
                    for (int index = 0; index < batchRes.length; index++) {
                        if (batchRes[index] == Statement.EXECUTE_FAILED) {
                            logger.error("Error execution >>>>>>>>>>>"
                                    + index + " --- , codeFail : " + batchRes[index]
                                    + "---, line " + map.get(index));
                        }
                    }
                }
            }  
            throw new BusinessException(e);
        }

    }

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

Spring JdbcTemplate 错误处理批量更新 的相关文章

随机推荐

  • C++ 编译时子字符串

    我有非常大的代码库 它使用 FILE 广泛用于日志记录 但是 它包含完整路径 这是 1 不需要的 2 可能会发生安全违规 我正在尝试编写编译时子字符串表达式 最终以这个解决方案 https blog galowicz de 2016 02
  • 高级类型的辅助模式

    编辑 这是问题的一个更简单的表述 使用Foo作为一个例子Aux模式其中does work Foo is a simple Aux pattern type trait Foo A B type Out object Foo type Aux
  • Python 的“unittest”缺少“assertHasAttr”方法,我应该使用什么来代替?

    在众多的断言方法中Python的标准unittest package https docs python org 3 library unittest html assertHasAttr 奇怪的是缺席了 在编写一些单元测试时 我遇到了一种
  • 防止对 PHP 的虚假循环 ajax 请求

    在我的网站上 我为博客文章创建了评论部分 用户可以编写评论 单击按钮 AJAX 请求将发送到包含 JSON 数据的 PHP PHP 将处理和验证数据 然后将其插入数据库 成功后 将从数据库中检索所有评论 并使用 JQuery 重新加载页面的
  • 将 MySQL 数据库移动到远程服务器后,“用户访问被拒绝”

    我在访问数据库时遇到一些问题 该脚本之前在我的本地主机上运行过 我将其导入到另一台服务器中 另一台服务器给我一条访问被拒绝的消息 给出的消息是 Access denied for user root 10 4 1 163 using pas
  • 对 USB 传输电缆进行编程/与 USB 设备驱动程序通信

    如何以编程方式访问 USB 传输电缆 例如 Belkin 的易传输电缆 http www belkin com easytransfercable 从Windows 我熟悉libusb win32 http libusb win32 sou
  • 如何显示eclipse项目类型

    在 Eclipse IDE 中 有图标显示项目类型 但我找不到文字描述 我希望右键单击 gt 属性来显示此信息 但根据此所有项目都是 项目 类型 即使它们是 java 项目或 Maven 项目等 有人知道吗 Thanks 根据 您不会在 E
  • 如何使用 TELETHON 按日期获取消息?

    如何获取今天发布的消息TELETHON 我正在使用下面的代码 date of post datetime datetime 2019 12 24 with TelegramClient name api id api hash as cli
  • 如何优化 R 中词干提取和拼写检查的性能?

    我有大约 1 400 万个文档 每个文档的平均字符数为 中位数 250 和平均值 470 我想在对它们进行分类之前执行拼写检查和词干提取 模拟文档 sentence lt We aree drivng as fast as we drove
  • WPF 4:DataGridColumnHeader 发生了什么?

    DataGridColumnHeader 发生了什么 看起来当 DataGrid 移至PresentationFramework 时它已被删除 DataGridColumnHeader http msdn microsoft com en
  • 汇编程序如何将 x86 指令助记符映射到二进制机器指令?

    我对编写 x86 汇编程序感兴趣 我想知道将 x86 汇编助记符指令 使用类似 Intel 的语法 映射到相应的二进制机器代码指令的好方法是什么 您想了解助记符到机器代码的物理映射吗 如果是这样 则第 2A 卷和第 2B 卷英特尔 IA32
  • 我可以将字符串映射到java中的方法吗?

    我正在用 Java 编写一个表达式计算器 我希望能够添加更多运算符 我目前只有 和 目前 我的代码如下所示 case return a b case return a b case return a b 这适用于我的代码 因为我只有几个运算
  • git 可以提交新的非空文件的“空版本”吗?

    git 可以提交某些文件的空版本吗 恰当的例子是 我需要首先添加新的 未跟踪的 非空文件并提交为empty文件 以便将其内容标记为新内容并进行审查 完整的 未跟踪的文件应not被添加到索引中 git diff应通过将文件与其提交的空版本进行
  • Facebook 页面默认登陆选项卡

    我有一个 Facebook 页面 我将默认登录页面设置为自定义选项卡 如果用户不喜欢该页面 这很有效 如果用户喜欢该页面 则登陆页面始终是墙 有什么方法可以确保您的自定义选项卡始终是登录页面 无论用户是否喜欢您的页面 Example htt
  • Jquery Select2 插件版本检查

    在我的项目中 我检查 Select2 插件是否以这种方式加载 if jQuery select2 但现在我将尝试验证加载了 Select2 插件的版本 3 5 X 或 4 X 我想也许你可以检查一下 4 X 版本中引入的选项 功能是否在 3
  • 从包内加载mathematica包

    我或多或少有以下设置 在 path to my packages我有两个包裹package1 m and package2 m 每个包的概要如下 BeginPackage package1 Unprotect Names package1
  • numpy.linalg.inv 如何计算正交矩阵的逆?

    我正在实施一个LinearTransformation类 继承自numpy matrix和用途numpy matrix I计算变换矩阵的逆 有谁知道 numpy 在尝试计算逆矩阵之前是否检查矩阵的正交性 我问这个问题是因为我的大多数矩阵 但
  • 使用 pandas df.plot 在子图上绘制多条线

    有没有一种方法可以在一个图上绘制多个数据框列 并为数据框绘制多个子图 例如 如果 df 有 12 个数据列 则在子图 1 上绘制第 1 3 列 子图 2 第 4 6 列等 我了解如何使用 df plot 为每一列创建一个子图 但不确定如何按
  • 在django中将图像和缩略图存储在s3上

    我正在尝试使用 django storages boto 和 sorl thumbnail 将图像缩略图存储在 s3 上 我可以使用它 但是即使图像很小 速度也很慢 我不介意当我保存表单并将图像上传到 s3 时速度很慢 但我希望它在那之后能
  • Spring JdbcTemplate 错误处理批量更新

    我正在尝试使用batchUpdate 更新表中的数千行 我的要求是 1 假设一个批次有1000条记录 235 号记录导致错误 如何找出导致错误的记录 2 假设记录 600 没有导致更新 原因可能是没有记录匹配 where 子句 如何找出未更