org.apache.flink.connector.jdbc.internal.converter

Interface JdbcRowConverter

All Superinterfaces:

Serializable

All Known Implementing Classes:

AbstractJdbcRowConverter, DerbyRowConverter, MySQLRowConverter, PostgresRowConverter

public interface JdbcRowConverter
extends Serializable

Converter that is responsible to convert between JDBC object and Flink SQL internal data structure RowData.

Method Summary

Modifier and Type	Method and Description
PreparedStatement	toExternal(RowData rowData, PreparedStatement statement) Convert data retrieved from Flink internal RowData to JDBC Object.
RowData	toInternal(ResultSet resultSet) Convert data retrieved from ResultSet to internal RowData.

Method Detail

toInternal

RowData toInternal(ResultSet resultSet)
            throws SQLException

Convert data retrieved from ResultSet to internal RowData.

Parameters:

resultSet - ResultSet from JDBC

Throws:

SQLException

toExternal

PreparedStatement toExternal(RowData rowData,
                             PreparedStatement statement)
                      throws SQLException

Convert data retrieved from Flink internal RowData to JDBC Object.

Parameters:

rowData - The given internal RowData.

statement - The statement to be filled.

Returns:

The filled statement.

Throws:

SQLException