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

Class SqlServerConnectionUtils

java.lang.Object

org.apache.flink.cdc.connectors.sqlserver.source.utils.SqlServerConnectionUtils

public class SqlServerConnectionUtils
extends Object

Utils for SqlServer connection.

Constructor Summary

Constructors

Constructor	Description
SqlServerConnectionUtils()

Method Summary

Modifier and Type	Method	Description
static io.debezium.connector.sqlserver.SqlServerConnection	createSqlServerConnection(io.debezium.relational.RelationalDatabaseConnectorConfig connectorConfig)
static List<io.debezium.relational.TableId>	listTables(io.debezium.jdbc.JdbcConnection jdbc, RelationalTableFilters tableFilters, List<String> databaseList)

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlServerConnectionUtils

public SqlServerConnectionUtils()

Method Detail

createSqlServerConnection

public static io.debezium.connector.sqlserver.SqlServerConnection createSqlServerConnection(io.debezium.relational.RelationalDatabaseConnectorConfig connectorConfig)

listTables

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

Throws:

SQLException