From 8caa1d65003447d27a5df0c323cc47a9f20f616c Mon Sep 17 00:00:00 2001 From: Piotr Findeisen Date: Mon, 22 Mar 2021 23:45:19 +0100 Subject: [PATCH] Simplify cleanup --- .../postgresql/TestPostgreSqlCaseInsensitiveMapping.java | 6 +----- .../plugin/postgresql/TestPostgreSqlConnectorTest.java | 6 +----- .../trino/plugin/postgresql/TestPostgreSqlTypeMapping.java | 6 +----- 3 files changed, 3 insertions(+), 15 deletions(-) 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(),