}
- public static final int CURRENT_SCHEMA_VERSION = 9;
+ public static final int CURRENT_SCHEMA_VERSION = 10;
public static final int CONNECTION_TIMEOUT = 24 * 60 * 60;
upgrade(version);
}
- public void beginTransaction() throws SQLException {
- c.setAutoCommit(false);
- }
-
private static void upgrade(int version) {
try {
Statement s = getInstance().c.createStatement();
try {
while (version < CURRENT_SCHEMA_VERSION) {
- try (InputStream resourceAsStream = DatabaseConnection.class.getResourceAsStream("upgrade/from_" + version + ".sql")) {
- if (resourceAsStream == null) {
- throw new Error("Upgrade script from version " + version + " was not found.");
- }
- SQLFileManager.addFile(s, resourceAsStream, ImportType.PRODUCTION);
- }
+ addUpgradeScript(Integer.toString(version), s);
version++;
}
s.addBatch("UPDATE \"schemeVersion\" SET version='" + version + "'");
}
}
- public void commitTransaction() throws SQLException {
- c.commit();
- c.setAutoCommit(true);
- }
-
- public void quitTransaction() {
- try {
- if ( !c.getAutoCommit()) {
- c.rollback();
- c.setAutoCommit(true);
+ private static void addUpgradeScript(String version, Statement s) throws Error, IOException, SQLException {
+ try (InputStream resourceAsStream = DatabaseConnection.class.getResourceAsStream("upgrade/from_" + version + ".sql")) {
+ if (resourceAsStream == null) {
+ throw new Error("Upgrade script from version " + version + " was not found.");
}
- } catch (SQLException e) {
- e.printStackTrace();
+ SQLFileManager.addFile(s, resourceAsStream, ImportType.PRODUCTION);
}
}