• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java UpdateOneModel类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中com.mongodb.client.model.UpdateOneModel的典型用法代码示例。如果您正苦于以下问题:Java UpdateOneModel类的具体用法?Java UpdateOneModel怎么用?Java UpdateOneModel使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



UpdateOneModel类属于com.mongodb.client.model包,在下文中一共展示了UpdateOneModel类的5个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: updateAll

import com.mongodb.client.model.UpdateOneModel; //导入依赖的package包/类
@Override
public <P extends ParaObject> void updateAll(String appid, List<P> objects) {
	if (StringUtils.isBlank(appid) || objects == null) {
		return;
	}
	try {
		ArrayList<WriteModel<Document>> updates = new ArrayList<WriteModel<Document>>();
		List<String> ids = new ArrayList<String>(objects.size());
		for (P object : objects) {
			if (object != null) {
				object.setUpdated(Utils.timestamp());
				Document id = new Document(ID, object.getId());
				Document data = new Document("$set", toRow(object, Locked.class, true));
				UpdateOneModel<Document> um = new UpdateOneModel<Document>(id, data);
				updates.add(um);
				ids.add(object.getId());
			}
		}
		BulkWriteResult res = getTable(appid).bulkWrite(updates, new BulkWriteOptions().ordered(true));
		logger.debug("Updated: " + res.getModifiedCount() + ", keys: " + ids);
	} catch (Exception e) {
		logger.error(null, e);
	}
	logger.debug("DAO.updateAll() {}", objects.size());
}
 
开发者ID:Erudika,项目名称:para-dao-mongodb,代码行数:26,代码来源:MongoDBDAO.java


示例2: put

import com.mongodb.client.model.UpdateOneModel; //导入依赖的package包/类
/**
 * Put the records in the sink.
 *
 * @param collection the set of records to send.
 */
@Override
public void put(Collection<SinkRecord> collection) {
    List<SinkRecord> records = new ArrayList<>(collection);
    for (int i = 0; i < records.size(); i++) {
        Map<String, List<WriteModel<Document>>> bulks = new HashMap<>();

        for (int j = 0; j < bulkSize && i < records.size(); j++, i++) {
            SinkRecord record = records.get(i);
            Map<String, Object> jsonMap = SchemaUtils.toJsonMap((Struct) record.value());
            String topic = record.topic();

            if (bulks.get(topic) == null) {
                bulks.put(topic, new ArrayList<WriteModel<Document>>());
            }

            Document newDocument = new Document(jsonMap)
                    .append("_id", record.kafkaOffset());

            log.trace("Adding to bulk: {}", newDocument.toString());
            bulks.get(topic).add(new UpdateOneModel<Document>(
                    Filters.eq("_id", record.kafkaOffset()),
                    new Document("$set", newDocument),
                    new UpdateOptions().upsert(true)));
        }
        i--;
        log.trace("Executing bulk");
        for (String key : bulks.keySet()) {
            try {
                com.mongodb.bulk.BulkWriteResult result = mapping.get(key).bulkWrite(bulks.get(key));
            } catch (Exception e) {
                log.error(e.getMessage());
            }
        }
    }
}
 
开发者ID:DataReply,项目名称:kafka-connect-mongodb,代码行数:41,代码来源:MongodbSinkTask.java


示例3: checkFilled

import com.mongodb.client.model.UpdateOneModel; //导入依赖的package包/类
public void checkFilled() {
	LocalDateTime now = LocalDateTime.now();
	LocalDateTime keytime = now.withMinute(0).withSecond(0).withNano(0);
	if (TIMESERIES_ALLOWED_KEYS.stream().anyMatch(key -> {
		Document serie = timeseries.find(Filters.and(Filters.eq("type", key), Filters.eq("timestamp_hour", keytime))).limit(1).first();
		if (serie != null) {
			Map<String, Long> values = (Map<String, Long>) serie.get("values");
			if (values.size() != 60) {
				log.warn("Wrong values size for timeserie collection {}", key);
				return true;
			}
			return false;
		}
		return false;
	})) {
		log.warn("Dropping the timeseries collection");
		timeseries.drop();
	}

	List<? extends WriteModel<Document>> requests = TIMESERIES_ALLOWED_KEYS
			.stream()
			.map(key -> Pair.of(key, timeseries.find(Filters.and(Filters.eq("type", key), Filters.eq("timestamp_hour", keytime))).limit(1).first()))
			.filter(doc -> doc.getRight() == null)
			.map(pair -> pair.getLeft())
			.map(key -> {
				Document document = new Document();
				document.append("type", key).append("timestamp_hour", keytime);
				document.append("values",
						IntStream.range(0, 60).collect(Document::new, (doc, val) -> doc.put(Integer.toString(val), Long.valueOf(0)), Document::putAll));
				return document;
			})
			.map(doc -> new UpdateOneModel<Document>(Filters.and(Filters.eq("type", doc.getString("type")), Filters.eq("timestamp_hour", keytime)),
					new Document("$set", doc), new UpdateOptions().upsert(true))).collect(Collectors.toList());
	if (CollectionUtils.isNotEmpty(requests)) {
		timeseries.bulkWrite(requests);
	}
}
 
