org.apache.flink.connector.jdbc.internal.executor

Class InsertOrUpdateJdbcExecutor<R,K,V>

java.lang.Object

org.apache.flink.connector.jdbc.internal.executor.InsertOrUpdateJdbcExecutor<R,K,V>

All Implemented Interfaces:

JdbcBatchStatementExecutor<R>

@Internal
public final class InsertOrUpdateJdbcExecutor<R,K,V>
extends Object
implements JdbcBatchStatementExecutor<R>

JdbcBatchStatementExecutor that provides upsert semantics by updating row if it exists and inserting otherwise. Used in Table API.

Constructor Summary

Constructors

Constructor and Description
InsertOrUpdateJdbcExecutor(String existSQL, String insertSQL, String updateSQL, JdbcStatementBuilder<K> existSetter, JdbcStatementBuilder<V> insertSetter, JdbcStatementBuilder<V> updateSetter, java.util.function.Function<R,K> keyExtractor, java.util.function.Function<R,V> valueExtractor)

Method Summary

Modifier and Type	Method and Description
void	addToBatch(R record)
void	closeStatements() Close JDBC related statements.
void	executeBatch() Submits a batch of commands to the database for execution.
void	prepareStatements(Connection connection) Create statements from connection.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.connector.jdbc.internal.executor.JdbcBatchStatementExecutor

keyed, simple

Constructor Detail

InsertOrUpdateJdbcExecutor

public InsertOrUpdateJdbcExecutor(@Nonnull
                                  String existSQL,
                                  @Nonnull
                                  String insertSQL,
                                  @Nonnull
                                  String updateSQL,
                                  @Nonnull
                                  JdbcStatementBuilder<K> existSetter,
                                  @Nonnull
                                  JdbcStatementBuilder<V> insertSetter,
                                  @Nonnull
                                  JdbcStatementBuilder<V> updateSetter,
                                  @Nonnull
                                  java.util.function.Function<R,K> keyExtractor,
                                  @Nonnull
                                  java.util.function.Function<R,V> valueExtractor)

Method Detail

prepareStatements

public void prepareStatements(Connection connection)
                       throws SQLException

Description copied from interface: JdbcBatchStatementExecutor

Create statements from connection.

Specified by:

prepareStatements in interface JdbcBatchStatementExecutor<R>

Throws:

SQLException

addToBatch

public void addToBatch(R record)

Specified by:

addToBatch in interface JdbcBatchStatementExecutor<R>

executeBatch

public void executeBatch()
                  throws SQLException

Description copied from interface: JdbcBatchStatementExecutor

Submits a batch of commands to the database for execution.

Specified by:

executeBatch in interface JdbcBatchStatementExecutor<R>

Throws:

SQLException

closeStatements

public void closeStatements()
                     throws SQLException

Description copied from interface: JdbcBatchStatementExecutor

Close JDBC related statements.

Specified by:

closeStatements in interface JdbcBatchStatementExecutor<R>

Throws:

SQLException