Upstream/Plan
1
0
Fork 0
mirror of https://github.com/plan-player-analytics/Plan.git synced 2024-12-26 02:57:52 +01:00
Code Issues Projects Releases Wiki Activity

Removed WorldTimesTable.Col

Browse Source
This commit is contained in:
Rsl1122 2019-01-24 15:26:58 +02:00
parent dec81cc12f
commit e75fb76906
3 changed files with 69 additions and 101 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
Plan/common/src/main/java/com/djrapitops/plan/db/patches/WorldTimesOptimizationPatch.java
View File

@ -19,7 +19,6 @@ package com.djrapitops.plan.db.patches;
import com.djrapitops.plan.api.exceptions.database.DBOpException;
import com.djrapitops.plan.db.SQLDB;
import com.djrapitops.plan.db.sql.tables.WorldTimesTable;
import com.djrapitops.plan.db.sql.tables.WorldTimesTable.Col;
public class WorldTimesOptimizationPatch extends Patch {
@ -34,9 +33,9 @@ public class WorldTimesOptimizationPatch extends Patch {
@Override
public boolean hasBeenApplied() {
return hasColumn(tableName, Col.ID.get())
&& hasColumn(tableName, Col.UUID.get())
&& hasColumn(tableName, Col.SERVER_UUID.get())
return hasColumn(tableName, WorldTimesTable.ID)
&& hasColumn(tableName, WorldTimesTable.USER_UUID)
&& hasColumn(tableName, WorldTimesTable.SERVER_UUID)
&& !hasColumn(tableName, "user_id")
&& !hasColumn(tableName, "server_id")
&& !hasTable(tempTableName); // If this table exists the patch has failed to finish.
@ -49,23 +48,23 @@ public class WorldTimesOptimizationPatch extends Patch {
db.getWorldTimesTable().createTable();
execute("INSERT INTO " + tableName + " (" +
Col.UUID + ", " +
Col.SERVER_UUID + ", " +
Col.ADVENTURE + ", " +
Col.CREATIVE + ", " +
Col.SURVIVAL + ", " +
Col.SPECTATOR + ", " +
Col.SESSION_ID + ", " +
Col.WORLD_ID +
WorldTimesTable.USER_UUID + ", " +
WorldTimesTable.SERVER_UUID + ", " +
WorldTimesTable.ADVENTURE + ", " +
WorldTimesTable.CREATIVE + ", " +
WorldTimesTable.SURVIVAL + ", " +
WorldTimesTable.SPECTATOR + ", " +
WorldTimesTable.SESSION_ID + ", " +
WorldTimesTable.WORLD_ID +
") SELECT " +
"(SELECT plan_users.uuid FROM plan_users WHERE plan_users.id = " + tempTableName + ".user_id LIMIT 1), " +
"(SELECT plan_servers.uuid FROM plan_servers WHERE plan_servers.id = " + tempTableName + ".server_id LIMIT 1), " +
Col.ADVENTURE + ", " +
Col.CREATIVE + ", " +
Col.SURVIVAL + ", " +
Col.SPECTATOR + ", " +
Col.SESSION_ID + ", " +
Col.WORLD_ID +
WorldTimesTable.ADVENTURE + ", " +
WorldTimesTable.CREATIVE + ", " +
WorldTimesTable.SURVIVAL + ", " +
WorldTimesTable.SPECTATOR + ", " +
WorldTimesTable.SESSION_ID + ", " +
WorldTimesTable.WORLD_ID +
" FROM " + tempTableName
);

2
Plan/common/src/main/java/com/djrapitops/plan/db/patches/WorldTimesSeverIDPatch.java
View File

@ -64,7 +64,7 @@ public class WorldTimesSeverIDPatch extends Patch {
String sql = "UPDATE " + WorldTimesTable.TABLE_NAME + " SET " +
"server_id=?" +
" WHERE " + WorldTimesTable.Col.SESSION_ID + "=?";
" WHERE " + WorldTimesTable.SESSION_ID + "=?";
executeBatch(new ExecStatement(sql) {
@Override

133
Plan/common/src/main/java/com/djrapitops/plan/db/sql/tables/WorldTimesTable.java
View File

@ -30,7 +30,6 @@ import com.djrapitops.plan.db.patches.Version10Patch;
import com.djrapitops.plan.db.patches.WorldTimesOptimizationPatch;
import com.djrapitops.plan.db.patches.WorldTimesSeverIDPatch;
import com.djrapitops.plan.db.patches.WorldsServerIDPatch;
import com.djrapitops.plan.db.sql.parsing.Column;
import com.djrapitops.plan.db.sql.parsing.CreateTableParser;
import com.djrapitops.plan.db.sql.parsing.Sql;
import com.djrapitops.plugin.utilities.Verify;
@ -46,8 +45,6 @@ import java.util.stream.Collectors;
* <p>
* Table Name: plan_world_times
* <p>
* For contained columns {@link Col}
* <p>
* Patches related to this table:
* {@link Version10Patch}
* {@link WorldTimesSeverIDPatch}
@ -79,14 +76,14 @@ public class WorldTimesTable extends Table {
worldTable = db.getWorldTable();
sessionsTable = db.getSessionsTable();
insertStatement = "INSERT INTO " + tableName + " (" +
Col.UUID + ", " +
Col.WORLD_ID + ", " +
Col.SERVER_UUID + ", " +
Col.SESSION_ID + ", " +
Col.SURVIVAL + ", " +
Col.CREATIVE + ", " +
Col.ADVENTURE + ", " +
Col.SPECTATOR +
USER_UUID + ", " +
WORLD_ID + ", " +
SERVER_UUID + ", " +
SESSION_ID + ", " +
SURVIVAL + ", " +
CREATIVE + ", " +
ADVENTURE + ", " +
SPECTATOR +
") VALUES (?, " +
worldTable.statementSelectID + ", " +
"?, ?, ?, ?, ?, ?)";
@ -117,15 +114,15 @@ public class WorldTimesTable extends Table {
String worldIDColumn = worldTable + "." + WorldTable.ID;
String worldNameColumn = worldTable + "." + WorldTable.NAME + " as world_name";
String sql = "SELECT " +
Col.SESSION_ID + ", " +
Col.SURVIVAL + ", " +
Col.CREATIVE + ", " +
Col.ADVENTURE + ", " +
Col.SPECTATOR + ", " +
SESSION_ID + ", " +
SURVIVAL + ", " +
CREATIVE + ", " +
ADVENTURE + ", " +
SPECTATOR + ", " +
worldNameColumn +
" FROM " + tableName +
" INNER JOIN " + worldTable + " on " + worldIDColumn + "=" + Col.WORLD_ID +
" WHERE " + Col.UUID + "=?";
" INNER JOIN " + worldTable + " on " + worldIDColumn + "=" + WORLD_ID +
" WHERE " + USER_UUID + "=?";
query(new QueryStatement<Object>(sql, 2000) {
@Override
@ -138,7 +135,7 @@ public class WorldTimesTable extends Table {
String[] gms = GMTimes.getGMKeyArray();
while (set.next()) {
int sessionID = set.getInt(Col.SESSION_ID.get());
int sessionID = set.getInt(SESSION_ID);
Session session = sessions.get(sessionID);
if (session == null) {
@ -148,10 +145,10 @@ public class WorldTimesTable extends Table {
String worldName = set.getString("world_name");
Map<String, Long> gmMap = new HashMap<>();
gmMap.put(gms[0], set.getLong(Col.SURVIVAL.get()));
gmMap.put(gms[1], set.getLong(Col.CREATIVE.get()));
gmMap.put(gms[2], set.getLong(Col.ADVENTURE.get()));
gmMap.put(gms[3], set.getLong(Col.SPECTATOR.get()));
gmMap.put(gms[0], set.getLong(SURVIVAL));
gmMap.put(gms[1], set.getLong(CREATIVE));
gmMap.put(gms[2], set.getLong(ADVENTURE));
gmMap.put(gms[3], set.getLong(SPECTATOR));
GMTimes gmTimes = new GMTimes(gmMap);
session.getUnsafe(SessionKeys.WORLD_TIMES).setGMTimesForWorld(worldName, gmTimes);
@ -196,17 +193,17 @@ public class WorldTimesTable extends Table {
public WorldTimes getWorldTimesOfServer(UUID serverUUID) {
String worldIDColumn = worldTable + "." + WorldTable.ID;
String worldNameColumn = worldTable + "." + WorldTable.NAME + " as world";
String worldNameColumn = worldTable + "." + WorldTable.NAME + " as world_name";
String sql = "SELECT " +
"SUM(" + Col.SURVIVAL + ") as survival, " +
"SUM(" + Col.CREATIVE + ") as creative, " +
"SUM(" + Col.ADVENTURE + ") as adventure, " +
"SUM(" + Col.SPECTATOR + ") as spectator, " +
"SUM(" + SURVIVAL + ") as survival, " +
"SUM(" + CREATIVE + ") as creative, " +
"SUM(" + ADVENTURE + ") as adventure, " +
"SUM(" + SPECTATOR + ") as spectator, " +
worldNameColumn +
" FROM " + tableName +
" INNER JOIN " + worldTable + " on " + worldIDColumn + "=" + Col.WORLD_ID +
" WHERE " + tableName + "." + Col.SERVER_UUID + "=?" +
" GROUP BY world";
" INNER JOIN " + worldTable + " on " + worldIDColumn + "=" + WORLD_ID +
" WHERE " + tableName + "." + SERVER_UUID + "=?" +
" GROUP BY " + WORLD_ID;
return query(new QueryStatement<WorldTimes>(sql, 1000) {
@Override
@ -220,7 +217,7 @@ public class WorldTimesTable extends Table {
WorldTimes worldTimes = new WorldTimes(new HashMap<>());
while (set.next()) {
String worldName = set.getString("world");
String worldName = set.getString("world_name");
Map<String, Long> gmMap = new HashMap<>();
gmMap.put(gms[0], set.getLong("survival"));
@ -238,17 +235,17 @@ public class WorldTimesTable extends Table {
public WorldTimes getWorldTimesOfUser(UUID uuid) {
String worldIDColumn = worldTable + "." + WorldTable.ID;
String worldNameColumn = worldTable + "." + WorldTable.NAME + " as world";
String worldNameColumn = worldTable + "." + WorldTable.NAME + " as world_name";
String sql = "SELECT " +
"SUM(" + Col.SURVIVAL + ") as survival, " +
"SUM(" + Col.CREATIVE + ") as creative, " +
"SUM(" + Col.ADVENTURE + ") as adventure, " +
"SUM(" + Col.SPECTATOR + ") as spectator, " +
"SUM(" + SURVIVAL + ") as survival, " +
"SUM(" + CREATIVE + ") as creative, " +
"SUM(" + ADVENTURE + ") as adventure, " +
"SUM(" + SPECTATOR + ") as spectator, " +
worldNameColumn +
" FROM " + tableName +
" INNER JOIN " + worldTable + " on " + worldIDColumn + "=" + Col.WORLD_ID +
" WHERE " + Col.UUID + "=?" +
" GROUP BY world";
" INNER JOIN " + worldTable + " on " + worldIDColumn + "=" + WORLD_ID +
" WHERE " + USER_UUID + "=?" +
" GROUP BY " + WORLD_ID;
return query(new QueryStatement<WorldTimes>(sql) {
@Override
@ -262,7 +259,7 @@ public class WorldTimesTable extends Table {
WorldTimes worldTimes = new WorldTimes(new HashMap<>());
while (set.next()) {
String worldName = set.getString("world");
String worldName = set.getString("world_name");
Map<String, Long> gmMap = new HashMap<>();
gmMap.put(gms[0], set.getLong("survival"));
@ -280,16 +277,16 @@ public class WorldTimesTable extends Table {
public Map<Integer, WorldTimes> getAllWorldTimesBySessionID() {
String worldIDColumn = worldTable + "." + WorldTable.ID;
String worldNameColumn = worldTable + "." + WorldTable.NAME + " as world";
String worldNameColumn = worldTable + "." + WorldTable.NAME + " as world_name";
String sql = "SELECT " +
Col.SESSION_ID + ", " +
Col.SURVIVAL + ", " +
Col.CREATIVE + ", " +
Col.ADVENTURE + ", " +
Col.SPECTATOR + ", " +
SESSION_ID + ", " +
SURVIVAL + ", " +
CREATIVE + ", " +
ADVENTURE + ", " +
SPECTATOR + ", " +
worldNameColumn +
" FROM " + tableName +
" INNER JOIN " + worldTable + " on " + worldIDColumn + "=" + Col.WORLD_ID;
" INNER JOIN " + worldTable + " on " + worldIDColumn + "=" + WORLD_ID;
return query(new QueryAllStatement<Map<Integer, WorldTimes>>(sql, 50000) {
@Override
@ -298,15 +295,15 @@ public class WorldTimesTable extends Table {
Map<Integer, WorldTimes> worldTimes = new HashMap<>();
while (set.next()) {
int sessionID = set.getInt(Col.SESSION_ID.get());
int sessionID = set.getInt(SESSION_ID);
String worldName = set.getString("world");
String worldName = set.getString("world_name");
Map<String, Long> gmMap = new HashMap<>();
gmMap.put(gms[0], set.getLong(Col.SURVIVAL.get()));
gmMap.put(gms[1], set.getLong(Col.CREATIVE.get()));
gmMap.put(gms[2], set.getLong(Col.ADVENTURE.get()));
gmMap.put(gms[3], set.getLong(Col.SPECTATOR.get()));
gmMap.put(gms[0], set.getLong(SURVIVAL));
gmMap.put(gms[1], set.getLong(CREATIVE));
gmMap.put(gms[2], set.getLong(ADVENTURE));
gmMap.put(gms[3], set.getLong(SPECTATOR));
GMTimes gmTimes = new GMTimes(gmMap);
WorldTimes worldTOfSession = worldTimes.getOrDefault(sessionID, new WorldTimes(new HashMap<>()));
@ -402,32 +399,4 @@ public class WorldTimesTable extends Table {
return Objects.hash(super.hashCode(), worldTable, sessionsTable, insertStatement);
}
@Deprecated
public enum Col implements Column {
@Deprecated ID("id"),
@Deprecated UUID("uuid"),
@Deprecated SERVER_UUID("server_uuid"),
@Deprecated SESSION_ID("session_id"),
@Deprecated WORLD_ID("world_id"),
@Deprecated SURVIVAL("survival_time"),
@Deprecated CREATIVE("creative_time"),
@Deprecated ADVENTURE("adventure_time"),
@Deprecated SPECTATOR("spectator_time");
private final String column;
Col(String column) {
this.column = column;
}
@Override
public String get() {
return toString();
}
@Override
public String toString() {
return column;
}
}
}