com.mongodb.BasicDBObject.entrySet()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(9.2k)|赞(0)|评价(0)|浏览(142)

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

BasicDBObject.entrySet介绍

暂无

代码示例

代码示例来源:origin: jphp-group/jphp

@Override
public Memory unconvert(Environment env, TraceInfo trace, BasicDBObject arg) throws Throwable {
  if (arg == null) return Memory.NULL;
  ArrayMemory result = ArrayMemory.createHashed(arg.size());
  for (Entry<String, Object> entry : arg.entrySet()) {
    if (entry.getValue() instanceof BasicDBObject) {
      result.put(entry.getKey(), unconvert(env, trace, (BasicDBObject) entry.getValue()));
    } else {
      result.put(entry.getKey(), Memory.wrap(env, entry.getValue()));
    }
  }
  return null;
}

代码示例来源:origin: querydsl/querydsl

private Object negate(BasicDBObject arg) {
  BasicDBList list = new BasicDBList();
  for (Map.Entry<String, Object> entry : arg.entrySet()) {
    if (entry.getKey().equals("$or")) {
      list.add(asDBObject("$nor", entry.getValue()));
    } else if (entry.getKey().equals("$and")) {
      BasicDBList list2 = new BasicDBList();
      for (Object o : ((BasicDBList) entry.getValue())) {
        list2.add(negate((BasicDBObject) o));
      }
      list.add(asDBObject("$or", list2));
    } else if (entry.getValue() instanceof Pattern) {
      list.add(asDBObject(entry.getKey(), asDBObject("$not", entry.getValue())));
    } else if (entry.getValue() instanceof BasicDBObject) {
      list.add(negate(entry.getKey(), (BasicDBObject) entry.getValue()));
    } else {
      list.add(asDBObject(entry.getKey(), asDBObject("$ne", entry.getValue())));
    }
  }
  return list.size() == 1 ? list.get(0) : asDBObject("$or", list);
}

代码示例来源:origin: querydsl/querydsl

private Object negate(String key, BasicDBObject value) {
  if (value.size() == 1) {
    return asDBObject(key, asDBObject("$not", value));
  } else {
    BasicDBList list2 = new BasicDBList();
    for (Map.Entry<String, Object> entry2 : value.entrySet()) {
      list2.add(asDBObject(key,
          asDBObject("$not", asDBObject(entry2.getKey(), entry2.getValue()))));
    }
    return asDBObject("$or", list2);
  }
}

代码示例来源:origin: apache/jackrabbit-oak

@NotNull
private Map<Revision, Object> convertMongoMap(@NotNull BasicDBObject obj) {
  Map<Revision, Object> map = new TreeMap<Revision, Object>(StableRevisionComparator.REVERSE);
  for (Map.Entry<String, Object> entry : obj.entrySet()) {
    map.put(Revision.fromString(entry.getKey()), entry.getValue());
  }
  return map;
}

代码示例来源:origin: org.apache.jackrabbit/oak-store-document

@NotNull
private Map<Revision, Object> convertMongoMap(@NotNull BasicDBObject obj) {
  Map<Revision, Object> map = new TreeMap<Revision, Object>(StableRevisionComparator.REVERSE);
  for (Map.Entry<String, Object> entry : obj.entrySet()) {
    map.put(Revision.fromString(entry.getKey()), entry.getValue());
  }
  return map;
}

代码示例来源:origin: com.lordofthejars/nosqlunit-mongodb

/**
 * Removes the properties defined with @IgnorePropertyValue annotation.
 *
 * @param dataObject Object to filter.
 * @param propertiesToIgnore Properties to filter
 * @return Data object without the properties to be ignored.
 */
private static BasicDBObject filterProperties(BasicDBObject dataObject, Set<String> propertiesToIgnore) {
  BasicDBObject filteredDataObject = new BasicDBObject();
  for (Map.Entry<String, Object> entry : dataObject.entrySet()) {
    if (propertiesToIgnore == null || !propertiesToIgnore.contains(entry.getKey())) {
      filteredDataObject.put(entry.getKey(), entry.getValue());
    }
  }
  return filteredDataObject;
}

