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