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;