- 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.");