开发者ID:Treydone,项目名称:mandrel,代码行数:38,代码来源:MongoMetricsRepository.java


示例4: prepareMinutes

import com.mongodb.client.model.UpdateOneModel; //导入依赖的package包/类
public void prepareMinutes(LocalDateTime keytime) {
	List<? extends WriteModel<Document>> requests = TIMESERIES_ALLOWED_KEYS
			.stream()
			.map(el -> {
				Document document = new Document();
				document.append("type", el).append("timestamp_hour", keytime);
				document.append("values",
						IntStream.range(0, 60).collect(Document::new, (doc, val) -> doc.put(Integer.toString(val), Long.valueOf(0)), Document::putAll));
				return document;
			})
			.map(doc -> new UpdateOneModel<Document>(Filters.and(Filters.eq("type", doc.getString("type")), Filters.eq("timestamp_hour", keytime)),
					new Document("$set", doc), new UpdateOptions().upsert(true))).collect(Collectors.toList());

	timeseries.bulkWrite(requests);
}
 
开发者ID:Treydone,项目名称:mandrel,代码行数:16,代码来源:MongoMetricsRepository.java


示例5: convertBulkOperations

import com.mongodb.client.model.UpdateOneModel; //导入依赖的package包/类
private List<WriteModel<JsonObject>> convertBulkOperations(List<BulkOperation> operations) {
  List<WriteModel<JsonObject>> result = new ArrayList<>(operations.size());
  for (BulkOperation bulkOperation : operations) {
    switch (bulkOperation.getType()) {
    case DELETE:
      Bson bsonFilter = toBson(encodeKeyWhenUseObjectId(bulkOperation.getFilter()));
      if (bulkOperation.isMulti()) {
        result.add(new DeleteManyModel<>(bsonFilter));
      } else {
        result.add(new DeleteOneModel<>(bsonFilter));
      }
      break;
    case INSERT:
      result.add(new InsertOneModel<>(encodeKeyWhenUseObjectId(bulkOperation.getDocument())));
      break;
    case REPLACE:
      result.add(new ReplaceOneModel<>(toBson(encodeKeyWhenUseObjectId(bulkOperation.getFilter())), bulkOperation.getDocument(),
          new com.mongodb.client.model.UpdateOptions().upsert(bulkOperation.isUpsert())));
      break;
    case UPDATE:
      Bson filter = toBson(encodeKeyWhenUseObjectId(bulkOperation.getFilter()));
      Bson document = toBson(encodeKeyWhenUseObjectId(bulkOperation.getDocument()));
      com.mongodb.client.model.UpdateOptions updateOptions = new com.mongodb.client.model.UpdateOptions()
          .upsert(bulkOperation.isUpsert());
      if (bulkOperation.isMulti()) {
        result.add(new UpdateManyModel<>(filter, document, updateOptions));
      } else {
        result.add(new UpdateOneModel<>(filter, document, updateOptions));
      }
      break;
    default:
      throw new IllegalArgumentException("Unknown bulk operation type: " + bulkOperation.getClass());
    }
  }
  return result;
}
 
开发者ID:vert-x3,项目名称:vertx-mongo-client,代码行数:37,代码来源:MongoClientImpl.java



注:本文中的com.mongodb.client.model.UpdateOneModel类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java ProviderApplyWhereMethodGenerator类代码示例发布时间:2022-05-22
下一篇:
Java RandomTokenSequenceIterator类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap