Sha256: 2caf2e3769f5cb5193e992415b97e374d71f14ea8a18789552791675ad05e0cc
Contents?: true
Size: 1.29 KB
Versions: 12
Compression:
Stored size: 1.29 KB
Contents
package org.embulk.input.jdbc.getter;
import java.math.BigDecimal;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.embulk.spi.Column;
import org.embulk.spi.PageBuilder;
import org.embulk.spi.type.Type;
import org.embulk.spi.type.Types;
public class BigDecimalColumnGetter
extends AbstractColumnGetter
{
protected BigDecimal value;
public BigDecimalColumnGetter(PageBuilder to, Type toType)
{
super(to, toType);
}
@Override
protected void fetch(ResultSet from, int fromIndex) throws SQLException
{
value = from.getBigDecimal(fromIndex);
}
@Override
protected Type getDefaultToType()
{
return Types.DOUBLE;
}
@Override
public void booleanColumn(Column column)
{
to.setBoolean(column, value.signum() > 0);
}
@Override
public void longColumn(Column column)
{
to.setLong(column, value.longValue());
}
@Override
public void doubleColumn(Column column)
{
// rounded value could be Double.NEGATIVE_INFINITY or Double.POSITIVE_INFINITY.
double rounded = value.doubleValue();
to.setDouble(column, rounded);
}
@Override
public void stringColumn(Column column)
{
to.setString(column, value.toPlainString());
}
}
Version data entries
12 entries across 12 versions & 2 rubygems