From b22bb3b345125d58aa6a274d34971ad43c1e2d20 Mon Sep 17 00:00:00 2001 From: hito4t Date: Mon, 2 Oct 2017 10:45:49 +0900 Subject: [PATCH] Supported INET type of PostgreSQL --- .../postgresql/setter/PostgreSQLColumnSetterFactory.java | 3 +++ 1 file changed, 3 insertions(+) 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); }