Skip to content

Commit 52bfe02

Browse files
committed
优化参数clone
1 parent ed5e3b0 commit 52bfe02

File tree

5 files changed

+12
-11
lines changed

5 files changed

+12
-11
lines changed

hsweb-commons/hsweb-commons-api/src/main/java/org/hswebframework/web/api/crud/entity/QueryParamEntity.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -128,7 +128,7 @@ public <T> Query<T, QueryParamEntity> toQuery() {
128128
* <p>
129129
* 执行后条件: (name=? or type=?) and userId=?
130130
*
131-
* @see this#toNestQuery(Consumer)
131+
* @see QueryParamEntity#toNestQuery(Consumer)
132132
* @since 3.0.4
133133
*/
134134
public <T> Query<T, QueryParamEntity> toNestQuery() {

hsweb-commons/hsweb-commons-crud/src/main/java/org/hswebframework/web/crud/service/ReactiveCrudService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -207,14 +207,14 @@ default <T> Mono<PagerResult<T>> queryPager(QueryParamEntity query, Function<E,
207207
if (query.isParallelPager()) {
208208
return Mono
209209
.zip(
210-
createQuery().setParam(query).count(),
210+
createQuery().setParam(query.clone()).count(),
211211
createQuery().setParam(query.clone()).fetch().map(mapper).collectList(),
212212
(total, data) -> PagerResult.of(total, data, query)
213213
);
214214
}
215215
return getRepository()
216216
.createQuery()
217-
.setParam(query)
217+
.setParam(query.clone())
218218
.count()
219219
.flatMap(total -> {
220220
if (total == 0) {

hsweb-commons/hsweb-commons-crud/src/main/java/org/hswebframework/web/crud/web/QueryController.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ default PagerResult<E> queryPager(@Parameter(hidden = true) QueryParamEntity que
113113
.fetch(), query)
114114
;
115115
}
116-
int total = getRepository().createQuery().setParam(query).count();
116+
int total = getRepository().createQuery().setParam(query.clone()).count();
117117
if (total == 0) {
118118
return PagerResult.of(0, Collections.emptyList(), query);
119119
}

hsweb-commons/hsweb-commons-crud/src/main/java/org/hswebframework/web/crud/web/ServiceQueryController.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -111,7 +111,7 @@ default PagerResult<E> queryPager(@Parameter(hidden = true) QueryParamEntity que
111111
.fetch(), query)
112112
;
113113
}
114-
int total = getService().createQuery().setParam(query).count();
114+
int total = getService().createQuery().setParam(query.clone()).count();
115115
if (total == 0) {
116116
return PagerResult.of(0, Collections.emptyList(), query);
117117
}

hsweb-commons/hsweb-commons-crud/src/main/java/org/hswebframework/web/crud/web/reactive/ReactiveQueryController.java

Lines changed: 7 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -44,7 +44,7 @@ public interface ReactiveQueryController<E, K> {
4444
@QueryAction
4545
@QueryOperation(summary = "使用GET方式分页动态查询(不返回总数)",
4646
description = "此操作不返回分页总数,如果需要获取全部数据,请设置参数paging=false")
47-
default Flux<E> query(@Parameter(hidden = true) QueryParamEntity query) {
47+
default Flux<E> query(@Parameter(hidden = true) QueryParamEntity query) {
4848
return getRepository()
4949
.createQuery()
5050
.setParam(query)
@@ -109,11 +109,12 @@ default Mono<PagerResult<E>> queryPager(@Parameter(hidden = true) QueryParamEnti
109109
.map(list -> PagerResult.of(query.getTotal(), list, query));
110110
}
111111

112-
return Mono.zip(
113-
getRepository().createQuery().setParam(query).count(),
114-
query(query.clone()).collectList(),
115-
(total, data) -> PagerResult.of(total, data, query)
116-
);
112+
return Mono
113+
.zip(
114+
getRepository().createQuery().setParam(query.clone()).count(),
115+
query(query.clone()).collectList(),
116+
(total, data) -> PagerResult.of(total, data, query)
117+
);
117118

118119
}
119120

0 commit comments

Comments
 (0)