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

Class SqlServerMetadataAccessor

java.lang.Object

org.apache.flink.cdc.connectors.sqlserver.source.SqlServerMetadataAccessor

All Implemented Interfaces:

MetadataAccessor

@Internal
public class SqlServerMetadataAccessor
extends Object
implements MetadataAccessor

MetadataAccessor for SqlServerDataSource.

Constructor Summary

Constructors

Constructor	Description
SqlServerMetadataAccessor(SqlServerSourceConfig sourceConfig)

Method Summary

Modifier and Type	Method	Description
Schema	getTableSchema(TableId tableId)	Get the Schema of the given table.
List<String>	listNamespaces()	List all databases from SQL Server.
List<String>	listSchemas(String namespace)	List all schemas from SQL Server database.
List<TableId>	listTables(String namespace, String schemaName)	List tables from SQL Server.

Methods inherited from class java.lang.Object

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

Constructor Detail

SqlServerMetadataAccessor

public SqlServerMetadataAccessor(SqlServerSourceConfig sourceConfig)

Method Detail

listNamespaces

public List<String> listNamespaces()

List all databases from SQL Server.

Specified by:

listNamespaces in interface MetadataAccessor

Returns:

The list of database names

listSchemas

public List<String> listSchemas(@Nullable
                                String namespace)

List all schemas from SQL Server database.

Specified by:

listSchemas in interface MetadataAccessor

Parameters:

namespace - The database name to list schemas from.

Returns:

The list of schema names

listTables

public List<TableId> listTables(@Nullable
                                String namespace,
                                @Nullable
                                String schemaName)

List tables from SQL Server.

Specified by:

listTables in interface MetadataAccessor

Parameters:

namespace - The database name. If null, uses the configured database.

schemaName - The schema name. If null, list tables from all schemas.

Returns:

The list of TableIds.

getTableSchema

public Schema getTableSchema(TableId tableId)

Get the Schema of the given table.

Specified by:

getTableSchema in interface MetadataAccessor

Parameters:

tableId - The TableId of the given table.

Returns:

The Schema of the table.