org.apache.flink.connector.jdbc.postgres.database.catalog

类 PostgresCatalog

java.lang.Object

org.apache.flink.table.catalog.AbstractCatalog

org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog

org.apache.flink.connector.jdbc.postgres.database.catalog.PostgresCatalog

所有已实现的接口:

Serializable, org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalog, org.apache.flink.table.catalog.Catalog

@Internal
public class PostgresCatalog
extends org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog

Catalog for PostgreSQL.

另请参阅:

序列化表格

字段概要

字段

限定符和类型	字段和说明
static String	DEFAULT_DATABASE
protected org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalogTypeMapper	dialectTypeMapper

从类继承的字段 org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog

baseUrl, connectionProperties, defaultUrl, userClassLoader

构造器概要

构造器

限定符	构造器和说明
protected	PostgresCatalog(ClassLoader userClassLoader, String catalogName, String defaultDatabase, String baseUrl, org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalogTypeMapper dialectTypeMapper, Properties connectProperties)
	PostgresCatalog(ClassLoader userClassLoader, String catalogName, String defaultDatabase, String baseUrl, Properties connectProperties)
	PostgresCatalog(ClassLoader userClassLoader, String catalogName, String defaultDatabase, String username, String pwd, String baseUrl)
protected	PostgresCatalog(ClassLoader userClassLoader, String catalogName, String defaultDatabase, String username, String pwd, String baseUrl, org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalogTypeMapper dialectTypeMapper) 已过时。

方法概要

限定符和类型	方法和说明
protected org.apache.flink.table.types.DataType	fromJDBCType(org.apache.flink.table.catalog.ObjectPath tablePath, ResultSetMetaData metadata, int colIndex) Converts Postgres type to Flink DataType.
protected Set<String>	getBuiltinSchemas()
protected List<String>	getPureTables(Connection conn, List<String> schemas)
protected String	getSchemaName(org.apache.flink.table.catalog.ObjectPath tablePath)
protected String	getSchemaTableName(org.apache.flink.table.catalog.ObjectPath tablePath)
protected String	getTableName(org.apache.flink.table.catalog.ObjectPath tablePath)
List<String>	listDatabases()
List<String>	listTables(String databaseName)
boolean	tableExists(org.apache.flink.table.catalog.ObjectPath tablePath)

从类继承的方法 org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog

alterDatabase, alterFunction, alterPartition, alterPartitionColumnStatistics, alterPartitionStatistics, alterTable, alterTableColumnStatistics, alterTableStatistics, close, createDatabase, createFunction, createPartition, createTable, databaseExists, dropDatabase, dropFunction, dropPartition, dropTable, equals, extractColumnValuesBySQL, extractColumnValuesByStatement, functionExists, getBaseUrl, getDatabase, getDatabaseUrl, getFactory, getFunction, getOptions, getPartition, getPartitionColumnStatistics, getPartitionStatistics, getPassword, getPrimaryKey, getTable, getTableColumnStatistics, getTableStatistics, getUsername, hashCode, listFunctions, listPartitions, listPartitions, listPartitionsByFilter, listViews, open, partitionExists, renameTable, validateJdbcUrl

从类继承的方法 org.apache.flink.table.catalog.AbstractCatalog

getDefaultDatabase, getName

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.flink.table.catalog.Catalog

alterTable, bulkGetPartitionColumnStatistics, bulkGetPartitionStatistics, dropDatabase, getDefaultDatabase, getFunctionDefinitionFactory, getProcedure, getTable, getTableFactory, listProcedures, supportsManagedTable

字段详细资料

DEFAULT_DATABASE

public static final String DEFAULT_DATABASE

另请参阅:

常量字段值

dialectTypeMapper

protected final org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalogTypeMapper dialectTypeMapper

构造器详细资料

PostgresCatalog

@VisibleForTesting
public PostgresCatalog(ClassLoader userClassLoader,
                                          String catalogName,
                                          String defaultDatabase,
                                          String username,
                                          String pwd,
                                          String baseUrl)

PostgresCatalog

public PostgresCatalog(ClassLoader userClassLoader,
                       String catalogName,
                       String defaultDatabase,
                       String baseUrl,
                       Properties connectProperties)

PostgresCatalog

@Deprecated
protected PostgresCatalog(ClassLoader userClassLoader,
                                      String catalogName,
                                      String defaultDatabase,
                                      String username,
                                      String pwd,
                                      String baseUrl,
                                      org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalogTypeMapper dialectTypeMapper)

已过时。

PostgresCatalog

protected PostgresCatalog(ClassLoader userClassLoader,
                          String catalogName,
                          String defaultDatabase,
                          String baseUrl,
                          org.apache.flink.connector.jdbc.core.database.catalog.JdbcCatalogTypeMapper dialectTypeMapper,
                          Properties connectProperties)

方法详细资料

listDatabases

public List<String> listDatabases()
                           throws org.apache.flink.table.catalog.exceptions.CatalogException

抛出:

org.apache.flink.table.catalog.exceptions.CatalogException

getBuiltinSchemas

protected Set<String> getBuiltinSchemas()

getPureTables

protected List<String> getPureTables(Connection conn,
                                     List<String> schemas)
                              throws SQLException

抛出:

SQLException

listTables

public List<String> listTables(String databaseName)
                        throws org.apache.flink.table.catalog.exceptions.DatabaseNotExistException,
                               org.apache.flink.table.catalog.exceptions.CatalogException

抛出:

org.apache.flink.table.catalog.exceptions.DatabaseNotExistException

org.apache.flink.table.catalog.exceptions.CatalogException

fromJDBCType

protected org.apache.flink.table.types.DataType fromJDBCType(org.apache.flink.table.catalog.ObjectPath tablePath,
                                                             ResultSetMetaData metadata,
                                                             int colIndex)
                                                      throws SQLException

Converts Postgres type to Flink DataType.

覆盖:

fromJDBCType 在类中 org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog

抛出:

SQLException

另请参阅:

org.postgresql.jdbc.TypeInfoCache

tableExists

public boolean tableExists(org.apache.flink.table.catalog.ObjectPath tablePath)
                    throws org.apache.flink.table.catalog.exceptions.CatalogException

抛出:

org.apache.flink.table.catalog.exceptions.CatalogException

getTableName

protected String getTableName(org.apache.flink.table.catalog.ObjectPath tablePath)

覆盖:

getTableName 在类中 org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog

getSchemaName

protected String getSchemaName(org.apache.flink.table.catalog.ObjectPath tablePath)

覆盖:

getSchemaName 在类中 org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog

getSchemaTableName

protected String getSchemaTableName(org.apache.flink.table.catalog.ObjectPath tablePath)

覆盖:

getSchemaTableName 在类中 org.apache.flink.connector.jdbc.core.database.catalog.AbstractJdbcCatalog