Contents

package org.embulk.output.postgresql.setter;

import org.embulk.output.jdbc.BatchInsert;
import org.embulk.output.jdbc.JdbcColumn;
import org.embulk.output.jdbc.JdbcColumnOption;
import org.embulk.output.jdbc.setter.ColumnSetter;
import org.embulk.output.jdbc.setter.ColumnSetterFactory;
import org.embulk.output.jdbc.setter.JsonColumnSetter;
import org.joda.time.DateTimeZone;

public class PostgreSQLColumnSetterFactory
        extends ColumnSetterFactory
{
    public PostgreSQLColumnSetterFactory(BatchInsert batch, DateTimeZone defaultTimeZone)
    {
        super(batch, defaultTimeZone);
    }

    @Override
    public ColumnSetter newCoalesceColumnSetter(JdbcColumn column, JdbcColumnOption option)
    {
        if (column.getSimpleTypeName().equalsIgnoreCase("json") || column.getSimpleTypeName().equalsIgnoreCase("jsonb")) {
            // actually "JSON"/"JSONB"
            return new JsonColumnSetter(batch, column, newDefaultValueSetter(column, option));
        } else {
            return super.newCoalesceColumnSetter(column, option);
        }
    }

}

Version data entries

28 entries across 28 versions & 1 rubygems

Version	Path
embulk-output-postgresql-0.8.7	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.8.6	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.8.5	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.8.4	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.8.3	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.8.2	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.8.1	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.8.0	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.13	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.12	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.11	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.10	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.9	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.8	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.7	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.6	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.5	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.4	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.3	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java
embulk-output-postgresql-0.7.2	src/main/java/org/embulk/output/postgresql/setter/PostgreSQLColumnSetterFactory.java