在java中以多线程方式插入或更新数据库中的多条记录

Question

我正在更新数据库中的多条记录。现在，每当 UI 发送要更新的记录列表时，我只需更新数据库中的这些记录。我正在为此使用 JDBC 模板。

早期案例

早先，每当我从 UI 获取记录时，我都会这样做

jdbcTemplate.batchUpdate(Query, List<object[]> params)

每当出现异常时，我都会回滚整个事务。

（已更新：batchUpdate 是多线程的还是在某些方面比批处理更新更快？）

后期案例

但后来每当出现异常时，需求就会发生变化。因此，每当出现异常时，我应该知道哪些记录未能更新。所以我不得不将记录发送回 UI，以防出现异常并说明为什么失败。

所以我不得不做类似的事情：

for(Record record : RecordList)
{
   try{
       jdbcTemplate.update(sql, Object[] param)
   }catch(Exception ex){
       record.setReason("Exception : "+ex.getMessage());
       continue;
   }
}

那么我是否以正确的方式通过使用循环来执行此操作？

如果是，有人可以建议我如何使其成为多线程。 或者在这种情况下有什么问题。 说实话，我很犹豫在循环中使用 try catch 块:(。

请指正，真的需要学习更好的方法，因为我自己觉得，一定有更好的方法，谢谢。

Answer 1

将所有更新操作设为可调用集合， 将其发送到 java.util.concurrent.ThreadPoolExecutor。池是多线程的。

使可调用：

class UpdateTask implements Callable<Exception> {
  //constructor with jdbctemplate,sql,param goes here.
  @Override
    public Exception call() throws Exception {
        try{
              jdbcTemplate.update(sql, Object[] param)
            }catch(Exception ex){
                   return ex;
           }

        return null;
    }

调用调用：

<T> List<Future<T>> java.util.concurrent.ExecutorService.invokeAll(Collection<? extends Callable<T>> tasks) throws InterruptedException

Answer 2

您的情况看起来您需要在java中使用验证并单独过滤掉有效数据并发送到数据库进行更新。

BO layer
-> filter out the Valid Record.
-> Invalid Record should be send back with some validation text.

在 DAO 层
-> 批量更新您的 RecordList

这将为您提供最佳性能。

永远不要使用数据库插入异常作为验证机制。

1. 异常代价高昂，因为必须创建堆栈跟踪
2. 与数据库的连接是另一个成本高昂的过程，需要花费一些时间才能建立连接
3. Java If-Else 在相同的数据库验证中运行得更快