代码示例来源:origin: gaillard/mongo-queue-java

/**
 * Count in queue, running true or false
 *
 * @param query query where top level fields do not contain operators. Lower level fields can however. eg: valid {a: {$gt: 1}, "b.c": 3},
 * invalid {$and: [{...}, {...}]}. Should not be null
 * @return count
 */
public long count(final BasicDBObject query) {
  Objects.requireNonNull(query);
  final BasicDBObject completeQuery = new BasicDBObject();
  for (final Entry<String, Object> field : query.entrySet()) {
    completeQuery.append("payload." + field.getKey(), field.getValue());
  }
  return collection.count(completeQuery);
}

代码示例来源:origin: gaillard/mongo-queue-java

/**
 * Count in queue
 *
 * @param query query where top level fields do not contain operators. Lower level fields can however. eg: valid {a: {$gt: 1}, "b.c": 3},
 * invalid {$and: [{...}, {...}]}. Should not be null
 * @param running count running messages or not running
 * @return count
 */
public long count(final BasicDBObject query, final boolean running) {
  Objects.requireNonNull(query);
  final BasicDBObject completeQuery = new BasicDBObject("running", running);
  for (final Entry<String, Object> field : query.entrySet()) {
    completeQuery.append("payload." + field.getKey(), field.getValue());
  }
  return collection.count(completeQuery);
}

代码示例来源:origin: eBay/YiDB

protected void setEmbedObjectValue(BasicDBObject embedObject){
  for (Entry<String, Object> entry : entity.getNode().entrySet()) {
    embedObject.put(entry.getKey(), entry.getValue());
  }
}

代码示例来源:origin: eBay/YiDB

protected void setEmbedObjectValue(BasicDBObject embedObject){
  for (Entry<String, Object> entry : entity.getNode().entrySet()) {
    embedObject.put(entry.getKey(), entry.getValue());
  }
}

代码示例来源:origin: org.eclipse.ditto/ditto-services-utils-persistence

static JsonObject mapBasicDBObjectToJsonObject(final BasicDBObject basicDBObject,
    final Function<String, String> jsonKeyNameReviser) {
  return basicDBObject.entrySet()
      .stream()
      .map(e -> JsonFactory.newField(reviseKeyName(e.getKey(), jsonKeyNameReviser),
          mapJavaObjectToJsonValue(e.getValue(), jsonKeyNameReviser)))
      .collect(JsonCollectors.fieldsToObject());
}

代码示例来源:origin: eBay/YiDB

protected void setEmbedObjectValue(BasicDBObject embedObject) {
  embedObject.clear();
  for (Entry<String, Object> entry : entity.getNode().entrySet()) {
    embedObject.put(entry.getKey(), entry.getValue());
  }
}

代码示例来源:origin: eBay/YiDB

protected void setEmbedObjectValue(BasicDBObject embedObject){
   embedObject.clear();
   for (Entry<String, Object> entry : entity.getNode().entrySet()) {
     embedObject.put(entry.getKey(), entry.getValue());
   }
 }
//

代码示例来源:origin: com.redhat.lightblue.mongo/lightblue-mongo-crud

protected boolean indexFieldsMatch(Index index, DBObject existingIndex) {
  BasicDBObject keys = (BasicDBObject) existingIndex.get("key");
  if (keys != null) {
    List<SortKey> fields = index.getFields();
    if (keys.size() == fields.size()) {
      Iterator<SortKey> sortKeyItr = fields.iterator();
      for (Map.Entry<String, Object> dbKeyEntry : keys.entrySet()) {
        SortKey sortKey = sortKeyItr.next();
        if (!compareSortKeys(sortKey, dbKeyEntry.getKey(), dbKeyEntry.getValue())) {
          return false;
        }
      }
      return true;
    }
  }
  return false;
}

