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

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

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

Query.getQueryObject介绍

暂无

代码示例

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

  1. @Override
  2. public BulkOperations remove(Query query) {
  3.   Assert.notNull(query, "Query must not be null!");
  4.   DeleteOptions deleteOptions = new DeleteOptions();
  5.   query.getCollation().map(Collation::toMongoCollation).ifPresent(deleteOptions::collation);
  6.   models.add(new DeleteManyModel<>(query.getQueryObject(), deleteOptions));
  7.   return this;
  8. }

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

  1. @Override
  2. public <T> List<T> find(Query query, Class<T> entityClass, String collectionName) {
  3.   Assert.notNull(query, "Query must not be null!");
  4.   Assert.notNull(collectionName, "CollectionName must not be null!");
  5.   Assert.notNull(entityClass, "EntityClass must not be null!");
  6.   return doFind(collectionName, query.getQueryObject(), query.getFieldsObject(), entityClass,
  7.       new QueryCursorPreparer(query, entityClass));
  8. }

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

  1. public long count(Query query, @Nullable Class<?> entityClass, String collectionName) {
  2.   Assert.notNull(query, "Query must not be null!");
  3.   Assert.hasText(collectionName, "Collection name must not be null or empty!");
  4.   CountOptions options = new CountOptions();
  5.   query.getCollation().map(Collation::toMongoCollation).ifPresent(options::collation);
  6.   Document document = queryMapper.getMappedObject(query.getQueryObject(),
  7.       Optional.ofNullable(entityClass).map(it -> mappingContext.getPersistentEntity(entityClass)));
  8.   return doCount(collectionName, document, options);
  9. }

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

  1. @Nullable
  2. @Override
  3. public <T> T findAndRemove(Query query, Class<T> entityClass, String collectionName) {
  4.   Assert.notNull(query, "Query must not be null!");
  5.   Assert.notNull(entityClass, "EntityClass must not be null!");
  6.   Assert.notNull(collectionName, "CollectionName must not be null!");
  7.   return doFindAndRemove(collectionName, query.getQueryObject(), query.getFieldsObject(),
  8.       getMappedSortObject(query, entityClass), query.getCollation().orElse(null), entityClass);
  9. }

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

  1. private Flux<T> doFind(@Nullable FindPublisherPreparer preparer) {
  2.   Document queryObject = query.getQueryObject();
  3.   Document fieldsObject = query.getFieldsObject();
  4.   return template.doFind(getCollectionName(), queryObject, fieldsObject, domainType, returnType,
  5.       preparer != null ? preparer : getCursorPreparer(query));
  6. }

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

  1. public <T> Flux<T> find(@Nullable Query query, Class<T> entityClass, String collectionName) {
  2.   if (query == null) {
  3.     return findAll(entityClass, collectionName);
  4.   }
  5.   return doFind(collectionName, query.getQueryObject(), query.getFieldsObject(), entityClass,
  6.       new QueryFindPublisherPreparer(query, entityClass));
  7. }

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

  1. private List<T> doFind(@Nullable CursorPreparer preparer) {
  2.   Document queryObject = query.getQueryObject();
  3.   Document fieldsObject = query.getFieldsObject();
  4.   return template.doFind(getCollectionName(), queryObject, fieldsObject, domainType, returnType,
  5.       getCursorPreparer(query, preparer));
  6. }

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

  1. @Override
  2. public <T> Flux<T> tail(@Nullable Query query, Class<T> entityClass, String collectionName) {
  3.   if (query == null) {
  4.     // TODO: clean up
  5.     LOGGER.debug(String.format("find for class: %s in collection: %s", entityClass, collectionName));
  6.     return executeFindMultiInternal(
  7.         collection -> new FindCallback(null).doInCollection(collection).cursorType(CursorType.TailableAwait), null,
  8.         new ReadDocumentCallback<>(mongoConverter, entityClass, collectionName), collectionName);
  9.   }
  10.   return doFind(collectionName, query.getQueryObject(), query.getFieldsObject(), entityClass,
  11.       new TailingQueryFindPublisherPreparer(query, entityClass));
  12. }

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

  1. public <T> Mono<T> findOne(Query query, Class<T> entityClass, String collectionName) {
  2.   if (ObjectUtils.isEmpty(query.getSortObject())) {
  3.     return doFindOne(collectionName, query.getQueryObject(), query.getFieldsObject(), entityClass,
  4.         query.getCollation().orElse(null));
  5.   }
  6.   query.limit(1);
  7.   return find(query, entityClass, collectionName).next();
  8. }

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

  1. public <T> Mono<T> findAndModify(Query query, Update update, FindAndModifyOptions options, Class<T> entityClass,
  2.     String collectionName) {
  3.   FindAndModifyOptions optionsToUse = FindAndModifyOptions.of(options);
  4.   Optionals.ifAllPresent(query.getCollation(), optionsToUse.getCollation(), (l, r) -> {
  5.     throw new IllegalArgumentException(
  6.         "Both Query and FindAndModifyOptions define a collation. Please provide the collation only via one of the two.");
  7.   });
  8.   query.getCollation().ifPresent(optionsToUse::collation);
  9.   return doFindAndModify(collectionName, query.getQueryObject(), query.getFieldsObject(),
  10.       getMappedSortObject(query, entityClass), entityClass, update, optionsToUse);
  11. }

