Contents

package org.embulk.output.oracle.setter;

import java.sql.Types;

import org.embulk.output.jdbc.BatchInsert;
import org.embulk.output.jdbc.JdbcColumn;
import org.embulk.output.jdbc.setter.ColumnSetter;
import org.embulk.output.jdbc.setter.ColumnSetterFactory;
import org.embulk.output.jdbc.setter.StringColumnSetter;
import org.embulk.spi.PageReader;
import org.embulk.spi.time.TimestampFormatter;

public class OracleColumnSetterFactory extends ColumnSetterFactory
{
	public OracleColumnSetterFactory(BatchInsert batch, PageReader pageReader,
			TimestampFormatter timestampFormatter)
	{
		super(batch, pageReader, timestampFormatter);
	}
	
	@Override
	public ColumnSetter newColumnSetter(JdbcColumn column)
    {
		switch (column.getSqlType()) {
			case Types.DECIMAL:
	            return new StringColumnSetter(batch, pageReader, column, timestampFormatter);
            default:
        		return super.newColumnSetter(column);
		}
	}
}

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
embulk-output-oracle-0.2.1	src/main/java/org/embulk/output/oracle/setter/OracleColumnSetterFactory.java