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

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

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

BasicDBObject.getInt介绍

暂无

代码示例

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

private boolean isReplicaSetStarted(BasicDBObject setting) {
  if (setting.get("members") == null) {
    return false;
  }
  BasicDBList members = (BasicDBList) setting.get("members");
  for (Object m : members.toArray()) {
    BasicDBObject member = (BasicDBObject) m;
    logger.info(member.toString());
    int state = member.getInt("state");
    logger.info("state: {}", state);
    // 1 - PRIMARY, 2 - SECONDARY, 7 - ARBITER
    if (state != 1 && state != 2 && state != 7) {
      return false;
    }
  }
  return true;
}

代码示例来源：origin: Graylog2/graylog2-server

} else {
  extentFreeList = DatabaseStats.ExtentFreeList.create(
      extentFreeListMap.getInt("num"),
      extentFreeListMap.getInt("totalSize")
  );
} else {
  dataFileVersion = DatabaseStats.DataFileVersion.create(
      dataFileVersionMap.getInt("major"),
      dataFileVersionMap.getInt("minor")
  );
final BasicDBObject connectionsMap = (BasicDBObject) serverStatusResult.get("connections");
final ServerStatus.Connections connections = ServerStatus.Connections.create(
    connectionsMap.getInt("current"),
    connectionsMap.getInt("available"),
    connectionsMap.containsField("totalCreated") ? connectionsMap.getLong("totalCreated") : null
);
    networkMap.getInt("bytesIn"),
    networkMap.getInt("bytesOut"),
    networkMap.getInt("numRequests")
);
    memoryMap.getInt("bits"),
    memoryMap.getInt("resident"),
    memoryMap.getInt("virtual"),
    memoryMap.getBoolean("supported"),
    memoryMap.getInt("mapped"),

代码示例来源：origin: Graylog2/graylog2-server

new DateTime(systemMap.getDate("currentTime")),
systemMap.getString("hostname"),
systemMap.getInt("cpuAddrSize"),
systemMap.getLong("memSizeMB"),
systemMap.getInt("numCores"),
systemMap.getString("cpuArch"),
systemMap.getBoolean("numaEnabled")

代码示例来源：origin: MorphiaOrg/morphia

@Test
public void shouldUseSuppliedConverterToEncodeAndDecodeObject() {
  // given
  getMorphia().map(CharEntity.class);
  // when
  getDs().save(new CharEntity());
  // then check the representation in the database is a number
  final BasicDBObject dbObj = (BasicDBObject) getDs().getCollection(CharEntity.class).findOne();
  assertThat(dbObj.get("c"), is(instanceOf(int.class)));
  assertThat(dbObj.getInt("c"), is((int) 'a'));
  // then check CharEntity can be decoded from the database
  final CharEntity ce = getDs().find(CharEntity.class).find(new FindOptions().limit(1)).tryNext();
  assertThat(ce.c, is(notNullValue()));
  assertThat(ce.c.charValue(), is('a'));
}

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

Assert.assertTrue(value.containsField("count"));
int age = value.getInt("age");
int count = value.getInt("count");

代码示例来源：origin: NightscoutFoundation/xDrip

public TransmitterRawData(BasicDBObject src) {
  TransmissionId = src.getInt("TransmissionId");
  TransmitterId  = src.getString("TransmitterId");
  RawValue       = src.getInt("RawValue");
  FilteredValue  = src.getInt("FilteredValue");
  BatteryLife    = src.getInt("BatteryLife");
  ReceivedSignalStrength = src.getInt("ReceivedSignalStrength");
  CaptureDateTime = src.getLong("CaptureDateTime");
  UploaderBatteryLife = src.getInt("UploaderBatteryLife");
}

代码示例来源：origin: jamorham/xDrip-plus

public TransmitterRawData(BasicDBObject src) {
  TransmissionId = src.getInt("TransmissionId");
  TransmitterId  = src.getString("TransmitterId");
  RawValue       = src.getInt("RawValue");
  FilteredValue  = src.getInt("FilteredValue");
  BatteryLife    = src.getInt("BatteryLife");
  ReceivedSignalStrength = src.getInt("ReceivedSignalStrength");
  CaptureDateTime = src.getLong("CaptureDateTime");
  UploaderBatteryLife = src.getInt("UploaderBatteryLife");
}

代码示例来源：origin: jamorham/xDrip-plus

