Sha256: ebe612cc62b4914f9435a85ca467f35a08aca2e92e646b85fc018e6e313e8e39
Contents?: true
Size: 946 Bytes
Versions: 7
Compression:
Stored size: 946 Bytes
Contents
package org.embulk.output.mysql;
import java.io.IOException;
import java.sql.Types;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import org.embulk.output.jdbc.StandardBatchInsert;
public class MySQLBatchInsert
extends StandardBatchInsert
{
public MySQLBatchInsert(MySQLOutputConnector connector) throws IOException, SQLException
{
super(connector);
}
@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
7 entries across 7 versions & 1 rubygems