diff --git a/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlCaseInsensitiveMapping.java b/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlCaseInsensitiveMapping.java index 96e8be30b5f09..03c5a83fec09a 100644 --- a/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlCaseInsensitiveMapping.java +++ b/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlCaseInsensitiveMapping.java @@ -43,11 +43,7 @@ public class TestPostgreSqlCaseInsensitiveMapping protected QueryRunner createQueryRunner() throws Exception { - postgreSqlServer = new TestingPostgreSqlServer(); - closeAfterClass(() -> { - postgreSqlServer.close(); - postgreSqlServer = null; - }); + postgreSqlServer = closeAfterClass(new TestingPostgreSqlServer()); return PostgreSqlQueryRunner.createPostgreSqlQueryRunner( postgreSqlServer, ImmutableMap.of(), diff --git a/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlConnectorTest.java b/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlConnectorTest.java index 3f2a74a03c80c..5604d9827644e 100644 --- a/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlConnectorTest.java +++ b/plugin/trino-postgresql/src/test/java/io/trino/plugin/postgresql/TestPostgreSqlConnectorTest.java @@ -62,11 +62,7 @@ public class TestPostgreSqlConnectorTest protected QueryRunner createQueryRunner() throws Exception { - postgreSqlServer = new TestingPostgreSqlServer(); - closeAfterClass(() -> { - postgreSqlServer.close(); - postgreSqlServer = null; - }); + postgreSqlServer = closeAfterClass(new TestingPostgreSqlServer()); return createPostgreSqlQueryRunner(postgreSqlServer, Map.of(), Map.of(), REQUIRED_TPCH_TABLES); } 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 9260048a69896..3e487af96957d 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 @@ -151,11 +151,7 @@ public class TestPostgreSqlTypeMapping protected QueryRunner createQueryRunner() throws Exception { - postgreSqlServer = new TestingPostgreSqlServer(); - closeAfterClass(() -> { - postgreSqlServer.close(); - postgreSqlServer = null; - }); + postgreSqlServer = closeAfterClass(new TestingPostgreSqlServer()); return createPostgreSqlQueryRunner( postgreSqlServer, ImmutableMap.of(),