public LibreWifiData(BasicDBObject src) {
  BlockBytes = src.getString("BlockBytes");
  CaptureDateTime = src.getLong("CaptureDateTime");
  ChecksumOk = src.getInt("ChecksumOk");
  DebugInfo = src.getString("DebugInfo");
  TomatoBatteryLife = src.getInt("TomatoBatteryLife");
  UploaderBatteryLife = src.getInt("UploaderBatteryLife");
  Uploaded = src.getInt("Uploaded");
  HwVersion = src.getString("HwVersion");
  FwVersion = src.getString("FwVersion");
  SensorId = src.getString("SensorId");
}

代码示例来源：origin: NightscoutFoundation/xDrip

public LibreWifiData(BasicDBObject src) {
  BlockBytes = src.getString("BlockBytes");
  CaptureDateTime = src.getLong("CaptureDateTime");
  ChecksumOk = src.getInt("ChecksumOk");
  DebugInfo = src.getString("DebugInfo");
  TomatoBatteryLife = src.getInt("TomatoBatteryLife");
  UploaderBatteryLife = src.getInt("UploaderBatteryLife");
  Uploaded = src.getInt("Uploaded");
  HwVersion = src.getString("HwVersion");
  FwVersion = src.getString("FwVersion");
  SensorId = src.getString("SensorId");
}

代码示例来源：origin: stackoverflow.com

final BasicDBObject dbObj = null;
if (dbObj.get("computers") != null){
  computerList =  (BasicDBList) dbObj.get("computers");
}
for ( obj : computerList) {
  final BasicDBObject computerAsDBObject = (BasicDBObject) obj;
  final Computer computer = new Computer(computerAsDBObject.getString("name"), 
                      computerAsDBObject.getInt("ipAddress"));
  System.getComputers().add(computer);
}

代码示例来源：origin: pl.edu.icm.synat/synat-core-services-impl

@Override
public YDate convert(BasicDBObject source) {
  if(source == null){
    return null;
  }
  YDate date = new YDate();
  date.setYear(source.getInt("year", 0));
  date.setDay(source.getInt("day", 0));
  date.setMonth(source.getInt("month",0));
  date.setType(source.getString("type"));
  date.setText(source.getString("text"));
  return date;
}

代码示例来源：origin: de.flapdoodle.embed/de.flapdoodle.embed.mongo

private boolean isReplicaSetStarted(BasicDBObject setting) {
  if (setting.get("members") == null) {
    return false;
  }
  BasicDBList members = (BasicDBList) setting.get("members");
  for (Object m : members.toArray()) {
    BasicDBObject member = (BasicDBObject) m;
    logger.info(member.toString());
    int state = member.getInt("state");
    logger.info("state: {}", state);
    // 1 - PRIMARY, 2 - SECONDARY, 7 - ARBITER
    if (state != 1 && state != 2 && state != 7) {
      return false;
    }
  }
  return true;
}

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

/**
 * Access field as a int.
 *
 * @param fieldName fully qualified name of the field to be accessed
 * @return value of the field as a double
 */
public Integer getInt(String fieldName) {
 BasicDBObject parent = getFieldParent(fieldName);
 String lf = getLeafName(fieldName);
 return parent.containsField(lf) && parent.get(lf) != null ? parent.getInt(lf) : null;
}

代码示例来源：origin: protegeproject/webprotege

@Override
  public Mention convert(BasicDBObject dbObject) {
    Object mentionClass = dbObject.get("_class" );
    if("IssueMention".equals(mentionClass)) {
      return new IssueMention(dbObject.getInt("issueNumber"));
    }
    else if("RevisionMention".equals(mentionClass)) {
      return new RevisionMention(dbObject.getLong("revisionNumber"));
    }
    else if("UserIdMention".equals(mentionClass)) {
      return new UserIdMention(UserId.getUserId(dbObject.get("userId").toString()));
    }
    else if("EntityMention".equals(mentionClass)) {
      DBObject entityObject = (DBObject) dbObject.get("entity");
      return new EntityMention(entityReadConverter.convert(entityObject));
    }
    throw new RuntimeException("Unknown class of Mention: " + mentionClass);
  }
}

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

@Test
public void testLoadProperties() {
  DBCollection coll = mongo.getDB(CMSConsts.SYS_DB).getCollection(CMSConsts.PROPERTIES_COLLECTION);
  DBCursor cursor = coll.find();
  
  BasicDBObject object = (BasicDBObject)cursor.next();
  Assert.assertEquals(5000, object.getInt("RepositoryCacheSize"));
  
  object = (BasicDBObject)cursor.next();
  Assert.assertEquals(3600, object.getInt("RepositoryCacheExpireSeconds"));
}

代码示例来源：origin: allegro/hermes

