Package org.apache.flink.cdc.connectors.mysql.source.utils

Class StatementUtils

java.lang.Object

org.apache.flink.cdc.connectors.mysql.source.utils.StatementUtils

public class StatementUtils
extends Object

Utils to prepare SQL statement.

Method Summary

Modifier and Type	Method	Description
static String	buildSplitScanQuery(io.debezium.relational.TableId tableId, org.apache.flink.table.types.logical.RowType pkRowType, boolean isFirstSplit, boolean isLastSplit)
static long	queryApproximateRowCnt(io.debezium.jdbc.JdbcConnection jdbc, io.debezium.relational.TableId tableId)
static Object	queryMin(io.debezium.jdbc.JdbcConnection jdbc, io.debezium.relational.TableId tableId, String columnName, Object excludedLowerBound)
static Object[]	queryMinMax(io.debezium.jdbc.JdbcConnection jdbc, io.debezium.relational.TableId tableId, String columnName)
static Object	queryNextChunkMax(io.debezium.jdbc.JdbcConnection jdbc, io.debezium.relational.TableId tableId, String splitColumnName, int chunkSize, Object includedLowerBound)
static String	quote(io.debezium.relational.TableId tableId)
static String	quote(String dbOrTableName)
static PreparedStatement	readTableSplitDataStatement(io.debezium.jdbc.JdbcConnection jdbc, String sql, boolean isFirstSplit, boolean isLastSplit, Object[] splitStart, Object[] splitEnd, int primaryKeyNum, int fetchSize)
static void	setSafeObject(PreparedStatement ps, int parameterIndex, Object value)

Methods inherited from class java.lang.Object

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

Method Detail

queryMinMax

public static Object[] queryMinMax(io.debezium.jdbc.JdbcConnection jdbc,
                                   io.debezium.relational.TableId tableId,
                                   String columnName)
                            throws SQLException

Throws:

SQLException

queryApproximateRowCnt

public static long queryApproximateRowCnt(io.debezium.jdbc.JdbcConnection jdbc,
                                          io.debezium.relational.TableId tableId)
                                   throws SQLException

Throws:

SQLException

setSafeObject

public static void setSafeObject(PreparedStatement ps,
                                 int parameterIndex,
                                 Object value)
                          throws SQLException

Throws:

SQLException

queryMin

public static Object queryMin(io.debezium.jdbc.JdbcConnection jdbc,
                              io.debezium.relational.TableId tableId,
                              String columnName,
                              Object excludedLowerBound)
                       throws SQLException

Throws:

SQLException

queryNextChunkMax

public static Object queryNextChunkMax(io.debezium.jdbc.JdbcConnection jdbc,
                                       io.debezium.relational.TableId tableId,
                                       String splitColumnName,
                                       int chunkSize,
                                       Object includedLowerBound)
                                throws SQLException

Throws:

SQLException

buildSplitScanQuery

public static String buildSplitScanQuery(io.debezium.relational.TableId tableId,
                                         org.apache.flink.table.types.logical.RowType pkRowType,
                                         boolean isFirstSplit,
                                         boolean isLastSplit)

readTableSplitDataStatement

public static PreparedStatement readTableSplitDataStatement(io.debezium.jdbc.JdbcConnection jdbc,
                                                            String sql,
                                                            boolean isFirstSplit,
                                                            boolean isLastSplit,
                                                            Object[] splitStart,
                                                            Object[] splitEnd,
                                                            int primaryKeyNum,
                                                            int fetchSize)

quote

public static String quote(String dbOrTableName)

quote

public static String quote(io.debezium.relational.TableId tableId)