Sha256: 80d73ab872f25ea6c2bfbba7c91ad065825efbd76830d7c422979a9e4a06f348
Contents?: true
Size: 1.2 KB
Versions: 12
Compression:
Stored size: 1.2 KB
Contents
package org.embulk.input.jdbc.getter;
import java.sql.ResultSet;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import com.fasterxml.jackson.databind.JsonNode;
import com.fasterxml.jackson.databind.node.JsonNodeFactory;
import org.embulk.spi.Column;
import org.embulk.spi.ColumnVisitor;
import org.embulk.spi.PageBuilder;
import org.embulk.spi.type.Type;
import org.embulk.spi.DataException;
import static java.util.Locale.ENGLISH;
public abstract class AbstractIncrementalHandler implements ColumnGetter
{
protected static final JsonNodeFactory jsonNodeFactory = JsonNodeFactory.instance;
protected ColumnGetter next;
public AbstractIncrementalHandler(ColumnGetter next)
{
this.next = next;
}
@Override
public void getAndSet(ResultSet from, int fromIndex,
Column toColumn) throws SQLException
{
next.getAndSet(from, fromIndex, toColumn);
}
@Override
public Type getToType()
{
return next.getToType();
}
@Override
public abstract JsonNode encodeToJson();
@Override
public abstract void decodeFromJsonTo(PreparedStatement toStatement, int toIndex, JsonNode fromValue)
throws SQLException;
}
Version data entries
12 entries across 12 versions & 2 rubygems