Contents

package org.embulk.input.postgresql.getter;

import org.embulk.input.jdbc.JdbcColumn;
import org.embulk.input.jdbc.JdbcColumnOption;
import org.embulk.input.jdbc.getter.ColumnGetter;
import org.embulk.input.jdbc.getter.ColumnGetterFactory;
import org.embulk.spi.PageBuilder;
import org.joda.time.DateTimeZone;

public class PostgreSQLColumnGetterFactory extends ColumnGetterFactory
{
    public PostgreSQLColumnGetterFactory(PageBuilder to, DateTimeZone defaultTimeZone)
    {
        super(to, defaultTimeZone);
    }

    @Override
    public ColumnGetter newColumnGetter(JdbcColumn column, JdbcColumnOption option)
    {
        if (column.getTypeName().equals("hstore")) {
            return new HstoreColumnGetter(to, getToType(option));
        } else {
            return super.newColumnGetter(column, option);
        }
    }

    @Override
    protected String sqlTypeToValueType(JdbcColumn column, int sqlType)
    {
        if (column.getTypeName().equals("json") || column.getTypeName().equals("jsonb")) {
            return "json";
        } else {
            return super.sqlTypeToValueType(column, sqlType);
        }
    }
}

Version data entries

6 entries across 6 versions & 1 rubygems

Version	Path
embulk-input-postgresql-0.8.0	src/main/java/org/embulk/input/postgresql/getter/PostgreSQLColumnGetterFactory.java
embulk-input-postgresql-0.7.4	src/main/java/org/embulk/input/postgresql/getter/PostgreSQLColumnGetterFactory.java
embulk-input-postgresql-0.7.3	src/main/java/org/embulk/input/postgresql/getter/PostgreSQLColumnGetterFactory.java
embulk-input-postgresql-0.7.2	src/main/java/org/embulk/input/postgresql/getter/PostgreSQLColumnGetterFactory.java
embulk-input-postgresql-0.7.1	src/main/java/org/embulk/input/postgresql/getter/PostgreSQLColumnGetterFactory.java
embulk-input-postgresql-0.7.0	src/main/java/org/embulk/input/postgresql/getter/PostgreSQLColumnGetterFactory.java