Protei/PromucFlow_constructor
2
0
Fork 0
Code Issues Pull Requests Actions 2 Packages Projects Releases Wiki Activity

chore: Use queryBulider for count op

Browse Source
This commit is contained in:
Shrikant Sharat Kandula 2024-02-28 10:58:56 +05:30
parent 21b0a5ebfb
commit 70cd65ec7d
1 changed files with 2 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
app/server/appsmith-server/src/main/java/com/appsmith/server/repositories/ce/CustomNewActionRepositoryCEImpl.java
View File

@ -22,7 +22,6 @@ import org.springframework.data.mongodb.core.aggregation.MatchOperation;
import org.springframework.data.mongodb.core.aggregation.ProjectionOperation; import org.springframework.data.mongodb.core.aggregation.ProjectionOperation;
import org.springframework.data.mongodb.core.convert.MongoConverter; import org.springframework.data.mongodb.core.convert.MongoConverter;
import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.data.mongodb.core.query.Update; import org.springframework.data.mongodb.core.query.Update;
import reactor.core.publisher.Flux; import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono; import reactor.core.publisher.Mono;
@ -351,12 +350,9 @@ public class CustomNewActionRepositoryCEImpl extends BaseAppsmithRepositoryImpl<
where(NewAction.Fields.publishedAction + ".datasource._id").is(new ObjectId(datasourceId)); where(NewAction.Fields.publishedAction + ".datasource._id").is(new ObjectId(datasourceId));
Criteria datasourceCriteria = Criteria datasourceCriteria =
notDeleted().orOperator(unpublishedDatasourceCriteria, publishedDatasourceCriteria); new Criteria().orOperator(unpublishedDatasourceCriteria, publishedDatasourceCriteria);
Query query = new Query(); return queryBuilder().criteria(datasourceCriteria).count();
query.addCriteria(datasourceCriteria);
return mongoOperations.count(query, NewAction.class);
} }
@Override @Override