Adopt to Spring R2DBC changes.

Update counts now return Long instead of Integer.

Closes #1198

Author: mp911de

spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core/R2dbcEntityOperations.java

@@ -129,7 +129,7 @@ public interface R2dbcEntityOperations extends FluentR2dbcOperations {
 	 * @return the number of affected rows.
 	 * @throws DataAccessException if there is any problem executing the query.
 	 */
-	Mono<Integer> update(Query query, Update update, Class<?> entityClass) throws DataAccessException;
+	Mono<Long> update(Query query, Update update, Class<?> entityClass) throws DataAccessException;
 
 	/**
 	 * Remove entities (rows)/columns from the table by {@link Query}.
@@ -139,7 +139,7 @@ public interface R2dbcEntityOperations extends FluentR2dbcOperations {
 	 * @return the number of affected rows.
 	 * @throws DataAccessException if there is any problem issuing the execution.
 	 */
-	Mono<Integer> delete(Query query, Class<?> entityClass) throws DataAccessException;
+	Mono<Long> delete(Query query, Class<?> entityClass) throws DataAccessException;
 
 	// -------------------------------------------------------------------------
 	// Methods dealing with org.springframework.r2dbc.core.PreparedOperation

spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core/R2dbcEntityTemplate.java

@@ -428,7 +428,7 @@ public <T> Mono<T> selectOne(Query query, Class<T> entityClass) throws DataAcces
 	 * @see org.springframework.data.r2dbc.core.R2dbcEntityOperations#update(org.springframework.data.r2dbc.query.Query, org.springframework.data.r2dbc.query.Update, java.lang.Class)
 	 */
 	@Override
-	public Mono<Integer> update(Query query, Update update, Class<?> entityClass) throws DataAccessException {
+	public Mono<Long> update(Query query, Update update, Class<?> entityClass) throws DataAccessException {
 
 		Assert.notNull(query, "Query must not be null");
 		Assert.notNull(update, "Update must not be null");
@@ -437,7 +437,7 @@ public Mono<Integer> update(Query query, Update update, Class<?> entityClass) th
 		return doUpdate(query, update, entityClass, getTableName(entityClass));
 	}
 
-	Mono<Integer> doUpdate(Query query, Update update, Class<?> entityClass, SqlIdentifier tableName) {
+	Mono<Long> doUpdate(Query query, Update update, Class<?> entityClass, SqlIdentifier tableName) {
 
 		StatementMapper statementMapper = dataAccessStrategy.getStatementMapper().forType(entityClass);
 
@@ -458,15 +458,15 @@ Mono<Integer> doUpdate(Query query, Update update, Class<?> entityClass, SqlIden
 	 * @see org.springframework.data.r2dbc.core.R2dbcEntityOperations#delete(org.springframework.data.r2dbc.query.Query, java.lang.Class)
 	 */
 	@Override
-	public Mono<Integer> delete(Query query, Class<?> entityClass) throws DataAccessException {
+	public Mono<Long> delete(Query query, Class<?> entityClass) throws DataAccessException {
 
 		Assert.notNull(query, "Query must not be null");
 		Assert.notNull(entityClass, "Entity class must not be null");
 
 		return doDelete(query, entityClass, getTableName(entityClass));
 	}
 
-	Mono<Integer> doDelete(Query query, Class<?> entityClass, SqlIdentifier tableName) {
+	Mono<Long> doDelete(Query query, Class<?> entityClass, SqlIdentifier tableName) {
 
 		StatementMapper statementMapper = dataAccessStrategy.getStatementMapper().forType(entityClass);
 
@@ -479,7 +479,7 @@ Mono<Integer> doDelete(Query query, Class<?> entityClass, SqlIdentifier tableNam
 		}
 
 		PreparedOperation<?> operation = statementMapper.getMappedObject(deleteSpec);
-		return this.databaseClient.sql(operation).fetch().rowsUpdated().defaultIfEmpty(0);
+		return this.databaseClient.sql(operation).fetch().rowsUpdated().defaultIfEmpty(0L);
 	}
 
 	// -------------------------------------------------------------------------

spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core/ReactiveDeleteOperation.java

@@ -113,7 +113,7 @@ interface TerminatingDelete {
 		 * @return the number of affected rows; never {@literal null}.
 		 * @see Mono
 		 */
-		Mono<Integer> all();
+		Mono<Long> all();
 	}
 
 	/**

spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core/ReactiveDeleteOperationSupport.java

@@ -92,7 +92,7 @@ public TerminatingDelete matching(Query query) {
 		 * (non-Javadoc)
 		 * @see org.springframework.data.r2dbc.core.ReactiveDeleteOperation.TerminatingDelete#all()
 		 */
-		public Mono<Integer> all() {
+		public Mono<Long> all() {
 			return template.doDelete(query, domainType, getTableName());
 		}
 

spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core/ReactiveUpdateOperation.java

@@ -117,7 +117,7 @@ interface TerminatingUpdate {
 		 * @return the number of affected rows by the update; never {@literal null}.
 		 * @see Mono
 		 */
-		Mono<Integer> apply(Update update);
+		Mono<Long> apply(Update update);
 	}
 
 	/**

spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/core/ReactiveUpdateOperationSupport.java

@@ -94,7 +94,7 @@ public TerminatingUpdate matching(Query query) {
 		 * @see org.springframework.data.r2dbc.core.ReactiveUpdateOperation.TerminatingUpdate#apply(org.springframework.data.r2dbc.query.Update)
 		 */
 		@Override
-		public Mono<Integer> apply(Update update) {
+		public Mono<Long> apply(Update update) {
 
 			Assert.notNull(update, "Update must not be null");
 

spring-data-r2dbc/src/main/java/org/springframework/data/r2dbc/repository/query/AbstractR2dbcQuery.java

@@ -137,7 +137,7 @@ private R2dbcQueryExecution getExecutionToWrap(ReturnedType returnedType) {
 			if (Number.class.isAssignableFrom(returnedType.getReturnedType())) {
 
 					return fs.rowsUpdated()
-							.map(integer -> converter.getConversionService().convert(integer, returnedType.getReturnedType()));
+							.map(count -> converter.getConversionService().convert(count, returnedType.getReturnedType()));
 			}
 
 			if (ReflectionUtils.isVoid(returnedType.getReturnedType())) {

spring-data-r2dbc/src/main/kotlin/org/springframework/data/r2dbc/core/ReactiveDeleteOperationExtensions.kt

@@ -33,5 +33,5 @@ inline fun <reified T : Any> ReactiveDeleteOperation.delete(): ReactiveDeleteOpe
 /**
  * Coroutines variant of [ReactiveDeleteOperation.TerminatingDelete.all].
  */
-suspend fun ReactiveDeleteOperation.TerminatingDelete.allAndAwait(): Int =
+suspend fun ReactiveDeleteOperation.TerminatingDelete.allAndAwait(): Long =
 		all().awaitSingle()

spring-data-r2dbc/src/main/kotlin/org/springframework/data/r2dbc/core/ReactiveUpdateOperationExtensions.kt

@@ -34,4 +34,4 @@ inline fun <reified T : Any> ReactiveUpdateOperation.update(): ReactiveUpdateOpe
 /**
  * Coroutines variant of [ReactiveUpdateOperation.TerminatingUpdate.apply].
  */
-suspend fun ReactiveUpdateOperation.TerminatingUpdate.applyAndAwait(update: Update): Int = apply(update).awaitSingle()
+suspend fun ReactiveUpdateOperation.TerminatingUpdate.applyAndAwait(update: Update): Long = apply(update).awaitSingle()

spring-data-r2dbc/src/test/java/org/springframework/data/r2dbc/core/R2dbcEntityTemplateUnitTests.java

@@ -214,7 +214,7 @@ void shouldUpdateByQuery() {
 		entityTemplate
 				.update(Query.query(Criteria.where("name").is("Walter")), Update.update("name", "Heisenberg"), Person.class) //
 				.as(StepVerifier::create) //
-				.expectNext(1) //
+				.expectNext(1L) //
 				.verifyComplete();
 
 		StatementRecorder.RecordedStatement statement = recorder.getCreatedStatement(s -> s.startsWith("UPDATE"));
@@ -235,7 +235,7 @@ void shouldDeleteByQuery() {
 
 		entityTemplate.delete(Query.query(Criteria.where("name").is("Walter")), Person.class) //
 				.as(StepVerifier::create) //
-				.expectNext(1) //
+				.expectNext(1L) //
 				.verifyComplete();
 
 		StatementRecorder.RecordedStatement statement = recorder.getCreatedStatement(s -> s.startsWith("DELETE"));