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

Class PostgresSchemaUtils

java.lang.Object

org.apache.flink.cdc.connectors.postgres.utils.PostgresSchemaUtils

public class PostgresSchemaUtils
extends Object

Utilities for converting from debezium Table types to Schema.

Constructor Summary

Constructors

Constructor	Description
PostgresSchemaUtils()

Method Summary

Modifier and Type	Method	Description
static PostgresDialect	getPostgresDialect(PostgresSourceConfig sourceConfig)
static Schema	getTableSchema(io.debezium.relational.TableId tableId, PostgresSourceConfig sourceConfig, PostgresConnection jdbc)
static Schema	getTableSchema(TableId tableId, PostgresSourceConfig sourceConfig, PostgresConnection jdbc)
static Schema	getTableSchema(PostgresSourceConfig sourceConfig, TableId tableId)
static List<String>	listNamespaces(io.debezium.jdbc.JdbcConnection jdbc)
static List<String>	listNamespaces(PostgresSourceConfig sourceConfig)
static List<String>	listSchemas(io.debezium.jdbc.JdbcConnection jdbc, String namespace)
static List<String>	listSchemas(PostgresSourceConfig sourceConfig, String namespace)
static List<TableId>	listTables(PostgresSourceConfig sourceConfig, String dbName)
static String	quote(String dbOrTableName)
static TableId	toCdcTableId(io.debezium.relational.TableId dbzTableId)
static TableId	toCdcTableId(io.debezium.relational.TableId dbzTableId, String databaseName, boolean includeDatabaseInTableId)
static Column	toColumn(io.debezium.relational.Column column, io.debezium.connector.postgresql.PostgresConnectorConfig dbzConfig, io.debezium.connector.postgresql.TypeRegistry typeRegistry)
static io.debezium.relational.TableId	toDbzTableId(TableId tableId)
static Schema	toSchema(io.debezium.relational.Table table, io.debezium.connector.postgresql.PostgresConnectorConfig dbzConfig, io.debezium.connector.postgresql.TypeRegistry typeRegistry)

Methods inherited from class java.lang.Object

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

Constructor Detail

PostgresSchemaUtils

public PostgresSchemaUtils()

Method Detail

listSchemas

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

listNamespaces

public static List<String> listNamespaces(PostgresSourceConfig sourceConfig)

listTables

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

getTableSchema

public static Schema getTableSchema(PostgresSourceConfig sourceConfig,
                                    TableId tableId)

getPostgresDialect

public static PostgresDialect getPostgresDialect(PostgresSourceConfig 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,
                                    PostgresSourceConfig sourceConfig,
                                    PostgresConnection jdbc)

getTableSchema

public static Schema getTableSchema(io.debezium.relational.TableId tableId,
                                    PostgresSourceConfig sourceConfig,
                                    PostgresConnection jdbc)

toSchema

public static Schema toSchema(io.debezium.relational.Table table,
                              io.debezium.connector.postgresql.PostgresConnectorConfig dbzConfig,
                              io.debezium.connector.postgresql.TypeRegistry typeRegistry)

toColumn

public static Column toColumn(io.debezium.relational.Column column,
                              io.debezium.connector.postgresql.PostgresConnectorConfig dbzConfig,
                              io.debezium.connector.postgresql.TypeRegistry typeRegistry)

toDbzTableId

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

toCdcTableId

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

toCdcTableId

public static TableId toCdcTableId(io.debezium.relational.TableId dbzTableId,
                                   String databaseName,
                                   boolean includeDatabaseInTableId)