Sha256: fd399a6f576a76b244565d6be3e072440ca65dd943c5f9909e0eaab882296558
Contents?: true
Size: 1.18 KB
Versions: 4
Compression:
Stored size: 1.18 KB
Contents
package org.embulk.output.cassandra.setter;
import com.datastax.driver.core.BoundStatement;
import com.datastax.driver.core.ColumnMetadata;
import java.math.BigDecimal;
public class DecimalColumnSetter extends CassandraColumnSetter
{
public DecimalColumnSetter(ColumnMetadata cassandraColumn)
{
super(cassandraColumn);
}
@Override
public void setBooleanValue(Boolean value, BoundStatement statement)
{
if (value) {
statement.setDecimal(cassandraColumn.getName(), BigDecimal.valueOf(1));
}
else {
statement.setDecimal(cassandraColumn.getName(), BigDecimal.valueOf(0));
}
}
@Override
public void setLongValue(Long value, BoundStatement statement)
{
statement.setDecimal(cassandraColumn.getName(), BigDecimal.valueOf(value));
}
@Override
public void setDoubleValue(Double value, BoundStatement statement)
{
statement.setDecimal(cassandraColumn.getName(), BigDecimal.valueOf(value));
}
@Override
public void setStringValue(String value, BoundStatement statement)
{
statement.setDecimal(cassandraColumn.getName(), new BigDecimal(value));
}
}
Version data entries
4 entries across 4 versions & 1 rubygems