com.ververica.cdc.connectors.mysql.source.utils

Class TableDiscoveryUtils

java.lang.Object

com.ververica.cdc.connectors.mysql.source.utils.TableDiscoveryUtils

public class TableDiscoveryUtils
extends Object

Utilities to discovery matched tables.

Constructor Summary

Constructors

Constructor and Description
TableDiscoveryUtils()

Method Summary

Modifier and Type	Method and Description
static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange>	discoverCapturedTableSchemas(MySqlSourceConfig sourceConfig, io.debezium.connector.mysql.MySqlConnection jdbc)
static List<io.debezium.relational.TableId>	listTables(io.debezium.jdbc.JdbcConnection jdbc, io.debezium.relational.RelationalTableFilters tableFilters)

Methods inherited from class java.lang.Object

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

Constructor Detail

TableDiscoveryUtils

public TableDiscoveryUtils()

Method Detail

listTables

public static List<io.debezium.relational.TableId> listTables(io.debezium.jdbc.JdbcConnection jdbc,
                                                              io.debezium.relational.RelationalTableFilters tableFilters)
                                                       throws SQLException

Throws:

SQLException

discoverCapturedTableSchemas

public static Map<io.debezium.relational.TableId,io.debezium.relational.history.TableChanges.TableChange> discoverCapturedTableSchemas(MySqlSourceConfig sourceConfig,
                                                                                                                                       io.debezium.connector.mysql.MySqlConnection jdbc)