Check for table existence instead of IF EXISTS which is not supported…

… by all databases
fstuff · Jul 19, 2020 · d737d73 · d737d73
1 parent 7774249
commit d737d73
Showing 1 changed file with 15 additions and 3 deletions.
diff --git a/jgnash-core/src/main/java/jgnash/engine/jpa/SqlUtils.java b/jgnash-core/src/main/java/jgnash/engine/jpa/SqlUtils.java
@@ -207,9 +207,21 @@ static void dropColumn(final String fileName, final char[] password, final Strin
                 final String url = properties.getProperty(JpaConfiguration.JAVAX_PERSISTENCE_JDBC_URL);
 
                 try (final Connection connection = DriverManager.getConnection(url)) {
-                    for (final String column : columns) {
-                        try (final Statement statement = connection.createStatement()) {
-                            statement.execute("ALTER TABLE IF EXISTS " + table + " DROP COLUMN IF EXISTS " + column);
+
+                    final DatabaseMetaData metaData = connection.getMetaData();
+
+                    final ResultSet resultSet = metaData.getTables(null, null, table,
+                            new String[] {"TABLE"});
+
+                    while (resultSet.next()) {
+                        final String tableName = resultSet.getString("TABLE_NAME");
+
+                        if (tableName !=null && tableName.equalsIgnoreCase(table)) {
+                            for (final String column : columns) {
+                                try (final Statement statement = connection.createStatement()) {
+                                    statement.execute("ALTER TABLE " + table + " DROP " + column);
+                                }
+                            }
                         }
                     }