diff --git a/embulk-output-postgresql/src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java b/embulk-output-postgresql/src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java index 5e4c6fce..b358fa7b 100644 --- a/embulk-output-postgresql/src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java +++ b/embulk-output-postgresql/src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java @@ -6,6 +6,7 @@ import org.embulk.output.jdbc.setter.ColumnSetter; import org.embulk.output.jdbc.setter.ColumnSetterFactory; import org.embulk.output.jdbc.setter.JsonColumnSetter; +import org.embulk.output.jdbc.setter.StringColumnSetter; import org.joda.time.DateTimeZone; public class PostgreSQLColumnSetterFactory @@ -22,6 +23,8 @@ public ColumnSetter newCoalesceColumnSetter(JdbcColumn column, JdbcColumnOption if (column.getSimpleTypeName().equalsIgnoreCase("json") || column.getSimpleTypeName().equalsIgnoreCase("jsonb")) { // actually "JSON"/"JSONB" return new JsonColumnSetter(batch, column, newDefaultValueSetter(column, option)); + } else if (column.getSimpleTypeName().equalsIgnoreCase("inet")) { + return new StringColumnSetter(batch, column, newDefaultValueSetter(column, option), newTimestampFormatter(option)); } else { return super.newCoalesceColumnSetter(column, option); }