Package org.apache.flink.table.jdbc.utils

Class DatabaseMetaDataUtils

java.lang.Object

org.apache.flink.table.jdbc.utils.DatabaseMetaDataUtils

public class DatabaseMetaDataUtils
extends Object

Utils to create catalog/schema results for FlinkDatabaseMetaData.

Constructor Summary

Constructors

Constructor	Description
DatabaseMetaDataUtils()

Method Summary

Modifier and Type	Method	Description
static FlinkResultSet	createCatalogsResultSet(Statement statement, org.apache.flink.table.client.gateway.StatementResult result)	Create result set for catalogs.
static FlinkResultSet	createSchemasResultSet(Statement statement, List<String> catalogs, Map<String,List<String>> catalogSchemas)	Create result set for schemas.

Methods inherited from class java.lang.Object

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

Constructor Detail

DatabaseMetaDataUtils

public DatabaseMetaDataUtils()

Method Detail

createCatalogsResultSet

public static FlinkResultSet createCatalogsResultSet(Statement statement,
                                                     org.apache.flink.table.client.gateway.StatementResult result)

Create result set for catalogs. The schema columns are:

• TABLE_CAT String => catalog name.

The results are ordered by catalog name.

Parameters:

statement - The statement for database meta data

result - The result for catalogs

Returns:

a ResultSet object in which each row has a single String column that is a catalog name

createSchemasResultSet

public static FlinkResultSet createSchemasResultSet(Statement statement,
                                                    List<String> catalogs,
                                                    Map<String,List<String>> catalogSchemas)

Create result set for schemas. The schema columns are:

• TABLE_SCHEM String => schema name
• TABLE_CATALOG String => catalog name (may be null)

The results are ordered by TABLE_CATALOG and TABLE_SCHEM.

Parameters:

statement - The statement for database meta data

catalogs - The catalog list

catalogSchemas - The catalog with schema list

Returns:

a ResultSet object in which each row is a schema description