diff --git a/Plan/src/main/java/com/djrapitops/plan/database/tables/CommandUseTable.java b/Plan/src/main/java/com/djrapitops/plan/database/tables/CommandUseTable.java index 31c851de7..e429abcb9 100644 --- a/Plan/src/main/java/com/djrapitops/plan/database/tables/CommandUseTable.java +++ b/Plan/src/main/java/com/djrapitops/plan/database/tables/CommandUseTable.java @@ -85,6 +85,7 @@ public class CommandUseTable extends Table { columnCommand, columnTimesUsed) .where(columnServerID + "=" + serverTable.statementSelectServerID) .toString()); + statement.setFetchSize(5000); statement.setString(1, serverUUID.toString()); set = statement.executeQuery(); while (set.next()) { diff --git a/Plan/src/main/java/com/djrapitops/plan/database/tables/IPsTable.java b/Plan/src/main/java/com/djrapitops/plan/database/tables/IPsTable.java index c6451e381..968575372 100644 --- a/Plan/src/main/java/com/djrapitops/plan/database/tables/IPsTable.java +++ b/Plan/src/main/java/com/djrapitops/plan/database/tables/IPsTable.java @@ -144,7 +144,7 @@ public class IPsTable extends UserIDTable { " FROM " + tableName + " JOIN " + usersTable + " on " + usersIDColumn + "=" + columnUserID ); - statement.setFetchSize(5000); + statement.setFetchSize(50000); set = statement.executeQuery(); while (set.next()) { UUID uuid = UUID.fromString(set.getString("uuid")); diff --git a/Plan/src/main/java/com/djrapitops/plan/database/tables/KillsTable.java b/Plan/src/main/java/com/djrapitops/plan/database/tables/KillsTable.java index 451ab52bf..4633e0d76 100644 --- a/Plan/src/main/java/com/djrapitops/plan/database/tables/KillsTable.java +++ b/Plan/src/main/java/com/djrapitops/plan/database/tables/KillsTable.java @@ -167,7 +167,7 @@ public class KillsTable extends UserIDTable { " JOIN " + usersTable + " on " + usersVictimIDColumn + "=" + columnVictimUserID + " JOIN " + usersTable + " a on " + usersKillerIDColumn + "=" + columnKillerUserID); - statement.setFetchSize(10000); + statement.setFetchSize(50000); set = statement.executeQuery(); Map> allKills = new HashMap<>(); @@ -250,7 +250,7 @@ public class KillsTable extends UserIDTable { " FROM " + tableName + " JOIN " + usersTable + " on " + usersIDColumn + "=" + columnVictimUserID); - statement.setFetchSize(10000); + statement.setFetchSize(50000); set = statement.executeQuery(); diff --git a/Plan/src/main/java/com/djrapitops/plan/database/tables/SessionsTable.java b/Plan/src/main/java/com/djrapitops/plan/database/tables/SessionsTable.java index 0c8ca50c6..b447dc3ec 100644 --- a/Plan/src/main/java/com/djrapitops/plan/database/tables/SessionsTable.java +++ b/Plan/src/main/java/com/djrapitops/plan/database/tables/SessionsTable.java @@ -365,6 +365,7 @@ public class SessionsTable extends UserIDTable { " FROM " + tableName + " WHERE " + columnSessionStart + ">?" + " AND " + columnServerID + "=" + serverTable.statementSelectServerID); + statement.setFetchSize(1000); statement.setLong(1, afterDate); statement.setString(2, serverUUID.toString()); set = statement.executeQuery(); @@ -533,7 +534,7 @@ public class SessionsTable extends UserIDTable { " FROM " + tableName + " JOIN " + usersTable + " on " + usersIDColumn + "=" + columnUserID + " GROUP BY uuid"); - statement.setFetchSize(5000); + statement.setFetchSize(20000); set = statement.executeQuery(); Map lastSeenMap = new HashMap<>(); while (set.next()) { 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 4d3a8d979..a8b5f04f2 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 @@ -86,7 +86,7 @@ public class TPSTable extends Table { statement = prepareStatement(Select.all(tableName) .where(columnServerID + "=" + serverTable.statementSelectServerID) .toString()); - statement.setFetchSize(20000); + statement.setFetchSize(50000); statement.setString(1, Plan.getServerUUID().toString()); set = statement.executeQuery(); while (set.next()) { @@ -176,6 +176,7 @@ public class TPSTable extends Table { .and(columnPlayers + "= (SELECT MAX(" + columnPlayers + ") FROM " + tableName + ")") .and(columnDate + ">= ?") .toString()); + statement.setFetchSize(1000); statement.setString(1, serverUUID.toString()); statement.setLong(2, afterDate); set = statement.executeQuery(); diff --git a/Plan/src/main/java/com/djrapitops/plan/database/tables/WorldTimesTable.java b/Plan/src/main/java/com/djrapitops/plan/database/tables/WorldTimesTable.java index f477e94d6..f31bff8ca 100644 --- a/Plan/src/main/java/com/djrapitops/plan/database/tables/WorldTimesTable.java +++ b/Plan/src/main/java/com/djrapitops/plan/database/tables/WorldTimesTable.java @@ -182,6 +182,7 @@ public class WorldTimesTable extends UserIDTable { " WHERE " + sessionServerIDColumn + "=" + db.getServerTable().statementSelectServerID + " GROUP BY " + columnWorldId ); + statement.setFetchSize(1000); statement.setString(1, serverUUID.toString()); set = statement.executeQuery(); String[] gms = GMTimes.getGMKeyArray(); @@ -326,7 +327,7 @@ public class WorldTimesTable extends UserIDTable { " FROM " + tableName + " JOIN " + worldTable + " on " + worldIDColumn + "=" + columnWorldId ); - statement.setFetchSize(10000); + statement.setFetchSize(50000); set = statement.executeQuery(); String[] gms = GMTimes.getGMKeyArray();