org.springframework.data.mongodb.core.query.Query.addCriteria()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(9.1k)|赞(0)|评价(0)|浏览(278)

本文整理了Java中org.springframework.data.mongodb.core.query.Query.addCriteria方法的一些代码示例，展示了Query.addCriteria的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Query.addCriteria方法的具体详情如下：
包路径：org.springframework.data.mongodb.core.query.Query
类名称：Query
方法名：addCriteria

Query.addCriteria介绍

[英]Adds the given CriteriaDefinition to the current Query.
[中]将给定的CriteriaDefinition添加到当前查询。

代码示例

代码示例来源：origin: spring-projects/spring-data-mongodb

  1. /**
  2.  * Creates a new {@link Query} using the given {@link CriteriaDefinition}.
  3.  *
  4.  * @param criteriaDefinition must not be {@literal null}.
  5.  * @since 1.6
  6.  */
  7. public Query(CriteriaDefinition criteriaDefinition) {
  8.   addCriteria(criteriaDefinition);
  9. }

代码示例来源：origin: yu199195/hmily

  1. @Override
  2. public List<HmilyTransaction> listAllByDelay(final Date date) {
  3.   Query query = new Query();
  4.   query.addCriteria(Criteria.where("lastTime").lt(date));
  5.   final List<MongoAdapter> mongoBeans =
  6.       template.find(query, MongoAdapter.class, collectionName);
  7.   if (CollectionUtils.isNotEmpty(mongoBeans)) {
  8.     return mongoBeans.stream().map(this::buildByCache).collect(Collectors.toList());
  9.   }
  10.   return Collections.emptyList();
  11. }

代码示例来源：origin: yu199195/myth

  1. @Override
  2. public List<MythTransaction> listAllByDelay(final Date date) {
  3.   Query query = new Query();
  4.   query.addCriteria(Criteria.where("lastTime").lt(date))
  5.       .addCriteria(Criteria.where("status").is(MythStatusEnum.BEGIN.getCode()));
  6.   final List<MongoAdapter> mongoBeans = template.find(query, MongoAdapter.class, collectionName);
  7.   if (CollectionUtils.isNotEmpty(mongoBeans)) {
  8.     return mongoBeans.stream().map(this::buildByCache).collect(Collectors.toList());
  9.   }
  10.   return Collections.emptyList();
  11. }

代码示例来源：origin: yu199195/hmily

  1. @Override
  2. public Boolean batchRemove(final List<String> ids, final String applicationName) {
  3.   if (CollectionUtils.isEmpty(ids) || StringUtils.isBlank(applicationName)) {
  4.     return Boolean.FALSE;
  5.   }
  6.   final String mongoTableName = RepositoryPathUtils.buildMongoTableName(applicationName);
  7.   ids.forEach(id -> {
  8.     Query query = new Query();
  9.     query.addCriteria(new Criteria("transId").is(id));
  10.     mongoTemplate.remove(query, mongoTableName);
  11.   });
  12.   return Boolean.TRUE;
  13. }

代码示例来源：origin: yu199195/myth

  1. @Override
  2. public Boolean batchRemove(final List<String> ids, final String appName) {
  3.   if (CollectionUtils.isEmpty(ids) || StringUtils.isBlank(appName)) {
  4.     return Boolean.FALSE;
  5.   }
  6.   final String mongoTableName = RepositoryPathUtils.buildMongoTableName(appName);
  7.   ids.forEach(id -> {
  8.     Query query = new Query();
  9.     query.addCriteria(new Criteria("transId").is(id));
  10.     mongoTemplate.remove(query, mongoTableName);
  11.   });
  12.   return Boolean.TRUE;
  13. }

