#57 - hacking - introduced alternative bind method.

Author: schauder

src/main/java/org/springframework/data/r2dbc/function/DefaultDatabaseClient.java

@@ -1031,16 +1031,7 @@ private <MR> FetchSpec<MR> exchange(Object toInsert, BiFunction<Row, RowMetadata
 
 			String sql = operation.toQuery();
 
-			Function<Connection, Statement> insertFunction = it -> {
-
-				if (logger.isDebugEnabled()) {
-					logger.debug("Executing SQL statement [" + sql + "]");
-				}
-
-				return operation.bind(it.createStatement(sql));
-			};
-
-			Function<Connection, Flux<Result>> resultFunction = it -> Flux.from(insertFunction.apply(it).execute());
+			Function<Connection, Flux<Result>> resultFunction = it -> Flux.from(operation.bind(it).execute());
 
 			return new DefaultSqlResult<>(DefaultDatabaseClient.this, //
 					sql, //

src/main/java/org/springframework/data/r2dbc/function/DefaultStatementFactory.java

@@ -15,6 +15,7 @@
  */
 package org.springframework.data.r2dbc.function;
 
+import io.r2dbc.spi.Connection;
 import io.r2dbc.spi.Statement;
 import lombok.Getter;
 import lombok.RequiredArgsConstructor;
@@ -470,5 +471,16 @@ public Statement bind(Statement to) {
 			binding.apply(to);
 			return to;
 		}
+
+		@Override
+		public Statement bind(Connection connection) {
+
+			// TODO add logging
+//			if (logger.isDebugEnabled()) {
+//				logger.debug("Executing SQL statement [" + sql + "]");
+//			}
+
+			return bind(connection.createStatement(toQuery()));
+		}
 	}
 }

src/main/java/org/springframework/data/r2dbc/function/PreparedOperation.java

@@ -15,6 +15,7 @@
  */
 package org.springframework.data.r2dbc.function;
 
+import io.r2dbc.spi.Connection;
 import io.r2dbc.spi.Statement;
 
 import java.util.function.Supplier;
@@ -45,4 +46,6 @@ public interface PreparedOperation<T> extends QueryOperation {
 	 * @return the bound statement.
 	 */
 	Statement bind(Statement to);
+
+	Statement bind(Connection connection);
 }