#212 - Polishing.

Consistently apply summing of updated rows. Tweak copyright years in license header to reflect file inception year.

Original pull request: #213.

Author: mp911de

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

@@ -391,7 +391,7 @@ <T> FetchSpec<T> exchange(Supplier<String> sqlSupplier, BiFunction<Row, RowMetad
 			return new DefaultSqlResult<>(DefaultDatabaseClient.this, //
 					sql, //
 					resultFunction, //
-					it -> resultFunction.apply(it).flatMap(Result::getRowsUpdated).next(), //
+					it -> sumRowsUpdated(resultFunction, it), //
 					mappingFunction);
 		}
 

src/main/java/org/springframework/data/r2dbc/core/DefaultSqlResult.java

@@ -56,7 +56,7 @@ public Flux<Object> all() {
 
 		@Override
 		public Mono<Integer> rowsUpdated() {
-			return Mono.empty();
+			return Mono.just(0);
 		}
 	};
 

src/main/kotlin/org/springframework/data/r2dbc/core/UpdatedRowsFetchSpecExtensions.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright 2018-2019 the original author or authors.
+ * Copyright 2019 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.

src/test/kotlin/org/springframework/data/r2dbc/core/UpdatedRowsFetchSpecExtensionsTests.kt

@@ -1,5 +1,5 @@
 /*
- * Copyright 2018-2019 the original author or authors.
+ * Copyright 2019 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.