代码示例来源：origin: yu199195/Raincat

  1. @Override
  2. public Boolean batchRemove(final List<String> ids, final String applicationName) {
  3.   if (CollectionUtils.isEmpty(ids) || StringUtils.isBlank(applicationName)) {
  4.     return Boolean.FALSE;
  5.   }
  6.   final String mongoTableName = RepositoryPathUtils.buildMongoTableName(applicationName);
  7.   ids.forEach(id -> {
  8.     Query query = new Query();
  9.     query.addCriteria(new Criteria("transId").is(id));
  10.     mongoTemplate.remove(query, mongoTableName);
  11.   });
  12.   return Boolean.TRUE;
  13. }

代码示例来源：origin: yu199195/Raincat

  1. @Override
  2. public List<TransactionRecover> listAllByDelay(final Date date) {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("status")
  5.       .in(TransactionStatusEnum.BEGIN.getCode(),
  6.           TransactionStatusEnum.FAILURE.getCode(),
  7.           TransactionStatusEnum.ROLLBACK.getCode()))
  8.       .addCriteria(Criteria.where("lastTime").lt(date));
  9.   final List<MongoAdapter> mongoBeans =
  10.       template.find(query, MongoAdapter.class, collectionName);
  11.   if (CollectionUtils.isNotEmpty(mongoBeans)) {
  12.     return mongoBeans.stream().map(this::buildByCache).collect(Collectors.toList());
  13.   }
  14.   return null;
  15. }

代码示例来源：origin: yu199195/Raincat

  1. @Override
  2. public List<TransactionRecover> listAll() {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("status")
  5.       .in(TransactionStatusEnum.BEGIN.getCode(),
  6.           TransactionStatusEnum.FAILURE.getCode(),
  7.           TransactionStatusEnum.ROLLBACK.getCode()));
  8.   final List<MongoAdapter> mongoAdapterList =
  9.       template.find(query, MongoAdapter.class, collectionName);
  10.   if (CollectionUtils.isNotEmpty(mongoAdapterList)) {
  11.     return mongoAdapterList.stream().map(this::buildByCache).collect(Collectors.toList());
  12.   }
  13.   return null;
  14. }

代码示例来源：origin: yu199195/hmily

  1. @Override
  2. public HmilyTransaction findById(final String id) {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("transId").is(id));
  5.   MongoAdapter cache = template.findOne(query, MongoAdapter.class, collectionName);
  6.   return buildByCache(Objects.requireNonNull(cache));
  7. }

代码示例来源：origin: yu199195/myth

  1. @Override
  2. public int remove(final String transId) {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("transId").is(transId));
  5.   template.remove(query, collectionName);
  6.   return CommonConstant.SUCCESS;
  7. }

代码示例来源：origin: yu199195/hmily

  1. @Override
  2. public int remove(final String id) {
  3.   AssertUtils.notNull(id);
  4.   Query query = new Query();
  5.   query.addCriteria(new Criteria("transId").is(id));
  6.   template.remove(query, collectionName);
  7.   return ROWS;
  8. }

代码示例来源：origin: yu199195/myth

  1. @Override
  2. public MythTransaction findByTransId(final String transId) {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("transId").is(transId));
  5.   MongoAdapter cache = template.findOne(query, MongoAdapter.class, collectionName);
  6.   return buildByCache(cache);
  7. }

代码示例来源：origin: yu199195/Raincat

  1. @Override
  2. public int remove(final String id) {
  3.   Assert.notNull(id);
  4.   Query query = new Query();
  5.   query.addCriteria(new Criteria("transId").is(id));
  6.   template.remove(query, collectionName);
  7.   return ROWS;
  8. }

代码示例来源：origin: yu199195/Raincat

  1. @Override
  2. public TransactionRecover findById(final String id) {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("transId").is(id));
  5.   MongoAdapter cache = template.findOne(query, MongoAdapter.class, collectionName);
  6.   return buildByCache(cache);
  7. }

