org.elasticsearch.client.transport.TransportClient.prepareUpdate()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(5.6k)|赞(0)|评价(0)|浏览(192)

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

TransportClient.prepareUpdate介绍

暂无

代码示例

代码示例来源:origin: alibaba/canal

public void append4Update(BulkRequestBuilder bulkRequestBuilder, ESMapping mapping, Object pkVal,
             Map<String, Object> esFieldData) {
  if (mapping.get_id() != null) {
    bulkRequestBuilder
      .add(transportClient.prepareUpdate(mapping.get_index(), mapping.get_type(), pkVal.toString())
        .setDoc(esFieldData));
  } else {
    SearchResponse response = transportClient.prepareSearch(mapping.get_index())
      .setTypes(mapping.get_type())
      .setQuery(QueryBuilders.termQuery(mapping.getPk(), pkVal))
      .setSize(MAX_BATCH_SIZE)
      .get();
    for (SearchHit hit : response.getHits()) {
      bulkRequestBuilder
        .add(transportClient.prepareUpdate(mapping.get_index(), mapping.get_type(), hit.getId())
          .setDoc(esFieldData));
    }
  }
}

代码示例来源:origin: petterobam/database-oop

/**
 * @param index 索引
 * @param type 类型
 * @param id    d
 * @return d
 */
public UpdateRequestBuilder updateRequest(String index, String type, String id) {
  return client.prepareUpdate(index, type, id);
}

代码示例来源:origin: whiney/springboot-elasticsearch

@Override
public void updateById(String index, String type, String id, String jsonStr) {
  transportClient.prepareUpdate(index, type,id)
      .setDoc(jsonStr, XContentType.JSON)
      .get();
}

代码示例来源:origin: caojx-git/learn

/**
 * 更新数据
 * ElasticSearch提供了根据索引名称,类别,文档ID来修改数据,修改的设置数据可以是Map,Json串,自带工具。我们实际开发一般用Json。
 */
@Test
public void testUpdate(){
  JSONObject jsonObject=new JSONObject();
  jsonObject.put("user", "锋哥");
  jsonObject.put("postDate", "1989-11-11");
  jsonObject.put("message", "学习Elasticsearch");
  UpdateResponse response = client.prepareUpdate("twitter", "tweet", "1").setDoc(jsonObject.toString(),XContentType.JSON).get();
  System.out.println("索引名称:"+response.getIndex());
  System.out.println("类型:"+response.getType());
  System.out.println("文档ID:"+response.getId());
  System.out.println("当前实例状态:"+response.status());
}

代码示例来源:origin: judasn/Elasticsearch-Tutorial-zh-CN

/**
 * 修改
 *
 * @param transportClient
 * @throws IOException
 */
private static void update(TransportClient transportClient) throws IOException {
  UpdateResponse updateResponse = transportClient.prepareUpdate("product_index", "product", "1")
      .setDoc(XContentFactory.jsonBuilder()
          .startObject()
          .field("product_name", "飞利浦电动牙刷 HX6700 促销优惠")
          .endObject())
      .get();
  logger.info("--------------------------------:" + updateResponse.getResult());
}

代码示例来源:origin: xuxueli/xxl-search

/**
 * 更新一条索引   (overwrite exists)
 *
 * @param index
 * @param type
 * @param id
 * @param source
 * @return
 */
public static UpdateResponse prepareUpdate(String index, String type, String id, Map source) {
  UpdateResponse response = getInstance().prepareUpdate(index, type, id).setDoc(source).get();
  return response;
}

代码示例来源:origin: ConsenSys/IPFS-Store

.prepareUpdate(indexFormated, indexFormated, documentId)
.setDoc(convertObjectToJsonString(source), XContentType.JSON).get();

代码示例来源:origin: judasn/Elasticsearch-Tutorial-zh-CN

/**
 * 批量更新
 *
 * @param transportClient
 */
private static void batchUpdate(TransportClient transportClient) throws IOException {
  BulkRequestBuilder bulkRequestBuilder = transportClient.prepareBulk();
  UpdateRequestBuilder updateRequestBuilder1 = transportClient.prepareUpdate("product_index", "product", "1")
      .setDoc(XContentFactory.jsonBuilder()
          .startObject()
          .field("product_name", "更新后的商品名称1")
          .endObject());
  UpdateRequestBuilder updateRequestBuilder2 = transportClient.prepareUpdate("product_index", "product", "2")
      .setDoc(XContentFactory.jsonBuilder()
          .startObject()
          .field("product_name", "更新后的商品名称2")
          .endObject());
  UpdateRequestBuilder updateRequestBuilder3 = transportClient.prepareUpdate("product_index", "product", "3")
      .setDoc(XContentFactory.jsonBuilder()
          .startObject()
          .field("product_name", "更新后的商品名称3")
          .endObject());
  bulkRequestBuilder.add(updateRequestBuilder1);
  bulkRequestBuilder.add(updateRequestBuilder2);
  bulkRequestBuilder.add(updateRequestBuilder3);
  BulkResponse bulkResponse = bulkRequestBuilder.get();
  for (BulkItemResponse bulkItemResponse : bulkResponse.getItems()) {
    logger.info("--------------------------------version= " + bulkItemResponse.getVersion());
  }
}

代码示例来源:origin: org.eclipse.rdf4j/rdf4j-sail-elasticsearch

@Override
protected void updateDocument(SearchDocument doc)
  throws IOException
{
  ElasticsearchDocument esDoc = (ElasticsearchDocument)doc;
  doUpdateRequest(client.prepareUpdate(esDoc.getIndex(), esDoc.getType(), esDoc.getId()).setVersion(
      esDoc.getVersion()).setDoc(esDoc.getSource()));
}

代码示例来源:origin: harbby/sylph

return;
UpdateRequestBuilder requestBuilder = client.prepareUpdate(config.index, config.type, id.toString());
requestBuilder.setDoc(map);
requestBuilder.setDocAsUpsert(true);

代码示例来源:origin: harbby/sylph

return;
UpdateRequestBuilder requestBuilder = client.prepareUpdate(config.index, config.type, id.toString());
requestBuilder.setDoc(map);
requestBuilder.setDocAsUpsert(true);

代码示例来源:origin: Stratio/wikipedia-parser

UpdateRequest updateRequest = client.prepareUpdate()
                  .setIndex(index)
                  .setType(type)

代码示例来源:origin: ef-labs/vertx-elasticsearch-service

@Override
public void update(String index, String type, String id, UpdateOptions options, Handler<AsyncResult<JsonObject>> resultHandler) {
  UpdateRequestBuilder builder = client.prepareUpdate(index, type, id);

相关文章

微信公众号

最新文章

更多