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

Class PostgresQueryUtils

java.lang.Object

org.apache.flink.cdc.connectors.postgres.source.utils.PostgresQueryUtils

public class PostgresQueryUtils
extends Object

Query-related Utilities for Postgres CDC source.

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, List<String> uuidFields)
static String	buildSplitScanQuery(io.debezium.relational.TableId tableId, org.apache.flink.table.types.logical.RowType pkRowType, boolean isFirstSplit, boolean isLastSplit, List<String> columnNames, List<String> uuidFields)
static boolean	isUUID(io.debezium.relational.Column column)
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, io.debezium.relational.Column column, Object excludedLowerBound)
static Object[]	queryMinMax(io.debezium.jdbc.JdbcConnection jdbc, io.debezium.relational.TableId tableId, io.debezium.relational.Column column)
static Object	queryNextChunkMax(io.debezium.jdbc.JdbcConnection jdbc, io.debezium.relational.TableId tableId, io.debezium.relational.Column splitColumn, int chunkSize, Object includedLowerBound)
static String	quote(io.debezium.relational.TableId tableId)
static String	quote(String name)
static PreparedStatement	readTableSplitDataStatement(io.debezium.jdbc.JdbcConnection jdbc, String sql, boolean isFirstSplit, boolean isLastSplit, Object[] splitStart, Object[] splitEnd, int primaryKeyNum, int fetchSize)

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,
                                   io.debezium.relational.Column column)
                            throws SQLException

Throws:

SQLException

queryApproximateRowCnt

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

Throws:

SQLException

queryMin

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

Throws:

SQLException

queryNextChunkMax

public static Object queryNextChunkMax(io.debezium.jdbc.JdbcConnection jdbc,
                                       io.debezium.relational.TableId tableId,
                                       io.debezium.relational.Column splitColumn,
                                       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,
                                         List<String> uuidFields)

buildSplitScanQuery

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

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 name)

isUUID

public static boolean isUUID(io.debezium.relational.Column column)

quote

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