Upstream/Plan
1
0
Fork 0
mirror of https://github.com/plan-player-analytics/Plan.git synced 2024-10-06 02:17:39 +02:00
Code Issues Projects Releases Wiki Activity

Refactored WorldTable#saveWorlds to an executable

Browse Source
This commit is contained in:
Rsl1122 2019-01-25 11:41:39 +02:00
parent d0d645d09a
commit 40a1325c48
3 changed files with 26 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
Plan/common/src/main/java/com/djrapitops/plan/db/access/transactions/BackupCopyTransaction.java
View File

@ -98,7 +98,7 @@ public class BackupCopyTransaction extends RemoveEverythingTransaction {
}
private void copyWorlds() {
db.getWorldTable().saveWorlds(sourceDB.query(LargeFetchQueries.fetchAllWorldNames()));
copy(LargeStoreQueries::storeAllWorldNames, LargeFetchQueries.fetchAllWorldNames());
}
private void copyUsers() {

20
Plan/common/src/main/java/com/djrapitops/plan/db/sql/queries/LargeStoreQueries.java
View File

@ -274,4 +274,24 @@ public class LargeStoreQueries {
}
};
}
public static Executable storeAllWorldNames(Map<UUID, Collection<String>> ofServers) {
if (Verify.isEmpty(ofServers)) {
return Executable.empty();
}
return new ExecBatchStatement(WorldTable.INSERT_STATEMENT) {
@Override
public void prepare(PreparedStatement statement) throws SQLException {
for (Map.Entry<UUID, Collection<String>> entry : ofServers.entrySet()) {
UUID serverUUID = entry.getKey();
for (String world : entry.getValue()) {
statement.setString(1, world);
statement.setString(2, serverUUID.toString());
statement.addBatch();
}
}
}
};
}
}

32
Plan/common/src/main/java/com/djrapitops/plan/db/sql/tables/WorldTable.java
View File

@ -51,6 +51,10 @@ public class WorldTable extends Table {
public static final String ID = "id";
public static final String SERVER_UUID = "server_uuid";
public static final String NAME = "world_name";
public static final String INSERT_STATEMENT = "INSERT INTO " + TABLE_NAME + " ("
+ NAME + ", "
+ SERVER_UUID
+ ") VALUES (?, ?)";
public final String statementSelectID;
private final ServerTable serverTable;
@ -99,27 +103,6 @@ public class WorldTable extends Table {
});
}
public void saveWorlds(Map<UUID, Collection<String>> worldMap) {
String sql = "INSERT INTO " + tableName + " ("
+ NAME + ", "
+ SERVER_UUID
+ ") VALUES (?, ?)";
executeBatch(new ExecStatement(sql) {
@Override
public void prepare(PreparedStatement statement) throws SQLException {
for (Map.Entry<UUID, Collection<String>> entry : worldMap.entrySet()) {
UUID serverUUID = entry.getKey();
for (String world : entry.getValue()) {
statement.setString(1, world);
statement.setString(2, serverUUID.toString());
statement.addBatch();
}
}
}
});
}
public void saveWorlds(Collection<String> worlds) {
saveWorlds(worlds, getServerUUID());
}
@ -141,12 +124,7 @@ public class WorldTable extends Table {
return;
}
String sql = "INSERT INTO " + tableName + " ("
+ NAME + ", "
+ SERVER_UUID
+ ") VALUES (?, ?)";
executeBatch(new ExecStatement(sql) {
executeBatch(new ExecStatement(INSERT_STATEMENT) {
@Override
public void prepare(PreparedStatement statement) throws SQLException {
for (String world : worldsToSave) {