src/main/java/org/embulk/output/jdbc/setter/IntColumnSetter.java in embulk-output-jdbc-0.5.1 vs src/main/java/org/embulk/output/jdbc/setter/IntColumnSetter.java in embulk-output-jdbc-0.6.0

- old
+ new

@@ -1,14 +1,17 @@ package org.embulk.output.jdbc.setter; import java.io.IOException; import java.sql.SQLException; import java.math.RoundingMode; + import com.google.common.math.DoubleMath; + import org.embulk.spi.time.Timestamp; import org.embulk.output.jdbc.JdbcColumn; import org.embulk.output.jdbc.BatchInsert; +import org.msgpack.value.Value; public class IntColumnSetter extends ColumnSetter { public IntColumnSetter(BatchInsert batch, JdbcColumn column, @@ -67,9 +70,15 @@ batch.setInt(iv); } @Override public void timestampValue(Timestamp v) throws IOException, SQLException + { + defaultValue.setInt(); + } + + @Override + public void jsonValue(Value v) throws IOException, SQLException { defaultValue.setInt(); } }