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

Refactored WorldTable

Browse Source
This commit is contained in:
Rsl1122 2017-10-06 17:33:57 +03:00
parent 94ba4fa0e9
commit 5433116cdb
1 changed files with 26 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

55
Plan/src/main/java/com/djrapitops/plan/database/tables/WorldTable.java
View File

@ -3,10 +3,11 @@ package main.java.com.djrapitops.plan.database.tables;
import com.djrapitops.plugin.utilities.Verify;
import main.java.com.djrapitops.plan.api.exceptions.DBCreateTableException;
import main.java.com.djrapitops.plan.database.databases.SQLDB;
import main.java.com.djrapitops.plan.database.processing.ExecStatement;
import main.java.com.djrapitops.plan.database.processing.QueryAllStatement;
import main.java.com.djrapitops.plan.database.sql.Sql;
import main.java.com.djrapitops.plan.database.sql.TableSqlParser;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
@ -25,7 +26,6 @@ public class WorldTable extends Table {
public final String statementSelectID;
private final String columnWorldId = "id";
private final String columnWorldName = "world_name";
private final String columnServerID = "server_id";
/**
* Constructor.
@ -55,20 +55,19 @@ public class WorldTable extends Table {
* @throws SQLException Database error occurs.
*/
public List<String> getWorlds() throws SQLException {
PreparedStatement statement = null;
ResultSet set = null;
try (Connection connection = getConnection()) {
statement = connection.prepareStatement("SELECT * FROM " + tableName);
set = statement.executeQuery();
List<String> worldNames = new ArrayList<>();
while (set.next()) {
String worldName = set.getString(columnWorldName);
worldNames.add(worldName);
String sql = "SELECT * FROM " + tableName;
return query(new QueryAllStatement<List<String>>(sql) {
@Override
public List<String> processResults(ResultSet set) throws SQLException {
List<String> worldNames = new ArrayList<>();
while (set.next()) {
String worldName = set.getString(columnWorldName);
worldNames.add(worldName);
}
return worldNames;
}
return worldNames;
} finally {
close(set, statement);
}
});
}
/**
@ -89,21 +88,19 @@ public class WorldTable extends Table {
return;
}
PreparedStatement statement = null;
try (Connection connection = getConnection()) {
statement = connection.prepareStatement("INSERT INTO " + tableName + " ("
+ columnWorldName
+ ") VALUES (?)");
for (String world : worldsToSave) {
statement.setString(1, world);
statement.addBatch();
}
String sql = "INSERT INTO " + tableName + " ("
+ columnWorldName
+ ") VALUES (?)";
statement.executeBatch();
commit(connection);
} finally {
close(statement);
}
executeBatch(new ExecStatement(sql) {
@Override
public void prepare(PreparedStatement statement) throws SQLException {
for (String world : worldsToSave) {
statement.setString(1, world);
statement.addBatch();
}
}
});
}
public String getColumnID() {