代码示例来源：origin: kaaproject/kaa

  1. @Override
  2. public List<MongoEndpointNotification> findNotificationsByKeyHash(final byte[] keyHash) {
  3.  LOG.debug("Find unicast notifications by endpoint key hash [{}] ", keyHash);
  4.  DBObject dbObject = query(where(EP_ENDPOINT_KEY_HASH).is(keyHash)).getQueryObject();
  5.  DBCursor cursor = mongoTemplate.getDb().getCollection(getCollectionName()).find(dbObject);
  6.  List<MongoEndpointNotification> endpointNotifications = new ArrayList<>();
  7.  while (cursor.hasNext()) {
  8.   endpointNotifications.add(mongoTemplate.getConverter()
  9.     .read(MongoEndpointNotification.class, cursor.next()));
  10.  }
  11.  return endpointNotifications;
  12. }

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

  1. @Override
  2. protected Query createQuery(ConvertingParameterAccessor accessor) {
  3.   String queryString = parameterBinder.bind(this.query, accessor,
  4.       new BindingContext(getQueryMethod().getParameters(), queryParameterBindings));
  5.   String fieldsString = parameterBinder.bind(this.fieldSpec, accessor,
  6.       new BindingContext(getQueryMethod().getParameters(), fieldSpecParameterBindings));
  7.   Query query = new BasicQuery(queryString, fieldsString).with(accessor.getSort());
  8.   if (LOG.isDebugEnabled()) {
  9.     LOG.debug(String.format("Created query %s for %s fields.", query.getQueryObject(), query.getFieldsObject()));
  10.   }
  11.   return query;
  12. }

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

  1. protected GridFSFindPublisher prepareQuery(Query query) {
  2.   Assert.notNull(query, "Query must not be null!");
  3.   Document queryObject = getMappedQuery(query.getQueryObject());
  4.   Document sortObject = getMappedQuery(query.getSortObject());
  5.   GridFSFindPublisher publisherToUse = getGridFs().find(queryObject).sort(sortObject);
  6.   Integer cursorBatchSize = query.getMeta().getCursorBatchSize();
  7.   if (cursorBatchSize != null) {
  8.     publisherToUse = publisherToUse.batchSize(cursorBatchSize);
  9.   }
  10.   return publisherToUse;
  11. }

代码示例来源：origin: kaaproject/kaa

  1. @Override
  2. public MongoEndpointProfile findByKeyHash(byte[] endpointKeyHash) {
  3.  LOG.debug("Find endpoint profile by endpoint key hash [{}] ", endpointKeyHash);
  4.  DBObject dbObject = query(where(EP_ENDPOINT_KEY_HASH)
  5.    .is(endpointKeyHash))
  6.    .getQueryObject();
  7.  DBObject result = mongoTemplate.getDb()
  8.    .getCollection(getCollectionName())
  9.    .findOne(dbObject);
  10.  return mongoTemplate.getConverter().read(getDocumentClass(), result);
  11. }

