navis opened a new pull request, #27840:
URL: https://github.com/apache/flink/pull/27840
The most of codes/descriptions are made by claude
## DatabaseMetaData
- getTables(catalog, schemaPattern, tableNamePattern, types) — Lists tables
and views across catalogs/schemas using SHOW TABLES and SHOW VIEWS SQL
statements. Supports filtering by table name pattern (SQL % and _ wildcards)
and table type (TABLE, VIEW).
- getColumns(catalog, schemaPattern, tableNamePattern, columnNamePattern) —
Retrieves column metadata (name, JDBC type, nullability, ordinal position) by
executing SELECT * FROM <table> LIMIT 0 and inspecting the ResolvedSchema. Maps
Flink logical types to JDBC java.sql.Types constants.
- getSchemas(catalog, schemaPattern) — Previously threw
UnsupportedOperationException. Now properly implemented with catalog and schema
pattern filtering via SHOW DATABASES IN <catalog>. The no-arg getSchemas() is
refactored to delegate to this method.
- getPrimaryKeys(catalog, schema, table) — Returns primary key information
from the table's ResolvedSchema when available.
- getTableTypes() — Returns the supported table types: TABLE and VIEW.
## FlinkResultSet
- ROW type — Converted to Map<String, Object> preserving field names and
values.
- ARRAY type — Converted to List<Object> with proper element type
conversion.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
