src/main/java/org/embulk/output/sqlserver/SQLServerOutputConnection.java in embulk-output-sqlserver-0.7.12 vs src/main/java/org/embulk/output/sqlserver/SQLServerOutputConnection.java in embulk-output-sqlserver-0.7.13

- old
+ new

@@ -1,10 +1,9 @@ package org.embulk.output.sqlserver; import java.sql.Connection; import java.sql.SQLException; -import java.sql.Statement; import java.util.Arrays; import java.util.List; import org.embulk.output.jdbc.JdbcColumn; import org.embulk.output.jdbc.JdbcOutputConnection; @@ -59,30 +58,12 @@ { // NOP } @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 final String[] SIMPLE_TYPE_NAMES = { "BIT", "FLOAT", };