diff --git a/Plan/src/main/java/com/djrapitops/plan/database/DBUtils.java b/Plan/src/main/java/com/djrapitops/plan/database/DBUtils.java index 05ea524e1..b34d39eed 100644 --- a/Plan/src/main/java/com/djrapitops/plan/database/DBUtils.java +++ b/Plan/src/main/java/com/djrapitops/plan/database/DBUtils.java @@ -19,6 +19,8 @@ import java.util.Map.Entry; */ public class DBUtils { + private static final int BATCH_SIZE = 10192; + /** * Constructor used to hide the public constructor */ @@ -26,8 +28,6 @@ public class DBUtils { throw new IllegalStateException("Utility class"); } - private static final int BATCH_SIZE = 10192; - /** * Splits a collection of objects into lists with the size defined by * BATCH_SIZE. diff --git a/Plan/src/main/java/com/djrapitops/plan/database/tables/TPSTable.java b/Plan/src/main/java/com/djrapitops/plan/database/tables/TPSTable.java index 92ba3c432..c63d9f8dc 100644 --- a/Plan/src/main/java/com/djrapitops/plan/database/tables/TPSTable.java +++ b/Plan/src/main/java/com/djrapitops/plan/database/tables/TPSTable.java @@ -117,17 +117,15 @@ public class TPSTable extends Table { * @param data * @throws SQLException */ - public void saveTPSData(List data) throws SQLException { + public void saveTPSData(List data) { List> batches = DBUtils.splitIntoBatches(data); - batches.stream() - .forEach(batch -> { - try { - saveTPSBatch(batch); - } catch (SQLException e) { - Log.toLog("UsersTable.saveUserDataInformationBatch", e); - } - }); - commit(); + batches.forEach(batch -> { + try { + saveTPSBatch(batch); + } catch (SQLException e) { + Log.toLog("UsersTable.saveUserDataInformationBatch", e); + } + }); } private void saveTPSBatch(List batch) throws SQLException {