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

Revert "chore: Use queryBulider for count op"

Browse Source 
This reverts commit 70cd65ec7d.
This commit is contained in:
Shrikant Sharat Kandula 2024-02-28 11:09:53 +05:30
parent 70cd65ec7d
commit e2d226f127
1 changed files with 6 additions and 2 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,6 +22,7 @@ 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;
@ -350,9 +351,12 @@ 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 =
new Criteria().orOperator(unpublishedDatasourceCriteria, publishedDatasourceCriteria); notDeleted().orOperator(unpublishedDatasourceCriteria, publishedDatasourceCriteria);
return queryBuilder().criteria(datasourceCriteria).count(); Query query = new Query();
query.addCriteria(datasourceCriteria);
return mongoOperations.count(query, NewAction.class);
} }
@Override @Override