private SentMessageTrace convertToSentMessage(DBObject rawObject) {
  BasicDBObject object = (BasicDBObject) rawObject;
  return new SentMessageTrace(
      object.getString(MESSAGE_ID),
      object.getString(BATCH_ID),
      object.getLong(TIMESTAMP),
      object.getString(SUBSCRIPTION),
      object.getString(TOPIC_NAME),
      SentMessageTraceStatus.valueOf(object.getString(STATUS)),
      object.getString(REASON),
      null,
      object.getInt(PARTITION, -1),
      object.getLong(OFFSET, -1),
      object.getString(CLUSTER, "")
  );
}

代码示例来源：origin: allegro/hermes

private SentMessageTrace convert(DBObject rawObject) {
    BasicDBObject object = (BasicDBObject) rawObject;
    return new SentMessageTrace(
        object.getString(MESSAGE_ID),
        object.getString(BATCH_ID),
        object.getLong(TIMESTAMP),
        object.getString(LogSchemaAware.SUBSCRIPTION),
        object.getString(TOPIC_NAME),
        SentMessageTraceStatus.valueOf(object.getString(STATUS)),
        object.getString(REASON),
        null,
        object.getInt(PARTITION, -1),
        object.getLong(OFFSET, -1),
        object.getString(CLUSTER, "")
    );
  }
}

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

@Test
public void test13Sum() {
  MetaClass metadata = raptorMetaService.getMetaClass("ServiceInstance");
  SearchGroup group = new SearchGroup();
  group.addGroupField(createGroupField(metadata, "healthStatus"));
  group.addGroupField(createGroupField(metadata, "manifestDiff"));
  AggregationField sumPorts = createAggregationField(metadata, AggFuncEnum.SUM, "_pversion");
  group.addAggregationField(sumPorts);
  SearchProjection project = new SearchProjection();
  project.addField(ProjectionField.STAR);
  ISearchQuery query = new SearchQuery(metadata, null, project, group, null, strategy);
  SearchOption option = new SearchOption();
  SearchResult result = searchService.search(query, option, raptorContext);
  Assert.assertEquals(2, result.getResultSize());
  BsonEntity entity = (BsonEntity) result.getResultSet().get(0);
  Assert.assertEquals(3, entity.getNode().size());
  int sumPort = entity.getNode().getInt(sumPorts.getFieldName());
  System.out.println(sumPort);
  Assert.assertTrue(sumPort == -5);
}

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

@Test
public void test13Sum() {
  MetaClass metadata = raptorMetaService.getMetaClass("ServiceInstance");
  SearchGroup group = new SearchGroup();
  group.addGroupField(createGroupField(metadata, "healthStatus"));
  group.addGroupField(createGroupField(metadata, "manifestDiff"));
  AggregationField sumPorts = createAggregationField(metadata, AggFuncEnum.SUM, "_pversion");
  group.addAggregationField(sumPorts);
  SearchProjection project = new SearchProjection();
  project.addField(ProjectionField.STAR);
  ISearchQuery query = new SearchQuery(metadata, null, project, group, null, strategy);
  SearchOption option = new SearchOption();
  SearchResult result = searchService.search(query, option, raptorContext);
  Assert.assertEquals(2, result.getResultSize());
  BsonEntity entity = (BsonEntity) result.getResultSet().get(0);
  Assert.assertEquals(3, entity.getNode().size());
  int sumPort = entity.getNode().getInt(sumPorts.getFieldName());
  System.out.println(sumPort);
  Assert.assertTrue(sumPort == -5);
}

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

@Test
public void test11Count() {
  MetaClass metadata = raptorMetaService.getMetaClass("ServiceInstance");
  SearchGroup group = new SearchGroup();
  group.addGroupField(createGroupField(metadata, "healthStatus"));
  group.addGroupField(createGroupField(metadata, "manifestDiff"));
  AggregationField count = new AggregationField(AggFuncEnum.COUNT, null);
  group.addAggregationField(count);
  Assert.assertEquals("AggregationField [func=COUNT, field=null, aliasName=_count]", count.toString());
  
  SearchProjection projection = new SearchProjection();
  ISearchQuery query = new SearchQuery(metadata, null, projection, group, null, strategy);
  SearchOption option = new SearchOption();
  SearchResult result = searchService.search(query, option, raptorContext);
  Assert.assertEquals(2, result.getResultSize());
  for (IEntity e : result.getResultSet()) {
    BsonEntity entity = (BsonEntity) e;
    List<?> values = count.getSearchValue(entity);
    Assert.assertEquals(5, values.get(0));
    Assert.assertEquals(3, entity.getNode().size());
    Assert.assertEquals(5, entity.getNode().getInt(count.getFieldName()));
  }
}

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

BasicDBObject

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

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