src/main/java/org/embulk/output/oracle/OracleOutputConnection.java in embulk-output-oracle-0.7.12 vs src/main/java/org/embulk/output/oracle/OracleOutputConnection.java in embulk-output-oracle-0.7.13

- old
+ new

@@ -62,29 +62,12 @@ connection.setSchema(schema); } } @Override - public void dropTableIfExists(TableIdentifier table) throws SQLException + protected boolean supportsTableIfExistsClause() { - if (tableExists(table)) { - dropTable(table); - } - } - - @Override - protected void dropTableIfExists(Statement stmt, TableIdentifier table) throws SQLException { - if (tableExists(table)) { - dropTable(stmt, table); - } - } - - @Override - public void createTableIfNotExists(TableIdentifier table, JdbcSchema schema) throws SQLException - { - if (!tableExists(table)) { - createTable(table, schema); - } + return false; } private static String getSchema(Connection connection) throws SQLException { // Because old Oracle JDBC drivers don't support Connection#getSchema method.