Skip to content

Commit d2cdf78

Browse files
disabled autocommit
1 parent 47369cc commit d2cdf78

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

src/main/java/net/javadiscord/javabot/data/h2db/message_cache/dao/MessageCacheRepository.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -44,12 +44,14 @@ public void insertList(@NotNull List<CachedMessage> messages) throws SQLExceptio
4444
try (PreparedStatement stmt = con.prepareStatement("MERGE INTO message_cache (message_id, author_id, message_content) VALUES (?, ?, ?)",
4545
Statement.RETURN_GENERATED_KEYS
4646
)) {
47+
con.setAutoCommit(false);
4748
for (CachedMessage msg : messages) {
4849
stmt.setLong(1, msg.getMessageId());
4950
stmt.setLong(2, msg.getAuthorId());
5051
stmt.setString(3, msg.getMessageContent());
5152
stmt.executeUpdate();
5253
}
54+
con.commit();
5355
}
5456
}
5557

0 commit comments

Comments
 (0)