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