From 9d9c665f7633edbff89de253494b6fc4aa98137a Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Wed, 20 Jun 2018 16:54:35 +0200 Subject: [PATCH] #2 - Polishing. --- .../data/jdbc/core/function/DefaultDatabaseClient.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/java/org/springframework/data/jdbc/core/function/DefaultDatabaseClient.java b/src/main/java/org/springframework/data/jdbc/core/function/DefaultDatabaseClient.java index 1385ff6..5146746 100644 --- a/src/main/java/org/springframework/data/jdbc/core/function/DefaultDatabaseClient.java +++ b/src/main/java/org/springframework/data/jdbc/core/function/DefaultDatabaseClient.java @@ -996,7 +996,7 @@ class DefaultDatabaseClient implements DatabaseClient, ConnectionAccessor { } catch (RuntimeException e) { String sql = getSql(action); - return Flux.error(new DefaultDatabaseClient.UncategorizedSQLException("ConnectionCallback", sql, e) {}); + return Flux.error(new DefaultDatabaseClient.UncategorizedSQLException("doInConnectionMany", sql, e) {}); } } @@ -1007,7 +1007,7 @@ class DefaultDatabaseClient implements DatabaseClient, ConnectionAccessor { } catch (RuntimeException e) { String sql = getSql(action); - return Mono.error(new DefaultDatabaseClient.UncategorizedSQLException("ConnectionCallback", sql, e) {}); + return Mono.error(new DefaultDatabaseClient.UncategorizedSQLException("doInConnection", sql, e) {}); } }