Sha256: 0130621c9c054bcd9759618439c2bdce86fc0ab74c121eac4ed21a3d98b33a5f
Contents?: true
Size: 1019 Bytes
Versions: 8
Compression:
Stored size: 1019 Bytes
Contents
package org.embulk.output.mysql;
import java.util.List;
import java.io.IOException;
import java.sql.Types;
import java.sql.SQLException;
import com.google.common.base.Optional;
import org.embulk.output.jdbc.StandardBatchInsert;
public class MySQLBatchInsert
extends StandardBatchInsert
{
public MySQLBatchInsert(MySQLOutputConnector connector, Optional<List<String>> mergeKeys) throws IOException, SQLException
{
super(connector, mergeKeys);
}
@Override
public void setFloat(float v) throws IOException, SQLException
{
if (Float.isNaN(v) || Float.isInfinite(v)) {
setNull(Types.REAL); // TODO get through argument
} else {
super.setFloat(v);
}
}
@Override
public void setDouble(double v) throws IOException, SQLException
{
if (Double.isNaN(v) || Double.isInfinite(v)) {
setNull(Types.DOUBLE); // TODO get through argument
} else {
super.setDouble(v);
}
}
}
Version data entries
8 entries across 8 versions & 1 rubygems