Spring/spring-data-relational
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

#289 - Polishing.

Browse Source 
Minor formatting.

Original pull request: #308.
This commit is contained in:
Jens Schauder
2020-03-17 11:32:09 +01:00
parent 10ec677c53
commit edc6d9b042
1 changed files with 6 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/org/springframework/data/r2dbc/core/DefaultDatabaseClient.java
View File

@@ -1237,7 +1237,9 @@ class DefaultDatabaseClient implements DatabaseClient, ConnectionAccessor {
SqlIdentifier table;
if (StringUtils.isEmpty(this.table)) {
Assert.state(this.typeToUpdate != null, "Type to update must not be null!");
table = dataAccessStrategy.getTableName(this.typeToUpdate);
} else {
table = this.table;
@@ -1260,6 +1262,7 @@ class DefaultDatabaseClient implements DatabaseClient, ConnectionAccessor {
}
Assert.state(this.assignments != null, "Update assignments must not be null!");
StatementMapper.UpdateSpec update = mapper.createUpdate(table, this.assignments);
if (this.where != null) {
@@ -1403,7 +1406,9 @@ class DefaultDatabaseClient implements DatabaseClient, ConnectionAccessor {
SqlIdentifier table;
if (StringUtils.isEmpty(this.table)) {
Assert.state(this.typeToDelete != null, "Type to delete must not be null!");
table = dataAccessStrategy.getTableName(this.typeToDelete);
} else {
table = this.table;
@@ -1495,6 +1500,7 @@ class DefaultDatabaseClient implements DatabaseClient, ConnectionAccessor {
return it -> {
Flux<Result> from = Flux.defer(() -> {
Statement statement = statementFactory.apply(it);
return filterFunction.filter(statement, executeFunction);
}).cast(Result.class);