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

Class MySqlSchema

java.lang.Object

org.apache.flink.cdc.connectors.mysql.schema.MySqlSchema

All Implemented Interfaces:

AutoCloseable

public class MySqlSchema
extends Object
implements AutoCloseable

A component used to get schema by table path.

Constructor Summary

Constructors

Constructor	Description
MySqlSchema(MySqlSourceConfig sourceConfig, boolean isTableIdCaseSensitive)

Method Summary

Modifier and Type	Method	Description
void	close()
io.debezium.relational.history.TableChanges.TableChange	getTableSchema(io.debezium.connector.mysql.MySqlPartition partition, 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.connector.mysql.MySqlPartition partition,
                                                                              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.

close

public void close()

Specified by:

close in interface AutoCloseable