com.ververica.cdc.connectors.mysql.debezium

Class DebeziumUtils

java.lang.Object

com.ververica.cdc.connectors.mysql.debezium.DebeziumUtils

public class DebeziumUtils
extends Object

Utilities related to Debezium.

Constructor Summary

Constructors

Constructor and Description
DebeziumUtils()

Method Summary

Modifier and Type	Method and Description
static com.github.shyiko.mysql.binlog.BinaryLogClient	createBinaryClient(io.debezium.config.Configuration dbzConfiguration) Creates a new BinaryLogClient for consuming mysql binlog.
static io.debezium.connector.mysql.MySqlConnection	createMySqlConnection(io.debezium.config.Configuration dbzConfiguration) 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 BinlogOffset	currentBinlogOffset(io.debezium.jdbc.JdbcConnection jdbc) Fetch current binlog offsets in MySql Server.
static List<io.debezium.relational.TableId>	discoverCapturedTables(io.debezium.jdbc.JdbcConnection jdbc, MySqlSourceConfig sourceConfig)
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 io.debezium.connector.mysql.MySqlConnection createMySqlConnection(io.debezium.config.Configuration dbzConfiguration)

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(io.debezium.jdbc.JdbcConnection jdbc)

Fetch current binlog offsets in MySql Server.

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)