From 6e2acace6c9644047c7eb28ccf1ea2ff216ece2c Mon Sep 17 00:00:00 2001 From: PotatoPresident Date: Fri, 17 Sep 2021 09:26:57 -0700 Subject: [PATCH] Rewrite batched statements in mysql --- .../LedgerDatabaseExtension.kt | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/src/main/kotlin/net.quiltservertools.ledger.databases/LedgerDatabaseExtension.kt b/src/main/kotlin/net.quiltservertools.ledger.databases/LedgerDatabaseExtension.kt index ad7e6db..95f5481 100644 --- a/src/main/kotlin/net.quiltservertools.ledger.databases/LedgerDatabaseExtension.kt +++ b/src/main/kotlin/net.quiltservertools.ledger.databases/LedgerDatabaseExtension.kt @@ -14,10 +14,17 @@ class LedgerDatabaseExtension : DatabaseExtension { override fun getDatabase(server: MinecraftServer): Database { if (Ledger.config[DatabaseExtensionSpec.h2]) { - return Database.connect("jdbc:h2:${server.getSavePath(WorldSavePath.ROOT).resolve("ledger.h2").toFile()};MODE=MySQL", "org.h2.Driver") + return Database.connect( + url = "jdbc:h2:${server.getSavePath(WorldSavePath.ROOT).resolve("ledger.h2").toFile()};MODE=MySQL", + driver = "org.h2.Driver" + ) } else if (Ledger.config[DatabaseExtensionSpec.mySql]) { - return Database.connect("jdbc:mysql://${Ledger.config[DatabaseExtensionSpec.url]}", driver = "com.mysql.cj.jdbc.Driver", - user = Ledger.config[DatabaseExtensionSpec.userName], password = Ledger.config[DatabaseExtensionSpec.password]) + return Database.connect( + url = "jdbc:mysql://${Ledger.config[DatabaseExtensionSpec.url]}?rewriteBatchedStatements=true", + driver = "com.mysql.cj.jdbc.Driver", + user = Ledger.config[DatabaseExtensionSpec.userName], + password = Ledger.config[DatabaseExtensionSpec.password] + ) } return sqlite(server) }