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.