From 1d5bb962fd76f03b9bdb6d7ba60ff602d186d6e4 Mon Sep 17 00:00:00 2001 From: Mark Paluch Date: Tue, 19 Jun 2018 15:28:04 +0200 Subject: [PATCH] #2 - Polishing. --- .../data/jdbc/core/function/DatabaseClient.java | 8 +++++++- .../data/jdbc/core/function/DefaultDatabaseClient.java | 4 ++-- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/src/main/java/org/springframework/data/jdbc/core/function/DatabaseClient.java b/src/main/java/org/springframework/data/jdbc/core/function/DatabaseClient.java index a17ad27..cf8172b 100644 --- a/src/main/java/org/springframework/data/jdbc/core/function/DatabaseClient.java +++ b/src/main/java/org/springframework/data/jdbc/core/function/DatabaseClient.java @@ -71,7 +71,7 @@ public interface DatabaseClient { } /** - * Obtain a {@code WebClient} builder. + * Obtain a {@code DatabaseClient} builder. */ static DatabaseClient.Builder builder() { return new DefaultDatabaseClientBuilder(); @@ -219,6 +219,12 @@ public interface DatabaseClient { */ GenericInsertSpec into(String table); + /** + * Specify the target {@link Class} table to insert to using the {@link Class entity class}. + * + * @param table must not be {@literal null}. + * @return + */ TypedInsertSpec into(Class table); } 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 e254735..320684b 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 @@ -62,7 +62,7 @@ import org.springframework.util.Assert; class DefaultDatabaseClient implements DatabaseClient, ConnectionAccessor { /** Logger available to subclasses */ - protected final Log logger = LogFactory.getLog(getClass()); + private final Log logger = LogFactory.getLog(getClass()); private final ConnectionFactory connector; @@ -72,7 +72,7 @@ class DefaultDatabaseClient implements DatabaseClient, ConnectionAccessor { private final DefaultDatabaseClientBuilder builder; - public DefaultDatabaseClient(ConnectionFactory connector, SQLExceptionTranslator exceptionTranslator, + DefaultDatabaseClient(ConnectionFactory connector, SQLExceptionTranslator exceptionTranslator, ReactiveDataAccessStrategy dataAccessStrategy, DefaultDatabaseClientBuilder builder) { this.connector = connector;