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

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

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

BasicDBObject.removeField介绍

暂无

代码示例

代码示例来源:origin: Impetus/Kundera

private List extractAggregationValues(Iterable<DBObject> documents, BasicDBObject aggregation)
{
  List results = new LinkedList();
  if (aggregation != null)
  {
    if (aggregation.containsField("_id") && aggregation.get("_id") == null)
    {
      aggregation.removeField("_id");
    }
  }
  for (DBObject document : documents)
  {
    if (document.containsField("_id") && document.get("_id") == null)
    {
      document.removeField("_id");
    }
    extractAggregationValues(document, results, aggregation != null ? aggregation : (BasicDBObject) document);
  }
  return results;
}

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

/**
 * Requeue message. Same as ackSend() with the same message.
 *
 * @param message message to requeue received from get(). Should not be null
 * @param earliestGet earliest instant that a call to get() can return message. Should not be null
 * @param priority priority for order out of get(). 0 is higher priority than 1. Should not be NaN
 */
public void requeue(final BasicDBObject message, final Date earliestGet, final double priority) {
  Objects.requireNonNull(message);
  Objects.requireNonNull(earliestGet);
  if (Double.isNaN(priority)) {
    throw new IllegalArgumentException("priority was NaN");
  }
  final Object id = message.get("id");
  if (id.getClass() != ObjectId.class) {
    throw new IllegalArgumentException("id must be an ObjectId");
  }
  final BasicDBObject forRequeue = new BasicDBObject(message);
  forRequeue.removeField("id");
  ackSend(message, forRequeue, earliestGet, priority);
}

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

public void removeFieldProperty(String fieldName, String propertyName) {
  MetaField metaField = getMetaClass().getFieldByName(fieldName);
  FieldProperty fp = FieldProperty.fromQueryName(propertyName);
  CheckConditions.checkArgument(fp != null, MessageFormat.format("field property %s not found!", propertyName));
  String propertyValueDbName = metaField.getFlattenPropertyValueDbName(fp);
  bsonObject.removeField(propertyValueDbName);
}

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

@Override
public void removeField(String fieldName) {
  MetaField metaField = getMetaClass().getFieldByName(fieldName);
  CheckConditions.checkArgument(metaField != null, "Can't find meta field %s", fieldName);
  String dbName = metaField.getDbName();
  bsonObject.removeField(dbName); 
}

代码示例来源:origin: com.foursquare/fongo

ret.removeField(projection._1.get(0));
} else {
 addValuesAtPath(ret, result, projection._1, 0);

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

private DBObject buildModifyBody() {
    //Only root document have version, it's controlled by $inc
    BasicDBObject modifyBody = new BasicDBObject();
    BasicDBObject bsonObject = entity.getNode();
    
    //jianxu1: 2012/7/16 remove _id and _version
    bsonObject.removeField("_id");
    bsonObject.removeField(InternalFieldEnum.VERSION.getDbName());
    
    // CMS-2657 : for audit use case, make sure _status are in the modify body
    if (!entity.hasField(InternalFieldEnum.STATUS.getName())) {
      bsonObject.put(InternalFieldEnum.STATUS.getDbName(), StatusEnum.ACTIVE.toString());
    }
    
    modifyBody.put("$set", bsonObject);
    
    BasicDBObject versionObject = new BasicDBObject();
    versionObject.put(InternalFieldEnum.VERSION.getDbName(), 1);
    modifyBody.put("$inc", versionObject);
    return modifyBody;
  }
}

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

private DBObject buildModifyBody() {
    //Only root document have version, it's controlled by $inc
    BasicDBObject modifyBody = new BasicDBObject();
    BasicDBObject bsonObject = entity.getNode();
    
    //jianxu1: 2012/7/16 remove _id and _version
    bsonObject.removeField("_id");
    bsonObject.removeField(InternalFieldEnum.VERSION.getDbName());
    
    // CMS-2657 : for audit use case, make sure _status are in the modify body
    if (!entity.hasField(InternalFieldEnum.STATUS.getName())) {
      bsonObject.put(InternalFieldEnum.STATUS.getDbName(), StatusEnum.ACTIVE.toString());
    }
    
    modifyBody.put("$set", bsonObject);
    
    BasicDBObject versionObject = new BasicDBObject();
    versionObject.put(InternalFieldEnum.VERSION.getDbName(), 1);
    modifyBody.put("$inc", versionObject);
    return modifyBody;
  }
}

