Jooq 使用 MySql 中的记录批量更新

Question

使用 JOOQ 进行批量更新的正确方法是什么？

我有以下几点：

public void updateScores(Map<String, Integer> teamScores) {
    writeContext().transaction(config -> {
        DSLContext dslContext = DSL.using(config);
        dslContext.batchUpdate(Maps.transformEntries(teamScores, (id, score) -> {
            TeamScoresRecord record = new TeamScoresRecord();
            record.setTeamId(id);
            record.setScore(score);
            return record;
        }).values()).execute();
    });
}

或

public void updateScores(Map<String, Integer> teamScores) {
    writeContext().transaction(config -> {
        DSLContext dslContext = DSL.using(config);
        dslContext.batchUpdate(
                dslContext.selectFrom(TEAM_SCORES)
                          .where(TEAM_SCORES.TEAM_ID.in(teamScores.keySet()))
                          .forUpdate()
                          .fetch()
                          .stream()
                          .peek(record -> record.setScore(teamScores.get(record.getTeamId())))
                          .collect(Collectors.toList())
        ).execute();
    });
}

建议使用以下哪种方式进行批量更新？

Answer 1

这个问题显然很主观，不容易回答。以下是一些观察结果：

• 即使在 jOOQ 中使用批处理 API，您也会运行大量单独的查询，这会产生相当多的客户端/服务器开销。在您的特定情况下这可能很好，但考虑将整个逻辑移入数据库通常不是一个坏主意，例如通过将地图插入到临时表中，然后使用批量 UPDATE 语句合并两个数据集
• 如果两个冲突的批次以不同的顺序更新相同的记录，则两个批次都可能导致数据库死锁。我不确定这是否是您的代码中的问题，但您可能希望确保这永远不会发生。
• 第一种方法将运行一个较少的查询（SELECT 查询，这可能非常昂贵，具体取决于 in-list 的大小）。但是，如果没有 FOR UPDATE 子句，第一种方法可能具有更高的死锁风险。
• 第一种方法可能会运行比必要更多的更新语句，例如用于同时删除的ID 值。第二种方法可以防止这种情况发生

现在，我不太了解 MySQL，无法知道批量更新语句在这里是否会更好，即这样的语句：

UPDATE team_scores
SET score = CASE id
  WHEN :id1 THEN :score1
  WHEN :id2 THEN :score2
  WHEN :id3 THEN :score3
  ...
END
WHERE id IN (:id1, :id2, :id3, ...)

也许您可以对这种方法进行基准测试并将其与批处理进行比较（或将其与批处理相结合，例如批量更新 10 行并批量处理所有这些批量更新）