Skip to content

Commit

Permalink
refactoring of SimpleQuerydslR2dbcFragment
Browse files Browse the repository at this point in the history
  • Loading branch information
lpandzic committed Aug 7, 2023
1 parent bad3240 commit ad4ff2a
Showing 1 changed file with 6 additions and 6 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -71,12 +71,6 @@ public Mono<Long> update(Function<SQLUpdateClause, SQLUpdateClause> update) {
.rowsUpdated();
}

private List<Object> getBindings(List<SQLBindings> sqlBindings) {
return sqlBindings.stream()
.flatMap(bindings -> bindings.getNullFriendlyBindings().stream())
.toList();
}

@Override
@Transactional
public Mono<Long> deleteWhere(Predicate predicate) {
Expand Down Expand Up @@ -104,4 +98,10 @@ private <O> RowsFetchSpec<O> createQuery(Function<SQLQuery<?>, SQLQuery<O>> quer
return new SimpleRowsFetchSpec<>(
querydslParameterBinder.bind(databaseClient, sql.getNullFriendlyBindings(), sql.getSQL()).map(mapper));
}

private List<Object> getBindings(List<SQLBindings> sqlBindings) {
return sqlBindings.stream()
.flatMap(bindings -> bindings.getNullFriendlyBindings().stream())
.toList();
}
}

0 comments on commit ad4ff2a

Please sign in to comment.