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",
};