diff --git a/core/trino-main/src/main/java/io/trino/connector/system/MaterializedViewSystemTable.java b/core/trino-main/src/main/java/io/trino/connector/system/MaterializedViewSystemTable.java index f08b3e767088..00b7b0c30476 100644 --- a/core/trino-main/src/main/java/io/trino/connector/system/MaterializedViewSystemTable.java +++ b/core/trino-main/src/main/java/io/trino/connector/system/MaterializedViewSystemTable.java @@ -16,7 +16,6 @@ import io.trino.FullConnectorSession; import io.trino.Session; import io.trino.metadata.Metadata; -import io.trino.metadata.MetadataListing; import io.trino.metadata.QualifiedObjectName; import io.trino.metadata.QualifiedTablePrefix; import io.trino.metadata.ViewInfo; @@ -40,6 +39,7 @@ import static io.trino.connector.system.jdbc.FilterUtil.tablePrefix; import static io.trino.connector.system.jdbc.FilterUtil.tryGetSingleVarcharValue; import static io.trino.metadata.MetadataListing.getMaterializedViews; +import static io.trino.metadata.MetadataListing.listCatalogNames; import static io.trino.metadata.MetadataUtil.TableMetadataBuilder.tableMetadataBuilder; import static io.trino.spi.connector.SystemTable.Distribution.SINGLE_COORDINATOR; import static io.trino.spi.type.BooleanType.BOOLEAN; @@ -97,7 +97,7 @@ public RecordCursor cursor( Optional schemaFilter = tryGetSingleVarcharValue(constraint, 1); Optional tableFilter = tryGetSingleVarcharValue(constraint, 2); - MetadataListing.listCatalogNames(session, metadata, accessControl, catalogFilter).forEach(catalogName -> { + listCatalogNames(session, metadata, accessControl, catalogFilter).forEach(catalogName -> { QualifiedTablePrefix tablePrefix = tablePrefix(catalogName, schemaFilter, tableFilter); getMaterializedViews(session, metadata, accessControl, tablePrefix).forEach((tableName, definition) -> { diff --git a/core/trino-main/src/main/java/io/trino/connector/system/TableCommentSystemTable.java b/core/trino-main/src/main/java/io/trino/connector/system/TableCommentSystemTable.java index 3166ef2aa0a6..81537e945533 100644 --- a/core/trino-main/src/main/java/io/trino/connector/system/TableCommentSystemTable.java +++ b/core/trino-main/src/main/java/io/trino/connector/system/TableCommentSystemTable.java @@ -19,7 +19,6 @@ import io.trino.FullConnectorSession; import io.trino.Session; import io.trino.metadata.Metadata; -import io.trino.metadata.MetadataListing; import io.trino.metadata.QualifiedObjectName; import io.trino.metadata.QualifiedTablePrefix; import io.trino.metadata.ViewInfo; @@ -46,6 +45,7 @@ import static io.trino.connector.system.jdbc.FilterUtil.tryGetSingleVarcharValue; import static io.trino.metadata.MetadataListing.getMaterializedViews; import static io.trino.metadata.MetadataListing.getViews; +import static io.trino.metadata.MetadataListing.listCatalogNames; import static io.trino.metadata.MetadataListing.listTables; import static io.trino.metadata.MetadataUtil.TableMetadataBuilder.tableMetadataBuilder; import static io.trino.spi.connector.SystemTable.Distribution.SINGLE_COORDINATOR; @@ -98,7 +98,7 @@ public RecordCursor cursor(ConnectorTransactionHandle transactionHandle, Connect Session session = ((FullConnectorSession) connectorSession).getSession(); Builder table = InMemoryRecordSet.builder(COMMENT_TABLE); - for (String catalog : MetadataListing.listCatalogNames(session, metadata, accessControl, catalogFilter)) { + for (String catalog : listCatalogNames(session, metadata, accessControl, catalogFilter)) { QualifiedTablePrefix prefix = tablePrefix(catalog, schemaFilter, tableFilter); Set names = ImmutableSet.of(); diff --git a/core/trino-main/src/main/java/io/trino/connector/system/jdbc/CatalogJdbcTable.java b/core/trino-main/src/main/java/io/trino/connector/system/jdbc/CatalogJdbcTable.java index eed838517d8c..cac5b083204c 100644 --- a/core/trino-main/src/main/java/io/trino/connector/system/jdbc/CatalogJdbcTable.java +++ b/core/trino-main/src/main/java/io/trino/connector/system/jdbc/CatalogJdbcTable.java @@ -16,7 +16,6 @@ import io.trino.FullConnectorSession; import io.trino.Session; import io.trino.metadata.Metadata; -import io.trino.metadata.MetadataListing; import io.trino.security.AccessControl; import io.trino.spi.connector.ConnectorSession; import io.trino.spi.connector.ConnectorTableMetadata; @@ -29,6 +28,7 @@ import javax.inject.Inject; +import static io.trino.metadata.MetadataListing.listCatalogNames; import static io.trino.metadata.MetadataUtil.TableMetadataBuilder.tableMetadataBuilder; import static io.trino.spi.type.VarcharType.createUnboundedVarcharType; import static java.util.Objects.requireNonNull; @@ -63,7 +63,7 @@ public RecordCursor cursor(ConnectorTransactionHandle transactionHandle, Connect { Session session = ((FullConnectorSession) connectorSession).getSession(); Builder table = InMemoryRecordSet.builder(METADATA); - for (String name : MetadataListing.listCatalogNames(session, metadata, accessControl)) { + for (String name : listCatalogNames(session, metadata, accessControl)) { table.addRow(name); } return table.build().cursor(); diff --git a/core/trino-main/src/main/java/io/trino/sql/rewrite/ShowQueriesRewrite.java b/core/trino-main/src/main/java/io/trino/sql/rewrite/ShowQueriesRewrite.java index 0db6338c102a..144f91d8c977 100644 --- a/core/trino-main/src/main/java/io/trino/sql/rewrite/ShowQueriesRewrite.java +++ b/core/trino-main/src/main/java/io/trino/sql/rewrite/ShowQueriesRewrite.java @@ -29,7 +29,6 @@ import io.trino.metadata.MaterializedViewDefinition; import io.trino.metadata.MaterializedViewPropertyManager; import io.trino.metadata.Metadata; -import io.trino.metadata.MetadataListing; import io.trino.metadata.MetadataUtil; import io.trino.metadata.QualifiedObjectName; import io.trino.metadata.RedirectionAwareTableHandle; @@ -107,6 +106,8 @@ import static io.trino.connector.informationschema.InformationSchemaTable.SCHEMATA; import static io.trino.connector.informationschema.InformationSchemaTable.TABLES; import static io.trino.connector.informationschema.InformationSchemaTable.TABLE_PRIVILEGES; +import static io.trino.metadata.MetadataListing.listCatalogNames; +import static io.trino.metadata.MetadataListing.listCatalogs; import static io.trino.metadata.MetadataListing.listSchemas; import static io.trino.metadata.MetadataUtil.createCatalogSchemaName; import static io.trino.metadata.MetadataUtil.createQualifiedObjectName; @@ -442,7 +443,7 @@ protected Node visitShowSchemas(ShowSchemas node, Void context) @Override protected Node visitShowCatalogs(ShowCatalogs node, Void context) { - List rows = MetadataListing.listCatalogNames(session, metadata, accessControl).stream() + List rows = listCatalogNames(session, metadata, accessControl).stream() .map(name -> row(new StringLiteral(name))) .collect(toImmutableList()); @@ -830,7 +831,7 @@ private static String getFunctionType(FunctionMetadata function) protected Node visitShowSession(ShowSession node, Void context) { ImmutableList.Builder rows = ImmutableList.builder(); - List catalogInfos = MetadataListing.listCatalogs(session, metadata, accessControl); + List catalogInfos = listCatalogs(session, metadata, accessControl); List sessionProperties = sessionPropertyManager.getAllSessionProperties(session, catalogInfos); for (SessionPropertyValue sessionProperty : sessionProperties) { if (sessionProperty.isHidden()) {