diff --git a/lib/trino-plugin-toolkit/src/test/java/io/trino/plugin/base/security/BaseFileBasedSystemAccessControlTest.java b/lib/trino-plugin-toolkit/src/test/java/io/trino/plugin/base/security/BaseFileBasedSystemAccessControlTest.java index 2fa79c6a4bf7..532e10ad4339 100644 --- a/lib/trino-plugin-toolkit/src/test/java/io/trino/plugin/base/security/BaseFileBasedSystemAccessControlTest.java +++ b/lib/trino-plugin-toolkit/src/test/java/io/trino/plugin/base/security/BaseFileBasedSystemAccessControlTest.java @@ -1011,7 +1011,7 @@ public void testQuery() public void testInvalidQuery() { assertThatThrownBy(() -> newFileBasedSystemAccessControl("query-invalid.json")) - .getRootCause().hasMessage("A valid query rule cannot combine an queryOwner condition with access mode 'execute'"); + .rootCause().hasMessage("A valid query rule cannot combine an queryOwner condition with access mode 'execute'"); } @Test diff --git a/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/BaseDeltaLakeMinioConnectorTest.java b/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/BaseDeltaLakeMinioConnectorTest.java index 2abc136075ab..f97744570b6f 100644 --- a/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/BaseDeltaLakeMinioConnectorTest.java +++ b/plugin/trino-delta-lake/src/test/java/io/trino/plugin/deltalake/BaseDeltaLakeMinioConnectorTest.java @@ -140,7 +140,7 @@ protected void verifyConcurrentUpdateFailurePermissible(Exception e) { assertThat(e) .hasMessage("Failed to write Delta Lake transaction log entry") - .getCause() + .cause() .hasMessageMatching( "Transaction log locked.*" + "|.*/_delta_log/\\d+.json already exists" + @@ -154,7 +154,7 @@ protected void verifyConcurrentInsertFailurePermissible(Exception e) { assertThat(e) .hasMessage("Failed to write Delta Lake transaction log entry") - .getCause() + .cause() .hasMessageMatching( "Transaction log locked.*" + "|.*/_delta_log/\\d+.json already exists" + @@ -168,7 +168,7 @@ protected void verifyConcurrentAddColumnFailurePermissible(Exception e) { assertThat(e) .hasMessageMatching("Unable to add '.*' column for: .*") - .getCause() + .cause() .hasMessageMatching( "Transaction log locked.*" + "|.*/_delta_log/\\d+.json already exists" + diff --git a/plugin/trino-hive/src/test/java/io/trino/plugin/hive/BaseHiveConnectorTest.java b/plugin/trino-hive/src/test/java/io/trino/plugin/hive/BaseHiveConnectorTest.java index 8bbe28ebed25..e2303c7e303d 100644 --- a/plugin/trino-hive/src/test/java/io/trino/plugin/hive/BaseHiveConnectorTest.java +++ b/plugin/trino-hive/src/test/java/io/trino/plugin/hive/BaseHiveConnectorTest.java @@ -323,7 +323,7 @@ public void testUpdateRowConcurrently() // TODO (https://github.com/trinodb/trino/issues/10518) test this with a TestHiveConnectorTest version that creates ACID tables by default, or in some other way assertThatThrownBy(super::testUpdateRowConcurrently) .hasMessage("Unexpected concurrent update failure") - .getCause() + .cause() .hasMessage(MODIFYING_NON_TRANSACTIONAL_TABLE_MESSAGE); } diff --git a/plugin/trino-hive/src/test/java/io/trino/plugin/hive/s3/TestS3WrongRegionPicked.java b/plugin/trino-hive/src/test/java/io/trino/plugin/hive/s3/TestS3WrongRegionPicked.java index cc8240333754..390fee01923b 100644 --- a/plugin/trino-hive/src/test/java/io/trino/plugin/hive/s3/TestS3WrongRegionPicked.java +++ b/plugin/trino-hive/src/test/java/io/trino/plugin/hive/s3/TestS3WrongRegionPicked.java @@ -38,7 +38,7 @@ public void testS3WrongRegionSelection() String tableName = "s3_region_test_" + randomNameSuffix(); queryRunner.execute("CREATE TABLE default." + tableName + " (a int) WITH (external_location = 's3://" + bucketName + "/" + tableName + "')"); assertThatThrownBy(() -> queryRunner.execute("SELECT * FROM default." + tableName)) - .getRootCause() + .rootCause() .hasMessageContaining("Status Code: 400") .hasMessageContaining("Error Code: AuthorizationHeaderMalformed"); // That is how Minio reacts to bad region } diff --git a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java index 50b0be97946e..b05b558188d4 100644 --- a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java +++ b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/BaseIcebergConnectorTest.java @@ -231,7 +231,7 @@ protected void verifyConcurrentAddColumnFailurePermissible(Exception e) { assertThat(e) .hasMessageStartingWith("Failed to add column: Failed to replace table due to concurrent updates") - .getRootCause() + .rootCause() .hasMessageContaining("Cannot update Iceberg table: supplied previous location does not match current location"); } diff --git a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergV2.java b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergV2.java index efca9561dd5f..8616b6356c50 100644 --- a/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergV2.java +++ b/plugin/trino-iceberg/src/test/java/io/trino/plugin/iceberg/TestIcebergV2.java @@ -353,7 +353,7 @@ public void testDowngradingV2TableToV1Fails() assertEquals(loadTable(tableName).operations().current().formatVersion(), 2); assertThatThrownBy(() -> query("ALTER TABLE " + tableName + " SET PROPERTIES format_version = 1")) .hasMessage("Failed to set new property values") - .getRootCause() + .rootCause() .hasMessage("Cannot downgrade v2 table to v1"); } diff --git a/plugin/trino-ignite/src/test/java/io/trino/plugin/ignite/TestIgniteConnectorTest.java b/plugin/trino-ignite/src/test/java/io/trino/plugin/ignite/TestIgniteConnectorTest.java index 2a265f4b6dab..f3ade29f59fb 100644 --- a/plugin/trino-ignite/src/test/java/io/trino/plugin/ignite/TestIgniteConnectorTest.java +++ b/plugin/trino-ignite/src/test/java/io/trino/plugin/ignite/TestIgniteConnectorTest.java @@ -161,7 +161,7 @@ public void testCreateTableWithCommaPropertyColumn() String tableWithQuote = "create_table_with_unsupported_quote_column"; String tableDefinitionWithQuote = "(`a\"b` bigint primary key, c varchar)"; assertThatThrownBy(() -> onRemoteDatabase().execute("CREATE TABLE " + tableWithQuote + tableDefinitionWithQuote)) - .getRootCause() + .rootCause() .hasMessageContaining("Failed to parse query"); // Test the property column with comma diff --git a/plugin/trino-ignite/src/test/java/io/trino/plugin/ignite/TestIgniteTypeMapping.java b/plugin/trino-ignite/src/test/java/io/trino/plugin/ignite/TestIgniteTypeMapping.java index 64016dcd4568..a2131cda66b0 100644 --- a/plugin/trino-ignite/src/test/java/io/trino/plugin/ignite/TestIgniteTypeMapping.java +++ b/plugin/trino-ignite/src/test/java/io/trino/plugin/ignite/TestIgniteTypeMapping.java @@ -170,7 +170,7 @@ public void testUnsupportedBigint() private void assertIgniteQueryFailsWithColumnValueOutRange(@Language("SQL") String sql) { assertThatThrownBy(() -> igniteServer.execute(sql)) - .getCause() + .cause() .hasMessageContaining("Value conversion failed"); } diff --git a/plugin/trino-mysql/src/test/java/io/trino/plugin/mysql/TestMySqlTypeMapping.java b/plugin/trino-mysql/src/test/java/io/trino/plugin/mysql/TestMySqlTypeMapping.java index 0f1b41b2b2f5..f262f4f80d61 100644 --- a/plugin/trino-mysql/src/test/java/io/trino/plugin/mysql/TestMySqlTypeMapping.java +++ b/plugin/trino-mysql/src/test/java/io/trino/plugin/mysql/TestMySqlTypeMapping.java @@ -1108,7 +1108,7 @@ private DataSetup mysqlCreateAndInsert(String tableNamePrefix) private void assertMySqlQueryFails(@Language("SQL") String sql, String expectedMessage) { assertThatThrownBy(() -> mySqlServer.execute(sql)) - .getCause() + .cause() .hasMessageContaining(expectedMessage); } } diff --git a/plugin/trino-phoenix5/src/test/java/io/trino/plugin/phoenix5/TestPhoenixTypeMapping.java b/plugin/trino-phoenix5/src/test/java/io/trino/plugin/phoenix5/TestPhoenixTypeMapping.java index 619396d792f5..69f2dd906bda 100644 --- a/plugin/trino-phoenix5/src/test/java/io/trino/plugin/phoenix5/TestPhoenixTypeMapping.java +++ b/plugin/trino-phoenix5/src/test/java/io/trino/plugin/phoenix5/TestPhoenixTypeMapping.java @@ -777,7 +777,7 @@ private Session sessionWithDecimalMappingStrict(UnsupportedTypeHandling unsuppor private void assertPhoenixQueryFails(@Language("SQL") String sql, String expectedMessage) { assertThatThrownBy(() -> new PhoenixSqlExecutor(phoenixServer.getJdbcUrl()).execute(sql)) - .getCause() + .cause() .hasMessageContaining(expectedMessage); } } diff --git a/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlTypeMapping.java b/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlTypeMapping.java index 313555426449..b9b27bcefd20 100644 --- a/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlTypeMapping.java +++ b/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlTypeMapping.java @@ -1917,7 +1917,7 @@ private static void checkIsDoubled(ZoneId zone, LocalDateTime dateTime) private void assertPostgreSqlQueryFails(@Language("SQL") String sql, String expectedMessage) { assertThatThrownBy(() -> postgreSqlServer.execute(sql)) - .getCause() + .cause() .hasMessageContaining(expectedMessage); } } diff --git a/plugin/trino-raptor-legacy/src/test/java/io/trino/plugin/raptor/legacy/BaseRaptorConnectorTest.java b/plugin/trino-raptor-legacy/src/test/java/io/trino/plugin/raptor/legacy/BaseRaptorConnectorTest.java index d8e207e881e8..22406006b80a 100644 --- a/plugin/trino-raptor-legacy/src/test/java/io/trino/plugin/raptor/legacy/BaseRaptorConnectorTest.java +++ b/plugin/trino-raptor-legacy/src/test/java/io/trino/plugin/raptor/legacy/BaseRaptorConnectorTest.java @@ -926,7 +926,7 @@ protected void verifyConcurrentAddColumnFailurePermissible(Exception e) { assertThat(e) .hasMessageContaining("Failed to perform metadata operation") - .getCause() + .cause() .hasMessageMatching( "(?s).*SQLIntegrityConstraintViolationException.*" + "|.*Unique index or primary key violation.*" + diff --git a/plugin/trino-redshift/src/test/java/io/trino/plugin/redshift/TestRedshiftTypeMapping.java b/plugin/trino-redshift/src/test/java/io/trino/plugin/redshift/TestRedshiftTypeMapping.java index 26938c3b6532..64d8d04616c2 100644 --- a/plugin/trino-redshift/src/test/java/io/trino/plugin/redshift/TestRedshiftTypeMapping.java +++ b/plugin/trino-redshift/src/test/java/io/trino/plugin/redshift/TestRedshiftTypeMapping.java @@ -250,7 +250,7 @@ public void checkUnicodeCharInRedshift() try (TestTable table = testTable("check_multibyte_char", "(c char(32))")) { assertThatThrownBy(() -> getRedshiftExecutor() .execute(format("INSERT INTO %s VALUES ('\u968a')", table.getName()))) - .getCause() + .cause() .isInstanceOf(SQLException.class) .hasMessageContaining("CHAR string contains invalid ASCII character"); } @@ -842,7 +842,7 @@ private static void assertRedshiftCreateFails(String tableNamePrefix, String tab try { assertThatThrownBy(() -> getRedshiftExecutor() .execute(format("CREATE TABLE %s %s", tableName, tableBody))) - .getCause() + .cause() .as("Redshift create fails for %s %s", tableName, tableBody) .isInstanceOf(SQLException.class) .hasMessage(message); diff --git a/plugin/trino-sqlserver/src/test/java/io/trino/plugin/sqlserver/BaseSqlServerTypeMapping.java b/plugin/trino-sqlserver/src/test/java/io/trino/plugin/sqlserver/BaseSqlServerTypeMapping.java index 71d2a4579be9..efa58425c123 100644 --- a/plugin/trino-sqlserver/src/test/java/io/trino/plugin/sqlserver/BaseSqlServerTypeMapping.java +++ b/plugin/trino-sqlserver/src/test/java/io/trino/plugin/sqlserver/BaseSqlServerTypeMapping.java @@ -872,7 +872,7 @@ private static void checkIsGap(ZoneId zone, LocalDateTime dateTime) private void assertSqlServerQueryFails(@Language("SQL") String sql, String expectedMessage) { assertThatThrownBy(() -> onRemoteDatabase().execute(sql)) - .getCause() + .cause() .hasMessageContaining(expectedMessage); }