代码示例来源:origin: com.redhat.lightblue.mongo/lightblue-mongo

protected boolean indexFieldsMatch(Index index, DBObject existingIndex) {
  BasicDBObject keys = (BasicDBObject) existingIndex.get("key");
  if (keys != null) {
    List<IndexSortKey> fields = index.getFields();
    if (keys.size() == fields.size()) {
      Iterator<IndexSortKey> sortKeyItr = fields.iterator();
      for (Map.Entry<String, Object> dbKeyEntry : keys.entrySet()) {
        IndexSortKey sortKey = sortKeyItr.next();
        if (!compareSortKeys(sortKey, dbKeyEntry.getKey(), dbKeyEntry.getValue())) {
          return false;
        }
      }
      return true;
    }
  }
  return false;
}

代码示例来源:origin: com.mysema.querydsl/querydsl-mongodb

private Object negate(BasicDBObject arg) {
  BasicDBList list = new BasicDBList();
  for (Map.Entry<String, Object> entry : arg.entrySet()) {
    if (entry.getKey().equals("$or")) {
      list.add(asDBObject("$nor", entry.getValue()));
    } else if (entry.getKey().equals("$and")) {
      BasicDBList list2 = new BasicDBList();
      for (Object o : ((BasicDBList)entry.getValue())) {
        list2.add(negate((BasicDBObject)o));
      }
      list.add(asDBObject("$or", list2));
    } else if (entry.getValue() instanceof Pattern) {
      list.add(asDBObject(entry.getKey(), asDBObject("$not", entry.getValue())));
    } else if (entry.getValue() instanceof BasicDBObject) {
      list.add(negate(entry.getKey(), (BasicDBObject) entry.getValue()));
    } else {
      list.add(asDBObject(entry.getKey(), asDBObject("$ne", entry.getValue())));
    }
  }
  return list.size() == 1 ? list.get(0) : asDBObject("$or", list);
}

代码示例来源:origin: eBay/YiDB

protected void setEmbedObjectValue(BasicDBObject embedObject){
  for (Entry<String, Object> entry : entity.getNode().entrySet()) {
    embedObject.put(entry.getKey(), entry.getValue());
  }
}

代码示例来源:origin: com.mysema.querydsl/querydsl-mongodb

private Object negate(String key, BasicDBObject value) {
  if (value.size() == 1) {
    return asDBObject(key, asDBObject("$not", value));
  } else {
    BasicDBList list2 = new BasicDBList();
    for (Map.Entry<String, Object> entry2 : value.entrySet()) {
      list2.add(asDBObject(key,
          asDBObject("$not", asDBObject(entry2.getKey(), entry2.getValue()))));
    }
    return asDBObject("$or", list2);
  }
}

代码示例来源:origin: eBay/YiDB

protected void setEmbedObjectValue(BasicDBObject embedObject){
   embedObject.clear();
   for (Entry<String, Object> entry : entity.getNode().entrySet()) {
     embedObject.put(entry.getKey(), entry.getValue());
   }
 }
//

代码示例来源:origin: apache/gora

/* pp */ Object fromMongoMap(final String docf, final Schema fieldSchema,
  final BSONDecorator easybson, final Field f) throws GoraException {
 BasicDBObject map = easybson.getDBObject(docf);
 Map<Utf8, Object> rmap = new HashMap<>();
 if (map == null) {
  return new DirtyMapWrapper(rmap);
 }
 for (Entry<String, Object> e : map.entrySet()) {
  String mapKey = e.getKey();
  String decodedMapKey = decodeFieldKey(mapKey);
  DocumentFieldType storeType = mapping.getDocumentFieldType(docf);
  Object o = fromDBObject(fieldSchema.getValueType(), storeType, f, mapKey,
    new BSONDecorator(map));
  rmap.put(new Utf8(decodedMapKey), o);
 }
 return new DirtyMapWrapper<>(rmap);
}

相关文章