Skip to content

Commit 90c745d

Browse files
dependabot[bot]ebyhr
authored andcommitted
Bump dep.trino.version from 474 to 479
Bumps `dep.trino.version` from 474 to 479. Updates `io.trino:trino-parser` from 474 to 479 Updates `io.trino:trino-jdbc` from 474 to 479 Updates `io.trino:trino-client` from 474 to 479 - [Release notes](https://github.com/trinodb/trino/releases) - [Changelog](https://github.com/trinodb/trino/blob/master/docs/release-template.md) - [Commits](https://github.com/trinodb/trino/commits) --- updated-dependencies: - dependency-name: io.trino:trino-parser dependency-version: '479' dependency-type: direct:production update-type: version-update:semver-major - dependency-name: io.trino:trino-jdbc dependency-version: '479' dependency-type: direct:production update-type: version-update:semver-major - dependency-name: io.trino:trino-client dependency-version: '479' dependency-type: direct:development update-type: version-update:semver-major ... Signed-off-by: dependabot[bot] <[email protected]>
1 parent 3b7019b commit 90c745d

File tree

3 files changed

+12
-13
lines changed

3 files changed

+12
-13
lines changed

gateway-ha/pom.xml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -26,7 +26,7 @@
2626
<dep.jeasy.version>4.1.0</dep.jeasy.version>
2727
<dep.mockito.version>5.21.0</dep.mockito.version>
2828
<dep.okhttp3.version>5.3.2</dep.okhttp3.version>
29-
<dep.trino.version>474</dep.trino.version>
29+
<dep.trino.version>479</dep.trino.version>
3030
</properties>
3131

3232
<dependencyManagement>

gateway-ha/src/main/java/io/trino/gateway/ha/router/StatementUtils.java

Lines changed: 2 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -61,16 +61,14 @@
6161
import io.trino.sql.tree.Revoke;
6262
import io.trino.sql.tree.RevokeRoles;
6363
import io.trino.sql.tree.Rollback;
64+
import io.trino.sql.tree.SetAuthorizationStatement;
6465
import io.trino.sql.tree.SetColumnType;
6566
import io.trino.sql.tree.SetPath;
6667
import io.trino.sql.tree.SetProperties;
6768
import io.trino.sql.tree.SetRole;
68-
import io.trino.sql.tree.SetSchemaAuthorization;
6969
import io.trino.sql.tree.SetSession;
7070
import io.trino.sql.tree.SetSessionAuthorization;
71-
import io.trino.sql.tree.SetTableAuthorization;
7271
import io.trino.sql.tree.SetTimeZone;
73-
import io.trino.sql.tree.SetViewAuthorization;
7472
import io.trino.sql.tree.ShowCatalogs;
7573
import io.trino.sql.tree.ShowColumns;
7674
import io.trino.sql.tree.ShowCreate;
@@ -181,13 +179,11 @@ private StatementUtils() {}
181179
.add(basicStatement(DropNotNullConstraint.class, DATA_DEFINITION))
182180
.add(basicStatement(SetPath.class, DATA_DEFINITION))
183181
.add(basicStatement(SetRole.class, DATA_DEFINITION))
184-
.add(basicStatement(SetSchemaAuthorization.class, DATA_DEFINITION))
182+
.add(basicStatement(SetAuthorizationStatement.class, DATA_DEFINITION))
185183
.add(basicStatement(SetSession.class, DATA_DEFINITION))
186184
.add(basicStatement(SetSessionAuthorization.class, DATA_DEFINITION))
187185
.add(basicStatement(SetProperties.class, DATA_DEFINITION))
188-
.add(basicStatement(SetTableAuthorization.class, DATA_DEFINITION))
189186
.add(basicStatement(SetTimeZone.class, DATA_DEFINITION))
190-
.add(basicStatement(SetViewAuthorization.class, DATA_DEFINITION))
191187
.add(basicStatement(StartTransaction.class, DATA_DEFINITION))
192188
.add(basicStatement(Use.class, DATA_DEFINITION))
193189
.build().stream()

gateway-ha/src/main/java/io/trino/gateway/ha/router/TrinoQueryProperties.java

Lines changed: 9 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -53,10 +53,8 @@
5353
import io.trino.sql.tree.RenameSchema;
5454
import io.trino.sql.tree.RenameTable;
5555
import io.trino.sql.tree.RenameView;
56+
import io.trino.sql.tree.SetAuthorizationStatement;
5657
import io.trino.sql.tree.SetProperties;
57-
import io.trino.sql.tree.SetSchemaAuthorization;
58-
import io.trino.sql.tree.SetTableAuthorization;
59-
import io.trino.sql.tree.SetViewAuthorization;
6058
import io.trino.sql.tree.ShowColumns;
6159
import io.trino.sql.tree.ShowCreate;
6260
import io.trino.sql.tree.ShowSchemas;
@@ -420,9 +418,14 @@ private void visitNode(Node node, ImmutableSet.Builder<QualifiedName> tableBuild
420418
}
421419
case ShowSchemas s -> catalogBuilder.add(s.getCatalog().map(Identifier::getValue).or(() -> defaultCatalog).orElseThrow(this::unsetDefaultExceptionSupplier));
422420
case ShowTables s -> setCatalogAndSchemaNameFromSchemaQualifiedName(s.getSchema(), catalogBuilder, schemaBuilder, catalogSchemaBuilder);
423-
case SetSchemaAuthorization s -> setCatalogAndSchemaNameFromSchemaQualifiedName(Optional.of(s.getSource()), catalogBuilder, schemaBuilder, catalogSchemaBuilder);
424-
case SetTableAuthorization s -> tableBuilder.add(qualifyName(s.getSource()));
425-
case SetViewAuthorization s -> tableBuilder.add(qualifyName(s.getSource()));
421+
case SetAuthorizationStatement setAuthorization -> {
422+
if (setAuthorization.getOwnedEntityKind().equals("SCHEMA")) {
423+
setCatalogAndSchemaNameFromSchemaQualifiedName(Optional.of(setAuthorization.getSource()), catalogBuilder, schemaBuilder, catalogSchemaBuilder);
424+
}
425+
else {
426+
tableBuilder.add(qualifyName(setAuthorization.getSource()));
427+
}
428+
}
426429
case Table s -> {
427430
// ignore temporary tables as they can have various table parts
428431
if (!temporaryTables.contains(s.getName())) {

0 commit comments

Comments
 (0)