代码示例来源：origin: kaaproject/kaa

  1. @Override
  2. public MongoTopicListEntry findByHash(byte[] hash) {
  3.  LOG.debug("Find topic list entry by hash [{}] ", hash);
  4.  DBObject dbObject = query(where(ID).is(hash)).getQueryObject();
  5.  DBObject result = mongoTemplate.getDb()
  6.    .getCollection(getCollectionName())
  7.    .findOne(dbObject);
  8.  return mongoTemplate.getConverter().read(getDocumentClass(), result);
  9. }

代码示例来源：origin: kaaproject/kaa

  1. @Override
  2. public MongoEndpointConfiguration findByHash(final byte[] hash) {
  3.  LOG.debug("Find endpoint configuration by hash [{}] ", hash);
  4.  DBObject dbObject = query(where(ID).is(hash)).getQueryObject();
  5.  DBObject result = mongoTemplate.getDb()
  6.    .getCollection(getCollectionName())
  7.    .findOne(dbObject);
  8.  return mongoTemplate.getConverter().read(getDocumentClass(), result);
  9. }

代码示例来源：origin: kaaproject/kaa

  1. @Override
  2. public MongoEndpointProfile findByAccessToken(String endpointAccessToken) {
  3.  LOG.debug("Find endpoint profile by access token [{}] ", endpointAccessToken);
  4.  DBObject dbObject = query(where(EP_ACCESS_TOKEN).is(endpointAccessToken))
  5.    .getQueryObject();
  6.  DBObject result = mongoTemplate.getDb()
  7.    .getCollection(getCollectionName())
  8.    .findOne(dbObject);
  9.  return mongoTemplate.getConverter().read(getDocumentClass(), result);
  10. }

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

  1. @Test
  2. public void testBasicQueryFirstPage() {
  3.   ArgumentCaptor<Query> queryContainer = ArgumentCaptor.forClass(Query.class);
  4.   when(template.find(queryContainer.capture(), eq(String.class))).thenReturn(new ArrayList<>());
  5.   assertFalse(reader.doPageRead().hasNext());
  6.   Query query = queryContainer.getValue();
  7.   assertEquals(50, query.getLimit());
  8.   assertEquals(0, query.getSkip());
  9.   assertEquals("{ }", query.getQueryObject().toJson());
  10.   assertEquals("{ \"name\" : -1 }", query.getSortObject().toJson());
  11. }

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

  1. @Test
  2. public void testBasic() throws Exception {
  3.   MongoItemReader<String> reader = getBasicBuilder().build();
  4.   when(template.find(this.queryContainer.capture(), eq(String.class))).thenReturn(new ArrayList<>());
  5.   assertNull("reader should not return result", reader.read());
  6.   Query query = this.queryContainer.getValue();
  7.   assertEquals(50, query.getLimit());
  8.   assertEquals(0, query.getSkip());
  9.   assertEquals("{ }", query.getQueryObject().toJson());
  10.   assertEquals("{ \"name\" : -1 }", query.getSortObject().toJson());
  11. }

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

  1. @Override
  2.   public CloseableIterator<T> doInCollection(MongoCollection<Document> collection)
  3.       throws MongoException, DataAccessException {
  4.     MongoPersistentEntity<?> persistentEntity = mappingContext.getRequiredPersistentEntity(entityType);
  5.     Document mappedFields = getMappedFieldsObject(query.getFieldsObject(), persistentEntity, returnType);
  6.     Document mappedQuery = queryMapper.getMappedObject(query.getQueryObject(), persistentEntity);
  7.     FindIterable<Document> cursor = new QueryCursorPreparer(query, entityType)
  8.         .prepare(collection.find(mappedQuery, Document.class).projection(mappedFields));
  9.     return new CloseableIterableCursorAdapter<>(cursor, exceptionTranslator,
  10.         new ProjectingReadCallback<>(mongoConverter, entityType, returnType, collectionName));
  11.   }
  12. });

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

query

相关文章

    查看更多

    热门标签

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

    最新文章

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