Spring Boot-通过JPQL UPDATE查询批量更新数十万个对象？

Question

我正在使用具有HiberNate的Spring Boot1.5.2。

我有一个对象列表。每个对象都包含许多属性和@OneTo许多关系（即从数据库中获取此对象并将此对象更新到数据库需要很长时间）。

这就是我使用自定义 JPQL 查询的原因：

• 一个用于加载对象列表的基本属性
• 一个用于更新对象所需的属性

@Entity
@Table(name = coverage)
@Inheritance(strategy = InheritanceType.JOINED)
public class Coverage implements Serializable {
    @Id
    @JsonIgnore
    @Column(name = COLUMN_ID)
    @GeneratedValue(strategy = GenerationType.AUTO)
    protected long id;

    @Column(name = "coverage_id", unique = true)
    protected String coverageId;

    ... many more properties
}

我从CrudRepository扩展了这个方法，用于获取对象列表(只有所需的属性)

@Transactional
public interface CoverageRepository extends CrudRepository<Coverage, String> {
    @Query("Select id, coverageId from Coverage")
    List<Object[]> readAllCoverageIdsAndTypes();

    @Modifying
    @Query("update Coverage set coverageId = :coverageId where id = :id")
    void saveCoverage(@Param("id") long id, @Param("coverageId") String coverageId);
}

现在，我想通过以下公式更新每个Coverage对象的coverageId：

newCoverageId = coverageId + randomString.

因此，我有一个覆盖范围对象列表，其中包含更新的coverageId。有10万个物体。

我做的事情非常缓慢：

    @Autowired
    CoverageRepository coverageRepository;
   
    @Transactional
    public void saveAllCoverages(List<Coverage> coverages) {
        for(Coverage coverage : coverages) {
           long id = coverage.getId();
           String newCoverageId = coverage.getCoverageId();
           this.coverageRepository.saveCoverage(id, newCoverageId);
        }
    }

性能很差，因为HiberNate每次迭代都会发送一个UPDATE查询。我如何让它更快？我想每个事务向postgreql发送100个查询，例如（批量更新）。

Answer 1

您可以使用ExecutorService。这里有完整的描述。

ExecutorService是一个JDK API，它简化了异步模式下的运行任务。一般来说，ExecutorService会自动提供一个线程池和一个为其分配任务的API。创建ExecutorService最简单的方法是使用Executors类的工厂方法之一。

例如，以下代码行将创建一个包含10个线程的线程池：

ExecutorService executorService = Executors.newFixedThreadPool(10); //init

executorService.execute(() -> YOUR_WORK_HERE);//usage