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

Class MySqlSchemaUtils

java.lang.Object

org.apache.flink.cdc.connectors.mysql.utils.MySqlSchemaUtils

public class MySqlSchemaUtils
extends Object

Utilities for converting from debezium Table types to Schema.

Method Summary

Modifier and Type	Method	Description
static Schema	getTableSchema(io.debezium.connector.mysql.MySqlPartition partition, TableId tableId, MySqlSourceConfig sourceConfig, MySqlConnection jdbc)
static Schema	getTableSchema(MySqlSourceConfig sourceConfig, io.debezium.connector.mysql.MySqlPartition partition, TableId tableId)
static boolean	isTableIdCaseInsensitive(MySqlSourceConfig sourceConfig)
static List<String>	listDatabases(io.debezium.jdbc.JdbcConnection jdbc)
static List<String>	listDatabases(MySqlSourceConfig sourceConfig)
static List<TableId>	listTables(io.debezium.jdbc.JdbcConnection jdbc, String dbName)
static List<TableId>	listTables(MySqlSourceConfig sourceConfig, String dbName)
static Column	toColumn(io.debezium.relational.Column column, boolean tinyInt1isBit)
static io.debezium.relational.TableId	toDbzTableId(TableId tableId)
static Schema	toSchema(io.debezium.relational.Table table, boolean tinyInt1isBit)

Methods inherited from class java.lang.Object

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

Method Detail

listDatabases

public static List<String> listDatabases(MySqlSourceConfig sourceConfig)

listTables

public static List<TableId> listTables(MySqlSourceConfig sourceConfig,
                                       @Nullable
                                       String dbName)

getTableSchema

public static Schema getTableSchema(MySqlSourceConfig sourceConfig,
                                    io.debezium.connector.mysql.MySqlPartition partition,
                                    TableId tableId)

listDatabases

public static List<String> listDatabases(io.debezium.jdbc.JdbcConnection jdbc)
                                  throws SQLException

Throws:

SQLException

listTables

public static List<TableId> listTables(io.debezium.jdbc.JdbcConnection jdbc,
                                       String dbName)
                                throws SQLException

Throws:

SQLException

getTableSchema

public static Schema getTableSchema(io.debezium.connector.mysql.MySqlPartition partition,
                                    TableId tableId,
                                    MySqlSourceConfig sourceConfig,
                                    MySqlConnection jdbc)

toSchema

public static Schema toSchema(io.debezium.relational.Table table,
                              boolean tinyInt1isBit)

toColumn

public static Column toColumn(io.debezium.relational.Column column,
                              boolean tinyInt1isBit)

toDbzTableId

public static io.debezium.relational.TableId toDbzTableId(TableId tableId)

isTableIdCaseInsensitive

public static boolean isTableIdCaseInsensitive(MySqlSourceConfig sourceConfig)