Added extra logs

Author: alex268

jdbc/src/main/java/tech/ydb/jdbc/context/QueryServiceExecutor.java

@@ -9,6 +9,8 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.concurrent.TimeUnit;
+import java.util.logging.Level;
+import java.util.logging.Logger;
 
 import tech.ydb.common.transaction.TxMode;
 import tech.ydb.core.Issue;
@@ -41,6 +43,8 @@
  * @author Aleksandr Gorshenin
  */
 public class QueryServiceExecutor extends BaseYdbExecutor {
+    private static final Logger LOGGER = Logger.getLogger(QueryServiceExecutor.class.getName());
+
     private final Duration sessionTimeout;
     private final QueryClient queryClient;
 
@@ -66,9 +70,11 @@ public QueryServiceExecutor(YdbContext ctx, int transactionLevel, boolean autoCo
 
     protected QuerySession createNewQuerySession(YdbValidator validator) throws SQLException {
         try {
-            Result<QuerySession> session = queryClient.createSession(sessionTimeout).join();
-            validator.addStatusIssues(session.getStatus());
-            return session.getValue();
+            Result<QuerySession> result = queryClient.createSession(sessionTimeout).join();
+            validator.addStatusIssues(result.getStatus());
+            QuerySession session = result.getValue();
+            LOGGER.log(Level.FINEST, "Acquired session {0}", session);
+            return session;
         } catch (UnexpectedResultException ex) {
             throw ExceptionFactory.createException("Cannot create session with " + ex.getStatus(), ex);
         }
@@ -82,6 +88,7 @@ public void close() {
 
     private void cleanTx() {
         if (tx != null) {
+            LOGGER.log(Level.FINEST, "Released session {0}", tx.getSession());
             tx.getSession().close();
             tx = null;
         }

jdbc/src/main/java/tech/ydb/jdbc/context/YdbValidator.java

@@ -73,9 +73,12 @@ public void execute(String msg, Supplier<CompletableFuture<Status>> fn) throws S
         try {
             runImpl(msg, fn);
             logger.log(Level.FINEST, "[{0}] OK ", sw.stop());
-        } catch (SQLException | RuntimeException ex) {
+        } catch (SQLException ex) {
             logger.log(Level.FINE, "[{0}] {1} ", new Object[] {sw.stop(), ex.getMessage()});
             throw ex;
+        } catch (Exception ex) {
+            logger.log(Level.WARNING, "ERROR ", ex);
+            throw ex;
         }
     }
 
@@ -91,8 +94,11 @@ public <R> R call(String msg, Supplier<CompletableFuture<Result<R>>> fn) throws
             R value = callImpl(msg, fn);
             logger.log(Level.FINEST, "[{0}] OK ", sw.stop());
             return value;
-        } catch (SQLException | RuntimeException ex) {
-            logger.log(Level.FINE, "[{0}] {1} ", new Object[] {sw.stop(), ex.getMessage()});
+        } catch (SQLException ex) {
+            logger.log(Level.FINE, "[{0}] FAIL {1} ", new Object[] {sw.stop(), ex.getMessage()});
+            throw ex;
+        } catch (Exception ex) {
+            logger.log(Level.WARNING, "ERROR ", ex);
             throw ex;
         }
     }