diff --git a/embulk-output-jdbc/src/main/java/org/embulk/output/jdbc/JdbcOutputConnection.java b/embulk-output-jdbc/src/main/java/org/embulk/output/jdbc/JdbcOutputConnection.java index 24287eca..5696eadb 100644 --- a/embulk-output-jdbc/src/main/java/org/embulk/output/jdbc/JdbcOutputConnection.java +++ b/embulk-output-jdbc/src/main/java/org/embulk/output/jdbc/JdbcOutputConnection.java @@ -121,8 +121,16 @@ public void dropTableIfExists(TableIdentifier table) throws SQLException protected void dropTableIfExists(Statement stmt, TableIdentifier table) throws SQLException { if (supportsTableIfExistsClause()) { - String sql = String.format("DROP TABLE IF EXISTS %s", quoteTableIdentifier(table)); - executeUpdate(stmt, sql); + try { + String sql = String.format("DROP TABLE IF EXISTS %s", quoteTableIdentifier(table)); + executeUpdate(stmt, sql); + } + catch (Exception ex) { + logger.warn("IF EXISTS Not Supported."); + if (tableExists(table)) { + dropTable(stmt, table); + } + } } else { if (tableExists(table)) { dropTable(stmt, table);