多线程中更新数据库出现问题

在一个异步调用的方法中使用了更新操作
方法如下

  @Async(value = "downloadExecutor")
    public void handle(SpzwSimpleIllegalData record) {

        if (!downloadVideo(record)) {
            record.setLastDownloadDatetime(DateUtil.getSecondTimestamp(new Date()) + 600 * 15);
            illegalDataService.update(record);
            LOGGER.error("视频下载失败. fileCode:[{}] simpleIllegalDataId:[{}]", record.getFileCode(), record.getId());
            return;
        }

        record.setDownloadVideo(true);
        record.setDownloadVideoDatetime(DateUtil.getTimestamp());
        int count = illegalDataService.updateFields(record, "^(downloadVideo|downloadVideoDatetime|videoUrl1|videoUrl2)$");
}

在日志中count返回了1 但是数据库却没有更新成功偶尔会出现这样子的情况，请问如何避免或者是有什么方法可以实际监听是否已经更新完成了

wendal

1楼•1752天前

加个事务模板包起来

lalala(wx_g9hej6qr60c9sgh4g6dv) 2楼•1752天前

请问哪里有这方面的资料啊找不到唉或者指导一下怎么写啊

lalala(wx_g9hej6qr60c9sgh4g6dv) 3楼•1752天前

使用了Trans.exec 还是会出现那种情况更新不了 sql也执行了放在数据库中是没问题的

wendal

4楼•1752天前

怎么加的？贴代码看看

wendal

5楼•1752天前

单从代码看，不是多线程的问题

这逻辑到底啥意思，get/post分开处理的意思？

wendal

6楼•1752天前

另外，@Async只能保证任务开始执行的顺序FIFO，但执行完成(及内部逻辑)的顺序是没有保证的

wendal

7楼•1752天前

例如请求a/b/c，总是以abc这样的顺序插入线程池，但执行完成的顺序完全不可预知，除非async线程池的线程数设置为1

lalala(wx_g9hej6qr60c9sgh4g6dv) 8楼•1752天前


    @Async(value = "downloadExecutor")
    public void handle(SpzwSimpleIllegalData record) {

        if (!downloadVideo(record)) {
            record.setLastDownloadDatetime(DateUtil.getSecondTimestamp(new Date()) + 600 * 15);
            illegalDataService.update(record);
            LOGGER.error("视频下载失败. fileCode:[{}] simpleIllegalDataId:[{}]", record.getFileCode(), record.getId());
            return;
        }

        Integer result = Trans.exec(new Molecule<Integer>() {
            @Override
            public void run() {
                record.setDownloadVideo(true);
                record.setDownloadVideoDatetime(DateUtil.getTimestamp());
                int count = illegalDataService.updateFields(record, "^(downloadVideo|downloadVideoDatetime|videoUrl1|videoUrl2)$");
                setObj(count);
            }
        });

        LOGGER.info("视频下载成功. -fileCode:[{}] -simpleIllegalDataId:[{}] -downloadDatetime:[{}]   -updateCount:[{}]", record.getFileCode(), record.getId(),record.getDownloadVideoDatetime(),result);
        return;
    }

这是一个定时任务调用的方法，更新语句偶会更新失败

wendal

9楼•1750天前

我觉得不是"更新失败", 是另外一个语句把这个语句的更新内容给覆盖了

lalala(wx_g9hej6qr60c9sgh4g6dv) 10楼•1749天前

另外的语句覆盖了应该是只有两个语句一个是上面的下载失败但是lastDownloadDatetime按理来说应该有值才对，实际没值
更新失败的意思数据还是跟原来的一样唉- -

wendal

11楼•1748天前

updateCount是自增的量? 那要用Chain.makeSpecial/addSpecial来做, 生成的sql 是 updateCount=updateCount+1 形式的

请先登陆