X-Git-Url: https://code.wpia.club/?a=blobdiff_plain;f=src%2Forg%2Fcacert%2Fgigi%2Fdatabase%2FDatabaseConnection.java;h=ef9b19cc71cbab89c6bbb5193479036eb90d1dd9;hb=14ce2292d15b5d43a285804991f9b7d94207e274;hp=49658fb7b3c7eed83aec542b3089d6c8a3867582;hpb=53a66914a544d38be7e626aec2e74542745d4fda;p=gigi.git

diff --git a/src/org/cacert/gigi/database/DatabaseConnection.java b/src/org/cacert/gigi/database/DatabaseConnection.java
index 49658fb7..ef9b19cc 100644
--- a/src/org/cacert/gigi/database/DatabaseConnection.java
+++ b/src/org/cacert/gigi/database/DatabaseConnection.java
@@ -120,11 +120,12 @@ public class DatabaseConnection {
         try {
             Statement s = getInstance().c.createStatement();
             while (version < CURRENT_SCHEMA_VERSION) {
-                InputStream resourceAsStream = DatabaseConnection.class.getResourceAsStream("upgrade/from_" + version + ".sql");
-                if (resourceAsStream == null) {
-                    throw new Error("Upgrade script from version " + version + " was not found.");
+                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);
                 }
-                SQLFileManager.addFile(s, resourceAsStream, ImportType.PRODUCTION);
                 version++;
             }
             s.addBatch("INSERT INTO schemeVersion SET version='" + version + "'");