Upstream/Plan
1
0
Fork 0
mirror of https://github.com/plan-player-analytics/Plan.git synced 2025-02-19 05:41:28 +01:00
Code Issues Projects Releases Wiki Activity

Improved Fetch speed

Browse Source
This commit is contained in:
Rsl1122 2017-09-27 19:31:37 +03:00
parent 6eab68a0ca
commit 3554efb8de
6 changed files with 10 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
Plan/src/main/java/com/djrapitops/plan/database/tables/CommandUseTable.java
View File

@ -85,6 +85,7 @@ public class CommandUseTable extends Table {
columnCommand, columnTimesUsed) columnCommand, columnTimesUsed)
.where(columnServerID + "=" + serverTable.statementSelectServerID) .where(columnServerID + "=" + serverTable.statementSelectServerID)
.toString()); .toString());
statement.setFetchSize(5000);
statement.setString(1, serverUUID.toString()); statement.setString(1, serverUUID.toString());
set = statement.executeQuery(); set = statement.executeQuery();
while (set.next()) { while (set.next()) {

2
Plan/src/main/java/com/djrapitops/plan/database/tables/IPsTable.java
View File

@ -144,7 +144,7 @@ public class IPsTable extends UserIDTable {
" FROM " + tableName + " FROM " + tableName +
" JOIN " + usersTable + " on " + usersIDColumn + "=" + columnUserID " JOIN " + usersTable + " on " + usersIDColumn + "=" + columnUserID
); );
statement.setFetchSize(5000); statement.setFetchSize(50000);
set = statement.executeQuery(); set = statement.executeQuery();
while (set.next()) { while (set.next()) {
UUID uuid = UUID.fromString(set.getString("uuid")); UUID uuid = UUID.fromString(set.getString("uuid"));

4
Plan/src/main/java/com/djrapitops/plan/database/tables/KillsTable.java
View File

@ -167,7 +167,7 @@ public class KillsTable extends UserIDTable {
" JOIN " + usersTable + " on " + usersVictimIDColumn + "=" + columnVictimUserID + " JOIN " + usersTable + " on " + usersVictimIDColumn + "=" + columnVictimUserID +
" JOIN " + usersTable + " a on " + usersKillerIDColumn + "=" + columnKillerUserID); " JOIN " + usersTable + " a on " + usersKillerIDColumn + "=" + columnKillerUserID);
statement.setFetchSize(10000); statement.setFetchSize(50000);
set = statement.executeQuery(); set = statement.executeQuery();
Map<UUID, List<PlayerKill>> allKills = new HashMap<>(); Map<UUID, List<PlayerKill>> allKills = new HashMap<>();
@ -250,7 +250,7 @@ public class KillsTable extends UserIDTable {
" FROM " + tableName + " FROM " + tableName +
" JOIN " + usersTable + " on " + usersIDColumn + "=" + columnVictimUserID); " JOIN " + usersTable + " on " + usersIDColumn + "=" + columnVictimUserID);
statement.setFetchSize(10000); statement.setFetchSize(50000);
set = statement.executeQuery(); set = statement.executeQuery();

3
Plan/src/main/java/com/djrapitops/plan/database/tables/SessionsTable.java
View File

@ -365,6 +365,7 @@ public class SessionsTable extends UserIDTable {
" FROM " + tableName + " FROM " + tableName +
" WHERE " + columnSessionStart + ">?" + " WHERE " + columnSessionStart + ">?" +
" AND " + columnServerID + "=" + serverTable.statementSelectServerID); " AND " + columnServerID + "=" + serverTable.statementSelectServerID);
statement.setFetchSize(1000);
statement.setLong(1, afterDate); statement.setLong(1, afterDate);
statement.setString(2, serverUUID.toString()); statement.setString(2, serverUUID.toString());
set = statement.executeQuery(); set = statement.executeQuery();
@ -533,7 +534,7 @@ public class SessionsTable extends UserIDTable {
" FROM " + tableName + " FROM " + tableName +
" JOIN " + usersTable + " on " + usersIDColumn + "=" + columnUserID + " JOIN " + usersTable + " on " + usersIDColumn + "=" + columnUserID +
" GROUP BY uuid"); " GROUP BY uuid");
statement.setFetchSize(5000); statement.setFetchSize(20000);
set = statement.executeQuery(); set = statement.executeQuery();
Map<UUID, Long> lastSeenMap = new HashMap<>(); Map<UUID, Long> lastSeenMap = new HashMap<>();
while (set.next()) { while (set.next()) {

3
Plan/src/main/java/com/djrapitops/plan/database/tables/TPSTable.java
View File

@ -86,7 +86,7 @@ public class TPSTable extends Table {
statement = prepareStatement(Select.all(tableName) statement = prepareStatement(Select.all(tableName)
.where(columnServerID + "=" + serverTable.statementSelectServerID) .where(columnServerID + "=" + serverTable.statementSelectServerID)
.toString()); .toString());
statement.setFetchSize(20000); statement.setFetchSize(50000);
statement.setString(1, Plan.getServerUUID().toString()); statement.setString(1, Plan.getServerUUID().toString());
set = statement.executeQuery(); set = statement.executeQuery();
while (set.next()) { while (set.next()) {
@ -176,6 +176,7 @@ public class TPSTable extends Table {
.and(columnPlayers + "= (SELECT MAX(" + columnPlayers + ") FROM " + tableName + ")") .and(columnPlayers + "= (SELECT MAX(" + columnPlayers + ") FROM " + tableName + ")")
.and(columnDate + ">= ?") .and(columnDate + ">= ?")
.toString()); .toString());
statement.setFetchSize(1000);
statement.setString(1, serverUUID.toString()); statement.setString(1, serverUUID.toString());
statement.setLong(2, afterDate); statement.setLong(2, afterDate);
set = statement.executeQuery(); set = statement.executeQuery();

3
Plan/src/main/java/com/djrapitops/plan/database/tables/WorldTimesTable.java
View File

@ -182,6 +182,7 @@ public class WorldTimesTable extends UserIDTable {
" WHERE " + sessionServerIDColumn + "=" + db.getServerTable().statementSelectServerID + " WHERE " + sessionServerIDColumn + "=" + db.getServerTable().statementSelectServerID +
" GROUP BY " + columnWorldId " GROUP BY " + columnWorldId
); );
statement.setFetchSize(1000);
statement.setString(1, serverUUID.toString()); statement.setString(1, serverUUID.toString());
set = statement.executeQuery(); set = statement.executeQuery();
String[] gms = GMTimes.getGMKeyArray(); String[] gms = GMTimes.getGMKeyArray();
@ -326,7 +327,7 @@ public class WorldTimesTable extends UserIDTable {
" FROM " + tableName + " FROM " + tableName +
" JOIN " + worldTable + " on " + worldIDColumn + "=" + columnWorldId " JOIN " + worldTable + " on " + worldIDColumn + "=" + columnWorldId
); );
statement.setFetchSize(10000); statement.setFetchSize(50000);
set = statement.executeQuery(); set = statement.executeQuery();
String[] gms = GMTimes.getGMKeyArray(); String[] gms = GMTimes.getGMKeyArray();