src/main/java/org/embulk/input/postgresql/getter/PostgreSQLColumnGetterFactory.java in embulk-input-postgresql-0.9.1 vs src/main/java/org/embulk/input/postgresql/getter/PostgreSQLColumnGetterFactory.java in embulk-input-postgresql-0.9.2

- old
+ new

@@ -4,10 +4,11 @@ import org.embulk.input.jdbc.JdbcColumn; import org.embulk.input.jdbc.JdbcColumnOption; import org.embulk.input.jdbc.JdbcInputConnection; import org.embulk.input.jdbc.getter.ColumnGetter; import org.embulk.input.jdbc.getter.ColumnGetterFactory; +import org.embulk.input.jdbc.getter.StringColumnGetter; import org.embulk.input.jdbc.getter.TimestampWithTimeZoneIncrementalHandler; import org.embulk.input.jdbc.getter.TimestampWithoutTimeZoneIncrementalHandler; import org.embulk.spi.PageBuilder; import org.embulk.spi.type.Types; import org.joda.time.DateTimeZone; @@ -27,9 +28,13 @@ return new HstoreToJsonColumnGetter(to, Types.JSON); } if (column.getSqlType() == java.sql.Types.ARRAY) { return new ArrayColumnGetter(to, getToType(option)); + } + + if ("uuid".equals(column.getTypeName())) { + return new StringColumnGetter(to, getToType(option)); } ColumnGetter getter = super.newColumnGetter(con, task, column, option); // incremental loading wrapper