代码示例来源：origin: yu199195/hmily

  1. @Override
  2. public Boolean updateRetry(final String id, final Integer retry, final String appName) {
  3.   if (StringUtils.isBlank(id) || StringUtils.isBlank(appName) || Objects.isNull(retry)) {
  4.     return Boolean.FALSE;
  5.   }
  6.   final String mongoTableName = RepositoryPathUtils.buildMongoTableName(appName);
  7.   Query query = new Query();
  8.   query.addCriteria(new Criteria("transId").is(id));
  9.   Update update = new Update();
  10.   update.set("lastTime", DateUtils.getCurrentDateTime());
  11.   update.set("retriedCount", retry);
  12.   final UpdateResult updateResult = mongoTemplate.updateFirst(query, update,
  13.       MongoAdapter.class, mongoTableName);
  14.   if (updateResult.getModifiedCount() <= 0) {
  15.     throw new HmilyRuntimeException("更新数据异常!");
  16.   }
  17.   return Boolean.TRUE;
  18. }

代码示例来源：origin: yu199195/hmily

  1. @Override
  2. public int updateStatus(final String id, final Integer status) {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("transId").is(id));
  5.   Update update = new Update();
  6.   update.set("status", status);
  7.   final UpdateResult updateResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
  8.   if (updateResult.getModifiedCount() <= 0) {
  9.     throw new HmilyRuntimeException("update data exception!");
  10.   }
  11.   return ROWS;
  12. }

代码示例来源：origin: yu199195/myth

  1. @Override
  2. public int updateStatus(final String id, final Integer status) throws MythRuntimeException {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("transId").is(id));
  5.   Update update = new Update();
  6.   update.set("status", status);
  7.   final WriteResult writeResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
  8.   if (writeResult.getN() <= 0) {
  9.     throw new MythRuntimeException(ERROR);
  10.   }
  11.   return CommonConstant.SUCCESS;
  12. }

代码示例来源：origin: yu199195/myth

  1. @Override
  2. public void updateFailTransaction(final MythTransaction mythTransaction) throws MythRuntimeException {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("transId").is(mythTransaction.getTransId()));
  5.   Update update = new Update();
  6.   update.set("status", mythTransaction.getStatus());
  7.   update.set("errorMsg", mythTransaction.getErrorMsg());
  8.   update.set("lastTime", new Date());
  9.   update.set("retriedCount", mythTransaction.getRetriedCount());
  10.   final WriteResult writeResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
  11.   if (writeResult.getN() <= 0) {
  12.     throw new MythRuntimeException(ERROR);
  13.   }
  14. }

代码示例来源：origin: yu199195/hmily

  1. @Override
  2. public int updateParticipant(final HmilyTransaction hmilyTransaction) {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("transId").is(hmilyTransaction.getTransId()));
  5.   Update update = new Update();
  6.   try {
  7.     update.set("contents", objectSerializer.serialize(hmilyTransaction.getHmilyParticipants()));
  8.   } catch (HmilyException e) {
  9.     e.printStackTrace();
  10.   }
  11.   final UpdateResult updateResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
  12.   if (updateResult.getModifiedCount() <= 0) {
  13.     throw new HmilyRuntimeException("update data exception!");
  14.   }
  15.   return ROWS;
  16. }

代码示例来源：origin: yu199195/myth

  1. @Override
  2. public void updateParticipant(final MythTransaction mythTransaction) throws MythRuntimeException {
  3.   Query query = new Query();
  4.   query.addCriteria(new Criteria("transId").is(mythTransaction.getTransId()));
  5.   Update update = new Update();
  6.   try {
  7.     update.set("contents", objectSerializer.serialize(mythTransaction.getMythParticipants()));
  8.   } catch (MythException e) {
  9.     e.printStackTrace();
  10.   }
  11.   final WriteResult writeResult = template.updateFirst(query, update, MongoAdapter.class, collectionName);
  12.   if (writeResult.getN() <= 0) {
  13.     throw new MythRuntimeException(ERROR);
  14.   }
  15. }

内容来源于网络，如有侵权，请联系作者删除！

query

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com