Polishing

spring-r2dbc/src/main/java/org/springframework/r2dbc/core/DatabaseClient.java

@@ -37,14 +37,14 @@ import org.springframework.r2dbc.core.binding.BindMarkersFactory;
 import org.springframework.util.Assert;
 
 /**
- * A non-blocking, reactive client for performing database calls requests with
+ * A non-blocking, reactive client for performing database calls with
  * Reactive Streams back pressure. Provides a higher level, common API over
  * R2DBC client libraries.
  *
- * <p>Use one of the static factory methods {@link #create(ConnectionFactory)}
- * or obtain a {@link DatabaseClient#builder()} to create an instance.
+ * <p>Use the static factory method {@link #create(ConnectionFactory)} or obtain
+ * a {@linkplain DatabaseClient#builder() builder} to create an instance.
  *
- * Usage example:
+ * <p>Usage example:
  * <pre class="code">
  * ConnectionFactory factory = …
  *
@@ -52,8 +52,7 @@ import org.springframework.util.Assert;
  * Mono&lt;Actor&gt; actor = client.sql("select first_name, last_name from t_actor")
  *     .map(row -&gt; new Actor(row.get("first_name", String.class),
  *          row.get("last_name", String.class)))
- *     .first();
- * </pre>
+ *     .first();</pre>
  *
  * @author Mark Paluch
  * @since 5.3
@@ -61,13 +60,13 @@ import org.springframework.util.Assert;
 public interface DatabaseClient extends ConnectionAccessor {
 
 	/**
-	 * Return the {@link ConnectionFactory} that this client uses.
+	 * Get the {@link ConnectionFactory} that this client uses.
 	 * @return the connection factory
 	 */
 	ConnectionFactory getConnectionFactory();
 
 	/**
-	 * Specify a static {@code sql} statement to run. Contract for specifying a
+	 * Specify a static {@code sql} statement to run. Contract for specifying an
 	 * SQL call along with options leading to the execution. The SQL string can
 	 * contain either native parameter bind markers or named parameters (e.g.
 	 * {@literal :foo, :bar}) when {@link NamedParameterExpander} is enabled.
@@ -79,7 +78,7 @@ public interface DatabaseClient extends ConnectionAccessor {
 	GenericExecuteSpec sql(String sql);
 
 	/**
-	 * Specify a {@link Supplier SQL supplier} that provides SQL to run.
+	 * Specify an {@linkplain Supplier SQL supplier} that provides SQL to run.
 	 * Contract for specifying an SQL call along with options leading to
 	 * the execution. The SQL string can contain either native parameter
 	 * bind markers or named parameters (e.g. {@literal :foo, :bar}) when
@@ -99,7 +98,7 @@ public interface DatabaseClient extends ConnectionAccessor {
 	/**
 	 * Create a {@code DatabaseClient} that will use the provided {@link ConnectionFactory}.
 	 * @param factory the {@code ConnectionFactory} to use for obtaining connections
-	 * @return a new {@code DatabaseClient}. Guaranteed to be not {@code null}.
+	 * @return a new {@code DatabaseClient}; never {@code null}
 	 */
 	static DatabaseClient create(ConnectionFactory factory) {
 		return new DefaultDatabaseClientBuilder().connectionFactory(factory).build();
@@ -129,14 +128,14 @@ public interface DatabaseClient extends ConnectionAccessor {
 		Builder connectionFactory(ConnectionFactory factory);
 
 		/**
-		 * Configure a {@link ExecuteFunction} to execute {@link Statement} objects.
+		 * Configure an {@link ExecuteFunction} to execute {@link Statement} objects.
 		 * @see Statement#execute()
 		 */
 		Builder executeFunction(ExecuteFunction executeFunction);
 
 		/**
 		 * Configure whether to use named parameter expansion.
-		 * Defaults to {@code true}.
+		 * <p>Defaults to {@code true}.
 		 * @param enabled {@code true} to use named parameter expansion;
 		 * {@code false} to disable named parameter expansion
 		 * @see NamedParameterExpander
@@ -144,7 +143,7 @@ public interface DatabaseClient extends ConnectionAccessor {
 		Builder namedParameters(boolean enabled);
 
 		/**
-		 * Configures a {@link Consumer} to configure this builder.
+		 * Apply a {@link Consumer} to configure this builder.
 		 */
 		Builder apply(Consumer<Builder> builderConsumer);
 
@@ -238,7 +237,7 @@ public interface DatabaseClient extends ConnectionAccessor {
 		 * Perform the SQL call and apply {@link BiFunction function} to the {@link  Result}.
 		 * @param mappingFunction a function that maps from {@link Result} into a result publisher
 		 * @param <R> the result type
-		 * @return a {@link Flux} emitting mapped elements
+		 * @return a {@link Flux} that emits mapped elements
 		 * @since 6.0
 		 * @see Result#filter(Predicate)
 		 * @see Result#flatMap(Function)

spring-r2dbc/src/main/java/org/springframework/r2dbc/core/DefaultDatabaseClient.java

@@ -200,16 +200,15 @@ class DefaultDatabaseClient implements DatabaseClient {
 	}
 
 	/**
-	 * Determine SQL from potential provider object.
-	 * @param sqlProvider object that's potentially a SqlProvider
+	 * Get SQL from a potential provider object.
+	 * @param object an object that is potentially an SqlProvider
 	 * @return the SQL string, or {@code null}
 	 * @see SqlProvider
 	 */
 	@Nullable
-	private static String getSql(Object sqlProvider) {
-
-		if (sqlProvider instanceof SqlProvider) {
-			return ((SqlProvider) sqlProvider).getSql();
+	private static String getSql(Object object) {
+		if (object instanceof SqlProvider sqlProvider) {
+			return sqlProvider.getSql();
 		}
 		else {
 			return null;
@@ -218,7 +217,7 @@ class DefaultDatabaseClient implements DatabaseClient {
 
 
 	/**
-	 * Base class for {@link DatabaseClient.GenericExecuteSpec} implementations.
+	 * Default {@link DatabaseClient.GenericExecuteSpec} implementation.
 	 */
 	class DefaultGenericExecuteSpec implements GenericExecuteSpec {
 
@@ -352,10 +351,10 @@ class DefaultDatabaseClient implements DatabaseClient {
 				if (logger.isDebugEnabled()) {
 					logger.debug("Executing SQL statement [" + sql + "]");
 				}
-				if (sqlSupplier instanceof PreparedOperation<?>) {
+				if (sqlSupplier instanceof PreparedOperation<?> preparedOperation) {
 					Statement statement = connection.createStatement(sql);
 					BindTarget bindTarget = new StatementWrapper(statement);
-					((PreparedOperation<?>) sqlSupplier).bindTo(bindTarget);
+					preparedOperation.bindTo(bindTarget);
 					return statement;
 				}
 
@@ -397,7 +396,7 @@ class DefaultDatabaseClient implements DatabaseClient {
 			Function<Connection, Flux<Result>> resultFunction = connection -> {
 				Statement statement = statementFunction.apply(connection);
 				return Flux.from(this.filterFunction.filter(statement, DefaultDatabaseClient.this.executeFunction))
-				.cast(Result.class).checkpoint("SQL \"" + sql + "\" [DatabaseClient]");
+						.cast(Result.class).checkpoint("SQL \"" + sql + "\" [DatabaseClient]");
 			};
 
 			return new ResultFunction(resultFunction, sql);

spring-r2dbc/src/main/java/org/springframework/r2dbc/core/PreparedOperation.java

@@ -1,5 +1,5 @@
 /*
- * Copyright 2002-2020 the original author or authors.
+ * Copyright 2002-2022 the original author or authors.
  *
  * Licensed under the Apache License, Version 2.0 (the "License");
  * you may not use this file except in compliance with the License.
@@ -23,25 +23,25 @@ import org.springframework.r2dbc.core.binding.BindTarget;
 /**
  * Extension to {@link QueryOperation} for a prepared SQL query
  * {@link Supplier} with bound parameters. Contains parameter
- * bindings that can be {@link #bindTo bound} bound to a {@link BindTarget}.
+ * bindings that can be {@link #bindTo bound} to a {@link BindTarget}.
  *
  * <p>Can be executed with {@link org.springframework.r2dbc.core.DatabaseClient}.
  *
  * @author Mark Paluch
  * @since 5.3
- * @param <T> underlying operation source.
+ * @param <T> underlying operation source
  * @see org.springframework.r2dbc.core.DatabaseClient#sql(Supplier)
  */
 public interface PreparedOperation<T> extends QueryOperation {
 
 	/**
-	 * Return the underlying query source.
+	 * Get the underlying query source.
 	 * @return the query source, such as a statement/criteria object
 	 */
 	T getSource();
 
 	/**
-	 * Apply bindings to {@link BindTarget}.
+	 * Apply bindings to the supplied {@link BindTarget}.
 	 * @param target the target to apply bindings to
 	 */
 	void bindTo(BindTarget target);