com.ververica.cdc.connectors.mysql.schema

Class MySqlSchema

java.lang.Object

com.ververica.cdc.connectors.mysql.schema.MySqlSchema

public class MySqlSchema
extends Object

A component used to get schema by table path.

Constructor Summary

Constructors

Constructor and Description
MySqlSchema(MySqlSourceConfig sourceConfig, boolean isTableIdCaseSensitive)

Method Summary

Modifier and Type	Method and Description
io.debezium.relational.history.TableChanges.TableChange	getTableSchema(io.debezium.jdbc.JdbcConnection jdbc, io.debezium.relational.TableId tableId) Gets table schema for the given table path.

Methods inherited from class java.lang.Object

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

Constructor Detail

MySqlSchema

public MySqlSchema(MySqlSourceConfig sourceConfig,
                   boolean isTableIdCaseSensitive)

Method Detail

getTableSchema

public io.debezium.relational.history.TableChanges.TableChange getTableSchema(io.debezium.jdbc.JdbcConnection jdbc,
                                                                              io.debezium.relational.TableId tableId)

Gets table schema for the given table path. It will request to MySQL server by running `SHOW CREATE TABLE` if cache missed.