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

- old
+ new

@@ -1,13 +1,15 @@ package org.embulk.output.jdbc.setter; import java.io.IOException; import java.sql.SQLException; + import org.embulk.spi.time.Timestamp; import org.embulk.spi.time.TimestampFormatter; import org.embulk.output.jdbc.JdbcColumn; import org.embulk.output.jdbc.BatchInsert; +import org.msgpack.value.Value; public class StringColumnSetter extends ColumnSetter { private final TimestampFormatter timestampFormatter; @@ -52,7 +54,13 @@ @Override public void timestampValue(Timestamp v) throws IOException, SQLException { batch.setString(timestampFormatter.format(v)); + } + + @Override + public void jsonValue(Value v) throws IOException, SQLException + { + batch.setString(v.toJson()); } }