Skip to content

Commit edc6d9b

Browse files
committed
#289 - Polishing.
Minor formatting. Original pull request: #308.
1 parent 10ec677 commit edc6d9b

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

Diff for: src/main/java/org/springframework/data/r2dbc/core/DefaultDatabaseClient.java

+6
Original file line numberDiff line numberDiff line change
@@ -1237,7 +1237,9 @@ public UpdatedRowsFetchSpec fetch() {
12371237
SqlIdentifier table;
12381238

12391239
if (StringUtils.isEmpty(this.table)) {
1240+
12401241
Assert.state(this.typeToUpdate != null, "Type to update must not be null!");
1242+
12411243
table = dataAccessStrategy.getTableName(this.typeToUpdate);
12421244
} else {
12431245
table = this.table;
@@ -1260,6 +1262,7 @@ private UpdatedRowsFetchSpec exchange(SqlIdentifier table) {
12601262
}
12611263

12621264
Assert.state(this.assignments != null, "Update assignments must not be null!");
1265+
12631266
StatementMapper.UpdateSpec update = mapper.createUpdate(table, this.assignments);
12641267

12651268
if (this.where != null) {
@@ -1403,7 +1406,9 @@ public UpdatedRowsFetchSpec fetch() {
14031406
SqlIdentifier table;
14041407

14051408
if (StringUtils.isEmpty(this.table)) {
1409+
14061410
Assert.state(this.typeToDelete != null, "Type to delete must not be null!");
1411+
14071412
table = dataAccessStrategy.getTableName(this.typeToDelete);
14081413
} else {
14091414
table = this.table;
@@ -1495,6 +1500,7 @@ private Function<Connection, Flux<Result>> toFunction(String sql, StatementFilte
14951500
return it -> {
14961501

14971502
Flux<Result> from = Flux.defer(() -> {
1503+
14981504
Statement statement = statementFactory.apply(it);
14991505
return filterFunction.filter(statement, executeFunction);
15001506
}).cast(Result.class);

0 commit comments

Comments
 (0)