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();
}
}