Sha256: 40b686f1000ce006b4f4eb32f991de187088e611c07df88ea6496738f4b1e411
Contents?: true
Size: 1.03 KB
Versions: 2
Compression:
Stored size: 1.03 KB
Contents
package org.embulk.output.mysql; import java.util.List; import java.io.IOException; import java.sql.Types; import java.sql.PreparedStatement; 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
2 entries across 2 versions & 1 rubygems
Version | Path |
---|---|
embulk-output-mysql-0.4.0 | src/main/java/org/embulk/output/mysql/MySQLBatchInsert.java |
embulk-output-mysql-0.3.0 | src/main/java/org/embulk/output/mysql/MySQLBatchInsert.java |