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

Class SqlServerSchemaUtils

java.lang.Object

org.apache.flink.cdc.connectors.sqlserver.utils.SqlServerSchemaUtils

public class SqlServerSchemaUtils
extends Object

Utilities for converting from debezium Table types to Schema.

Constructor Summary

Constructors

Constructor	Description
SqlServerSchemaUtils()

Method Summary

Modifier and Type	Method	Description
static SqlServerDialect	getSqlServerDialect(SqlServerSourceConfig sourceConfig)
static Schema	getTableSchema(io.debezium.relational.TableId tableId, io.debezium.connector.sqlserver.SqlServerConnection jdbc, SqlServerDialect dialect)
static Schema	getTableSchema(TableId tableId, io.debezium.connector.sqlserver.SqlServerConnection jdbc, SqlServerDialect dialect)
static Schema	getTableSchema(SqlServerSourceConfig sourceConfig, TableId tableId)
static List<String>	listNamespaces(io.debezium.jdbc.JdbcConnection jdbc)
static List<String>	listNamespaces(SqlServerSourceConfig sourceConfig)
static List<String>	listSchemas(io.debezium.jdbc.JdbcConnection jdbc, String namespace)
static List<String>	listSchemas(SqlServerSourceConfig sourceConfig, String namespace)
static List<TableId>	listTables(SqlServerSourceConfig sourceConfig, String dbName, String schemaName)
static String	quote(String dbOrTableName)
static TableId	toCdcTableId(io.debezium.relational.TableId dbzTableId)
static Column	toColumn(io.debezium.relational.Column column)
static io.debezium.relational.TableId	toDbzTableId(TableId tableId)
static Schema	toSchema(io.debezium.relational.Table table)
static void	validateSqlServerAgentRunning(SqlServerSourceConfig sourceConfig)

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlServerSchemaUtils

public SqlServerSchemaUtils()

Method Detail

listSchemas

public static List<String> listSchemas(SqlServerSourceConfig sourceConfig,
                                       String namespace)

listNamespaces

public static List<String> listNamespaces(SqlServerSourceConfig sourceConfig)

validateSqlServerAgentRunning

public static void validateSqlServerAgentRunning(SqlServerSourceConfig sourceConfig)

listTables

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

getTableSchema

public static Schema getTableSchema(SqlServerSourceConfig sourceConfig,
                                    TableId tableId)

getSqlServerDialect

public static SqlServerDialect getSqlServerDialect(SqlServerSourceConfig sourceConfig)

listSchemas

public static List<String> listSchemas(io.debezium.jdbc.JdbcConnection jdbc,
                                       String namespace)
                                throws SQLException

Throws:

SQLException

listNamespaces

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

Throws:

SQLException

quote

public static String quote(String dbOrTableName)

getTableSchema

public static Schema getTableSchema(TableId tableId,
                                    io.debezium.connector.sqlserver.SqlServerConnection jdbc,
                                    SqlServerDialect dialect)

getTableSchema

public static Schema getTableSchema(io.debezium.relational.TableId tableId,
                                    io.debezium.connector.sqlserver.SqlServerConnection jdbc,
                                    SqlServerDialect dialect)

toSchema

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

toColumn

public static Column toColumn(io.debezium.relational.Column column)

toDbzTableId

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

toCdcTableId

public static TableId toCdcTableId(io.debezium.relational.TableId dbzTableId)