From 6eafce05ba571db68d323b6aa68adeb3512d0f9b Mon Sep 17 00:00:00 2001 From: Rsl1122 Date: Sat, 16 Feb 2019 14:01:41 +0200 Subject: [PATCH] Removed TPSTable#getNetworkOnlineData - not used --- .../containers/NetworkContainerQuery.java | 11 +++--- .../plan/db/sql/tables/TPSTable.java | 39 ------------------- 2 files changed, 6 insertions(+), 44 deletions(-) diff --git a/Plan/common/src/main/java/com/djrapitops/plan/db/access/queries/containers/NetworkContainerQuery.java b/Plan/common/src/main/java/com/djrapitops/plan/db/access/queries/containers/NetworkContainerQuery.java index 1afdfdf49..dd8dae581 100644 --- a/Plan/common/src/main/java/com/djrapitops/plan/db/access/queries/containers/NetworkContainerQuery.java +++ b/Plan/common/src/main/java/com/djrapitops/plan/db/access/queries/containers/NetworkContainerQuery.java @@ -23,6 +23,7 @@ import com.djrapitops.plan.data.store.keys.ServerKeys; import com.djrapitops.plan.db.SQLDB; import com.djrapitops.plan.db.access.Query; import com.djrapitops.plan.db.access.queries.objects.ServerQueries; +import com.djrapitops.plan.db.access.queries.objects.TPSQueries; import com.djrapitops.plan.system.info.server.Server; import java.util.Optional; @@ -45,17 +46,17 @@ import java.util.stream.Collectors; */ public class NetworkContainerQuery implements Query { - private static Query getBungeeServerContainer() { + private static Query getProxyServerContainer() { return db -> { Optional proxyInformation = db.query(ServerQueries.fetchProxyServerInformation()); if (!proxyInformation.isPresent()) { return new ServerContainer(); } - UUID serverUUID = proxyInformation.get().getUuid(); - ServerContainer container = db.query(ContainerFetchQueries.fetchServerContainer(serverUUID)); + UUID proxyUUID = proxyInformation.get().getUuid(); + ServerContainer container = db.query(ContainerFetchQueries.fetchServerContainer(proxyUUID)); container.putCachingSupplier(ServerKeys.PLAYERS, () -> db.query(ContainerFetchQueries.fetchAllPlayerContainers())); - container.putCachingSupplier(ServerKeys.TPS, db.getTpsTable()::getNetworkOnlineData); + container.putCachingSupplier(ServerKeys.TPS, () -> db.query(TPSQueries.fetchTPSDataOfServer(proxyUUID))); container.putSupplier(ServerKeys.WORLD_TIMES, null); // Additional Session information not supported container.putSupplier(ServerKeys.PLAYER_KILLS, null); container.putSupplier(ServerKeys.PLAYER_KILL_COUNT, null); @@ -66,7 +67,7 @@ public class NetworkContainerQuery implements Query { @Override public NetworkContainer executeQuery(SQLDB db) { - ServerContainer bungeeContainer = db.query(getBungeeServerContainer()); + ServerContainer bungeeContainer = db.query(getProxyServerContainer()); NetworkContainer networkContainer = db.getNetworkContainerFactory().forBungeeContainer(bungeeContainer); networkContainer.putCachingSupplier(NetworkKeys.BUKKIT_SERVERS, () -> db.query(ServerQueries.fetchPlanServerInformation()).values() diff --git a/Plan/common/src/main/java/com/djrapitops/plan/db/sql/tables/TPSTable.java b/Plan/common/src/main/java/com/djrapitops/plan/db/sql/tables/TPSTable.java index 6a2ab910e..f86e4f3d3 100644 --- a/Plan/common/src/main/java/com/djrapitops/plan/db/sql/tables/TPSTable.java +++ b/Plan/common/src/main/java/com/djrapitops/plan/db/sql/tables/TPSTable.java @@ -21,15 +21,12 @@ import com.djrapitops.plan.data.container.builders.TPSBuilder; import com.djrapitops.plan.db.DBType; import com.djrapitops.plan.db.SQLDB; import com.djrapitops.plan.db.access.QueryAllStatement; -import com.djrapitops.plan.db.access.QueryStatement; -import com.djrapitops.plan.db.access.queries.objects.ServerQueries; import com.djrapitops.plan.db.sql.parsing.CreateTableParser; import com.djrapitops.plan.db.sql.parsing.Sql; import com.djrapitops.plan.system.info.server.Server; import com.djrapitops.plugin.api.TimeAmount; import org.apache.commons.text.TextStringBuilder; -import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.*; @@ -88,42 +85,6 @@ public class TPSTable extends Table { .toString(); } - public List getNetworkOnlineData() { - Optional proxyInfo = db.query(ServerQueries.fetchProxyServerInformation()); - if (!proxyInfo.isPresent()) { - return new ArrayList<>(); - } - UUID bungeeUUID = proxyInfo.get().getUuid(); - - String sql = "SELECT " + - DATE + ", " + - PLAYERS_ONLINE + - " FROM " + TABLE_NAME + - " WHERE " + SERVER_ID + "=" + ServerTable.STATEMENT_SELECT_SERVER_ID; - - return query(new QueryStatement>(sql, 50000) { - @Override - public void prepare(PreparedStatement statement) throws SQLException { - statement.setString(1, bungeeUUID.toString()); - } - - @Override - public List processResults(ResultSet set) throws SQLException { - List tpsList = new ArrayList<>(); - while (set.next()) { - - TPS tps = TPSBuilder.get() - .date(set.getLong(DATE)) - .playersOnline(set.getInt(PLAYERS_ONLINE)) - .toTPS(); - - tpsList.add(tps); - } - return tpsList; - } - }); - } - public Map> getPlayersOnlineForServers(Collection servers) { if (servers.isEmpty()) { return new HashMap<>();