Upstream/ShopChest-Updated
1
0
Fork 0
mirror of https://github.com/Flowsqy/ShopChest.git synced 2024-11-26 01:05:12 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

Add convenience methods for database versioning

Browse Source
This commit is contained in:
Eric 2019-06-16 17:54:55 +02:00
parent bc284a0717
commit 27083e5093
1 changed files with 34 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

42
src/main/java/de/epiceric/shopchest/sql/Database.java
View File

@ -36,8 +36,6 @@ import java.util.UUID;
import com.zaxxer.hikari.HikariDataSource; import com.zaxxer.hikari.HikariDataSource;
public abstract class Database { public abstract class Database {
private static final int DATABASE_VERSION = 2;
private final Set<String> notFoundWorlds = new HashSet<>(); private final Set<String> notFoundWorlds = new HashSet<>();
private final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); private final SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
@ -65,9 +63,30 @@ public abstract class Database {
abstract String getQueryGetTable(); abstract String getQueryGetTable();
private int getDatabaseVersion() throws SQLException {
try (Connection con = dataSource.getConnection()) {
try (Statement s = con.createStatement()) {
ResultSet rs = s.executeQuery("SELECT value FROM " + tableFields + " WHERE field='version'");
if (rs.next()) {
return rs.getInt("value");
}
}
}
return 0;
}
private void setDatabaseVersion(int version) throws SQLException {
String queryUpdateVersion = "REPLACE INTO " + tableFields + " VALUES ('version', ?)";
try (Connection con = dataSource.getConnection()) {
try (PreparedStatement ps = con.prepareStatement(queryUpdateVersion)) {
ps.setInt(1, version);
ps.executeUpdate();
}
}
}
private boolean update() throws SQLException { private boolean update() throws SQLException {
String queryGetTable = getQueryGetTable(); String queryGetTable = getQueryGetTable();
String queryUpdateVersion = "REPLACE INTO " + tableFields + " VALUES ('version', ?)";
try (Connection con = dataSource.getConnection()) { try (Connection con = dataSource.getConnection()) {
boolean needsUpdate1 = false; // update "shop_log" to "economy_logs" and update "shops" with prefixes boolean needsUpdate1 = false; // update "shop_log" to "economy_logs" and update "shops" with prefixes
@ -191,15 +210,22 @@ public abstract class Database {
try (Statement s = con.createStatement()) { try (Statement s = con.createStatement()) {
s.executeUpdate(getQueryCreateTableFields()); s.executeUpdate(getQueryCreateTableFields());
} }
setDatabaseVersion(2);
} }
// Set database version int databaseVersion = getDatabaseVersion();
try (PreparedStatement ps = con.prepareStatement(queryUpdateVersion)) {
ps.setInt(1, DATABASE_VERSION); if (databaseVersion < 3) {
ps.executeUpdate(); // plugin.getLogger().info("Updating database... (#3)");
// Update database structure...
// setDatabaseVersion(3);
} }
return needsUpdate1 || needsUpdate2; int newDatabaseVersion = getDatabaseVersion();
return needsUpdate1 || needsUpdate2 || newDatabaseVersion > databaseVersion;
} }
} }