#73 - hacking - removed call to old bind.

Author: schauder

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

@@ -908,20 +908,10 @@ private <R> FetchSpec<R> exchange(BiFunction<Row, RowMetadata, R> mappingFunctio
 						byName.forEach(it::bind);
 					});
 
-			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, //
+					operation.toQuery(), //
 					resultFunction, //
 					it -> resultFunction.apply(it).flatMap(Result::getRowsUpdated).next(), //
 					mappingFunction);

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

@@ -475,7 +475,7 @@ public Statement bind(Statement to) {
 		@Override
 		public Statement bind(Connection connection) {
 
-			// TODO add logging
+			// TODO add back logging
 //			if (logger.isDebugEnabled()) {
 //				logger.debug("Executing SQL statement [" + sql + "]");
 //			}

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

@@ -45,6 +45,7 @@ public interface PreparedOperation<T> extends QueryOperation {
 	 * @param to the target statement to bind parameters to.
 	 * @return the bound statement.
 	 */
+	@Deprecated
 	Statement bind(Statement to);
 
 	Statement bind(Connection connection);