Close statement first, then the connection

trinodb · Nov 8, 2024 · c1e75e0 · c1e75e0
1 parent 2d4c746
commit c1e75e0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcPageSink.java b/plugin/trino-base-jdbc/src/main/java/io/trino/plugin/jdbc/JdbcPageSink.java
@@ -29,6 +29,7 @@
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
 import java.sql.SQLNonTransientException;
+import java.sql.SQLRecoverableException;
 import java.util.Collection;
 import java.util.List;
 import java.util.concurrent.CompletableFuture;
@@ -231,8 +232,7 @@ public CompletableFuture<Collection<Slice>> finish()
     public void abort()
     {
         // rollback and close
-        try (Connection connection = this.connection;
-                PreparedStatement statement = this.statement) {
+        try (PreparedStatement statement = this.statement; Connection connection = this.connection) {
             // skip rollback if implicitly closed due to an error
             if (!connection.isClosed()) {
                 connection.rollback();