Replace the deprecated method getCause with cause method

trinodb · Mar 17, 2023 · f29512b · f29512b
1 parent 53b3d9f
commit f29512b
Show file tree

Hide file tree

Showing 9 changed files with 12 additions and 12 deletions.
diff --git a/...o-delta-lake/src/test/java/io/trino/plugin/deltalake/BaseDeltaLakeMinioConnectorTest.java b/...o-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
@@ -327,7 +327,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-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
@@ -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
@@ -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/.../trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlTypeMapping.java b/.../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/...no-raptor-legacy/src/test/java/io/trino/plugin/raptor/legacy/BaseRaptorConnectorTest.java b/...no-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
@@ -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
@@ -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);
     }