package org.embulk.input.jdbc.getter;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.PreparedStatement;
import com.fasterxml.jackson.databind.JsonNode;
import org.embulk.spi.Column;
import org.embulk.spi.type.Type;

public interface ColumnGetter
{
    public void getAndSet(ResultSet from, int fromIndex,
            Column toColumn) throws SQLException;

    public Type getToType();

    public JsonNode encodeToJson();

    public void decodeFromJsonTo(PreparedStatement toStatement, int toIndex, JsonNode fromValue)
        throws SQLException;
}