chunk writer 中需要对抛错的交易进行回滚,同时又要在其他表中记录是哪一笔交易记录失败

首先根据我有限的知识判断,回滚之后进行写表,该写表动作只能使用listener来进行。

考虑使用的listener有:ItemWriteListener     StepExecutionListener    ChunkListener

我首先使用了ItemWriteListener,在 onWriteError(Exception exception, List items) 方法中对items进行了写表,后来发现被回滚,通过一步一步debug,看到确实该方法之后才是rollback。

所以在该方法中写表是必定被回滚的。不符合我的需求。

Chunk Writer我忘了为什么不用了,它有一个afterChunkError(ChunkContext context)方法,我忘了它会不会被回滚,但是有一点就是它无法取得到底是哪一条记录出错,反正最后我没有使用它

经过仔细思考,我让我的listener类同时实现了ItemWriteListener和StepExecutionListener,并且定义了一个私有变量 private List<Extfundbatchrtxn> list;

然后在onWriteError中将出错的记录放入list,而非立即写表

@Override
    public void onWriteError(Exception exception, List items) {
        // TODO Auto-generated method stub
        list.addAll(items);
        log.debug("onWriteError ,item size: "+items.size());
    }

然后在整个step结束之后再写表

@Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        // TODO Auto-generated method stub
        if(list.size()>0) {
            for (Extfundbatchrtxn extfundbatchrtxn : list) {
                System.out.println("payeeacctnbr: " + extfundbatchrtxn.getPayeeacctnbr()+ "txnstat: " + extfundbatchrtxn.getTxnstat());
                Extfundbatchrtxn record = new Extfundbatchrtxn();
                record.setMseq(extfundbatchrtxn.getMseq());
                record.setExttxnid(extfundbatchrtxn.getExttxnid());
                record.setRtxnsourcecd(extfundbatchrtxn.getRtxnsourcecd());
                record.setTxnstat("F");
                DataAccessManager.getMapper(ExtfundbatchrtxnMapper.class).updateByPrimaryKeySelective(record);
            }
        }
        return null;
    }

哦 对了,onWriteError方法参数中的list包含该批次处理的所有记录,并不仅仅只是出错的那一条。很明显我不能把正常的交易也回滚了,所以我在定义Chunk的时候增加了属性commit-interval = 1 ,这样每个事务只包含一条数据,那么我回滚的肯定也就是出错的那一条数据,记录的也是出错的那一条数据

<chunk reader="extFundRtxnChargeDataProviderReader" writer="extFundRtxnChargeItemWriter" commit-interval="1"/>
时间: 2024-08-01 03:08:32

chunk writer 中需要对抛错的交易进行回滚,同时又要在其他表中记录是哪一笔交易记录失败的相关文章

php中对MYSQL操作之事务控制,回滚

<?php //事务控制,回滚 //创建一个mysqli对象 $mysqli = new MySQLi("主机名","mysql用户名","密码","数据库名"); //判断是否链接成功 if($mysqli->connect_error){ die($mysqli->connect_error); } //由于在事务提交中系统默认提交,故这里设置为FALSE先不提交 $mysqli->autocomm

Spring事务异常回滚,捕获异常不抛出就不会回滚(转载) 解决了我一年前的问题

最近遇到了事务不回滚的情况,我还考虑说JPA的事务有bug? 我想多了.......    为了打印清楚日志,很多方法我都加tyr catch,在catch中打印日志.但是这边情况来了,当这个方法异常时候 日志是打印了,但是加的事务却没有回滚. 例:     类似这样的方法不会回滚 (一个方法出错,另一个方法不会回滚) : if(userSave){ try { userDao.save(user); userCapabilityQuotaDao.save(capabilityQuota); }

spring事物回滚机制 (事务异常回滚,捕获异常不抛出就不会回滚)

当异常被捕获catch的时候,spring的事物则不会回滚 为什么不会滚呢??  spring aop  异常捕获原理:被拦截的方法需显式抛出异常,并不能经任何处理,这样aop代理才能捕获到方法的异常,才能进行回滚,默认情况下aop只捕获runtimeexception的异常: 解决方案: 1.例如service层处理事务,那么service中的方法中不做异常捕获,或者在catch语句中最后增加throw new RuntimeException()语句,以便让aop捕获异常再去回滚,并且在se

Spring事务异常回滚,捕获异常不抛出就不会回滚

最近遇到了事务不回滚的情况,我还考虑说JPA的事务有bug? 我想多了.......    为了打印清楚日志,很多方法我都加tyr catch,在catch中打印日志.但是这边情况来了,当这个方法异常时候 日志是打印了,但是加的事务却没有回滚. 例:     类似这样的方法不会回滚 (一个方法出错,另一个方法不会回滚) : [html] view plain copy if(userSave){ try { userDao.save(user); userCapabilityQuotaDao.s

Mysql数据库一个表字段中存了id,并以逗号分隔,id对应的详细信息在另一个表中

有两张表, 一张为爱好表b表 一张为用户表 u表 u表 id   名称   爱好Id 1    张三     1,2,3,4 2    李四      2,5 b表 id  名称 1    打乒乓 2    打羽毛球 3   打蓝球 4    上网玩游戏 5   打牌 正常查询u表 select * from u 现在需求是: id  名称   爱好 1  张三    打乒乓,打羽毛球,打篮球,上网 2 李四    打羽毛球,打牌 修改sql为 select u.id,u.名称,group_co

springboot 项目中使用@transactional注解不生效导致事务回滚失败问题总结

在常规使用@transactional注解时,如果碰到不生效问题,要首先想到如下几个问题: 1. 如果是有关数据库操作,首先要查看牵涉到的表使用的引擎是什么引擎,要知道使用"MYISAM"数据库引擎是不支持事务回滚操作的,需要使用"InnoDB数据引擎". 2. 查看方法是否是public方法,如果方法是private方法,也是不支持事务的. 3. 如果事务回滚失败还要查看出现的异常是checked异常还是unchecked异常.checked异常会回滚,unche

Service中事务不能回滚的解决方式(转)

1.在service方法里面如果对异常进行了捕获的话,该事务是不会进行回滚的        默认spring事务只在发生未被捕获的 runtimeexcetpion时才回滚.          spring aop  异常捕获原理:被拦截的方法需显式抛出异常,并不能经任何处理,这样aop代理才能捕获到方法的异常,才能进行回滚,默认情况下aop只捕获runtimeexception的异常,但可以通过配置来捕获特定的异常并回滚,换句话说在service的方法中不使用try catch 或者在catc

向SQL Server 现有表中添加新列并添加描述.

注: sql server 2005 及以上支持. 版本估计是不支持(工作环境2005,2008). 工作需要, 需要向SQL Server 现有表中添加新列并添加描述. 从而有个如下存储过程. (先附上存储过程然后解释) 代码 /********调用方法********** 作用: 添加列并添加列描述信息 调用: exec [SetColumnInfo] '表名', '列名', N'列说明,描述','列类型{默认:NVARCHAR(50)}','列默认值{默认:NULL}' *********

关于抛异常事务回滚的测试

TestController.java 代码如下***: /** * 测试异常回滚. * @return */ @RequestMapping(value = "/testExceptionRollBack") @ResponseBody public String testExceptionRollBack() { List<String> idList = Lists.newLinkedList(); idList.add("1111111111")