Package org.apache.flink.cdc.connectors.mysql.debezium

Class DebeziumUtils

java.lang.Object

org.apache.flink.cdc.connectors.mysql.debezium.DebeziumUtils

public class DebeziumUtils
extends Object

Utilities related to Debezium.

Constructor Summary

Constructors

Constructor	Description
DebeziumUtils()

Method Summary

Modifier and Type	Method	Description
static com.github.shyiko.mysql.binlog.BinaryLogClient	createBinaryClient(io.debezium.config.Configuration dbzConfiguration)	Creates a new BinaryLogClient for consuming mysql binlog.
static MySqlConnection	createMySqlConnection(io.debezium.config.Configuration dbzConfiguration, Properties jdbcProperties)	Creates a new MySqlConnection, but not open the connection.
static MySqlConnection	createMySqlConnection(MySqlSourceConfig sourceConfig)	Creates a new MySqlConnection, but not open the connection.
static io.debezium.connector.mysql.MySqlDatabaseSchema	createMySqlDatabaseSchema(io.debezium.connector.mysql.MySqlConnectorConfig dbzMySqlConfig, boolean isTableIdCaseSensitive)	Creates a new MySqlDatabaseSchema to monitor the latest MySql database schemas.
static io.debezium.relational.Tables.TableFilter	createTableFilter(String database, String table)	Create a TableFilter by database name and table name.
static BinlogOffset	currentBinlogOffset(MySqlConnection jdbc)	Fetch current binlog offsets in MySql Server.
static List<io.debezium.relational.TableId>	discoverCapturedTables(io.debezium.jdbc.JdbcConnection jdbc, MySqlSourceConfig sourceConfig)
static BinlogOffset	findBinlogOffset(long targetMs, MySqlConnection connection, MySqlSourceConfig mySqlSourceConfig)
static boolean	isTableIdCaseSensitive(io.debezium.jdbc.JdbcConnection connection)
static io.debezium.jdbc.JdbcConnection	openJdbcConnection(MySqlSourceConfig sourceConfig)	Creates and opens a new JdbcConnection backing connection pool.
static Map<String,String>	readMySqlSystemVariables(io.debezium.jdbc.JdbcConnection connection)

Methods inherited from class java.lang.Object

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

Constructor Detail

DebeziumUtils

public DebeziumUtils()

Method Detail

openJdbcConnection

public static io.debezium.jdbc.JdbcConnection openJdbcConnection(MySqlSourceConfig sourceConfig)

Creates and opens a new JdbcConnection backing connection pool.

createMySqlConnection

public static MySqlConnection createMySqlConnection(MySqlSourceConfig sourceConfig)

Creates a new MySqlConnection, but not open the connection.

createMySqlConnection

public static MySqlConnection createMySqlConnection(io.debezium.config.Configuration dbzConfiguration,
                                                    Properties jdbcProperties)

Creates a new MySqlConnection, but not open the connection.

createBinaryClient

public static com.github.shyiko.mysql.binlog.BinaryLogClient createBinaryClient(io.debezium.config.Configuration dbzConfiguration)

Creates a new BinaryLogClient for consuming mysql binlog.

createMySqlDatabaseSchema

public static io.debezium.connector.mysql.MySqlDatabaseSchema createMySqlDatabaseSchema(io.debezium.connector.mysql.MySqlConnectorConfig dbzMySqlConfig,
                                                                                        boolean isTableIdCaseSensitive)

Creates a new MySqlDatabaseSchema to monitor the latest MySql database schemas.

currentBinlogOffset

public static BinlogOffset currentBinlogOffset(MySqlConnection jdbc)

Fetch current binlog offsets in MySql Server.

createTableFilter

public static io.debezium.relational.Tables.TableFilter createTableFilter(String database,
                                                                          String table)

Create a TableFilter by database name and table name.

discoverCapturedTables

public static List<io.debezium.relational.TableId> discoverCapturedTables(io.debezium.jdbc.JdbcConnection jdbc,
                                                                          MySqlSourceConfig sourceConfig)

isTableIdCaseSensitive

public static boolean isTableIdCaseSensitive(io.debezium.jdbc.JdbcConnection connection)

readMySqlSystemVariables

public static Map<String,String> readMySqlSystemVariables(io.debezium.jdbc.JdbcConnection connection)

findBinlogOffset

public static BinlogOffset findBinlogOffset(long targetMs,
                                            MySqlConnection connection,
                                            MySqlSourceConfig mySqlSourceConfig)