代码示例来源:origin: com.impetus.kundera.client/kundera-mongo

private List extractAggregationValues(Iterable<DBObject> documents, BasicDBObject aggregation)
{
  List results = new LinkedList();
  if (aggregation != null)
  {
    if (aggregation.containsField("_id") && aggregation.get("_id") == null)
    {
      aggregation.removeField("_id");
    }
  }
  for (DBObject document : documents)
  {
    if (document.containsField("_id") && document.get("_id") == null)
    {
      document.removeField("_id");
    }
    extractAggregationValues(document, results, aggregation != null ? aggregation : (BasicDBObject) document);
  }
  return results;
}

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

@Override
public void removeField(String fieldName) {
  MetaField metaField = getMetaClass().getFieldByName(fieldName);
  CheckConditions.checkArgument(metaField != null, "Can't find meta field %s", fieldName);
  String dbName = metaField.getDbName();
  bsonObject.removeField(dbName); 
}

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

@Override
public void removeField(String fieldName) {
  MetaField metaField = getMetaClass().getFieldByName(fieldName);
  CheckConditions.checkArgument(metaField != null, "Can't find meta field %s", fieldName);
  String dbName = metaField.getDbName();
  if (!metaField.isInternal()) {
    dbName = metaField.getFlattenValueDbName();
  }
  bsonObject.removeField(dbName);
  for (FieldProperty fp : FieldProperty.values()) {
    removeFieldProperty(fieldName, fp.getName());
  }
}

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

private DBObject buildModifyBody() {
    //Only root document have version, it's controlled by $inc
    BasicDBObject modifyBody = new BasicDBObject();
    BasicDBObject bsonObject = entity.getNode();
    
    //jianxu1: 2012/7/16 remove _id and _version
    bsonObject.removeField("_id");
    bsonObject.removeField(InternalFieldEnum.VERSION.getDbName());
    
    // CMS-2657 : for audit use case, make sure _status are in the modify body
    if (!entity.hasField(InternalFieldEnum.STATUS.getName())) {
      bsonObject.put(InternalFieldEnum.STATUS.getDbName(), StatusEnum.ACTIVE.toString());
    }
    
    modifyBody.put("$set", bsonObject);
    
    BasicDBObject versionObject = new BasicDBObject();
    versionObject.put(InternalFieldEnum.VERSION.getDbName(), 1);
    modifyBody.put("$inc", versionObject);
    return modifyBody;
  }
}

代码示例来源:origin: org.keycloak/keycloak-model-mongo

@Override
  public void update(KeycloakSession session) throws ClassNotFoundException {
    DBCollection clients = db.getCollection("clients");
    DBCursor clientsCursor = clients.find();

    try {
      while (clientsCursor.hasNext()) {
        BasicDBObject client = (BasicDBObject) clientsCursor.next();

        boolean directGrantsOnly = client.getBoolean("directGrantsOnly", false);
        client.append("standardFlowEnabled", !directGrantsOnly);
        client.append("implicitFlowEnabled", false);
        client.append("directAccessGrantsEnabled", directGrantsOnly);
        client.removeField("directGrantsOnly");

        clients.save(client);
      }
    } finally {
      clientsCursor.close();
    }
  }
}

代码示例来源:origin: org.keycloak/keycloak-model-mongo

private void updateIdentityProviders() {
  DBCollection realms = db.getCollection("realms");
  DBCursor realmsCursor = realms.find();
  try {
    while (realmsCursor.hasNext()) {
      BasicDBObject realm = (BasicDBObject) realmsCursor.next();
      BasicDBList identityProviders = (BasicDBList) realm.get("identityProviders");
      if (identityProviders != null) {
        for (Object ipObj : identityProviders) {
          BasicDBObject identityProvider = (BasicDBObject) ipObj;
          boolean updateProfileFirstLogin = identityProvider.getBoolean("updateProfileFirstLogin");
          String upflMode = updateProfileFirstLogin ? IdentityProviderRepresentation.UPFLM_ON : IdentityProviderRepresentation.UPFLM_OFF;
          identityProvider.put("updateProfileFirstLoginMode", upflMode);
          identityProvider.removeField("updateProfileFirstLogin");
          identityProvider.put("trustEmail", false);
        }
      }
      realms.save(realm);
    }
  } finally {
    realmsCursor.close();
  }
}

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

@Override
protected DBObject buildModifyBody(BitSet arrayBits, DBObject rootObject, MetaClass rootMetaClass) {
  MetaField field = getField();
  BasicDBObject embedObject = (BasicDBObject) EmbedDBObjectFilter.filter(entity.getId(), rootObject,
      rootMetaClass, null, helper);
  embedObject.removeField(field.getFlattenValueDbName());
  // field properties
  for (FieldProperty fp : FieldProperty.values()) {
    String fpValueDbName = field.getFlattenPropertyValueDbName(fp);
    embedObject.removeField(fpValueDbName);
  }
  // need to update expression fields : set the payload from the given object to found rootObject
  MetaClass meta = getEntity().getMetaClass();
  if (meta.hasExpressionFields()) {
    List<MetaAttribute> expFields = meta.getExpressionFields();
    for (MetaAttribute expField : expFields) {
      String fieldValueDbName = expField.getFlattenValueDbName();
      embedObject.put(fieldValueDbName, getEntity().getNode().get(fieldValueDbName));
      // updateFieldProperty
      updateFieldProperty(embedObject, expField);
    }
  }
  
  embedObject.put(InternalFieldEnum.MODIFIER.getDbName(), entity.getModifier());
  embedObject.put(InternalFieldEnum.LASTMODIFIED.getDbName(), entity.getLastModified());
  
  return buildSetBody(rootObject);
}

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

@Override
protected DBObject buildModifyBody(BitSet arrayBits, DBObject rootObject, MetaClass rootMetaClass) {
  BasicDBObject embedObject = (BasicDBObject) EmbedDBObjectFilter.filter(entity.getId(), rootObject, rootMetaClass, null, helper);
  embedObject.removeField(getField().getDbName());
  MetaClass meta = getEntity().getMetaClass();
  if (meta.hasExpressionFields()) {
    List<MetaAttribute> expFields = meta.getExpressionFields();
    for (MetaAttribute expField : expFields) {
      String fieldDbName = expField.getDbName();
      embedObject.put(fieldDbName, getEntity().getNode().get(fieldDbName));
    }
  }
  
  embedObject.put(InternalFieldEnum.MODIFIER.getDbName(), entity.getModifier());
  embedObject.put(InternalFieldEnum.LASTMODIFIED.getDbName(), entity.getLastModified());
  
  return buildSetBody(rootObject);
}

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

@Override
protected DBObject buildModifyBody(BitSet arrayBits, DBObject rootObject, MetaClass rootMetaClass) {
  BasicDBObject embedObject = (BasicDBObject) EmbedDBObjectFilter.filter(entity.getId(), rootObject, rootMetaClass, null, helper);
  embedObject.removeField(getField().getDbName());
  MetaClass meta = getEntity().getMetaClass();
  if (meta.hasExpressionFields()) {
    List<MetaAttribute> expFields = meta.getExpressionFields();
    for (MetaAttribute expField : expFields) {
      String fieldDbName = expField.getDbName();
      embedObject.put(fieldDbName, getEntity().getNode().get(fieldDbName));
    }
  }
  
  embedObject.put(InternalFieldEnum.MODIFIER.getDbName(), entity.getModifier());
  embedObject.put(InternalFieldEnum.LASTMODIFIED.getDbName(), entity.getLastModified());
  
  return buildSetBody(rootObject);
}

相关文章