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

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

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

TransportClient.prepareDelete介绍

暂无

代码示例

代码示例来源：origin: brianfrankcooper/YCSB

@Override
public Status delete(final String table, final String key) {
 try {
  final SearchResponse searchResponse = search(table, key);
  if (searchResponse.getHits().totalHits == 0) {
   return Status.NOT_FOUND;
  }
  final String id = searchResponse.getHits().getAt(0).getId();
  final DeleteResponse deleteResponse = client.prepareDelete(indexKey, table, id).get();
  if (deleteResponse.getResult() == DocWriteResponse.Result.NOT_FOUND) {
   return Status.NOT_FOUND;
  }
  if (!isRefreshNeeded) {
   synchronized (this) {
    isRefreshNeeded = true;
   }
  }
  return Status.OK;
 } catch (final Exception e) {
  e.printStackTrace();
  return Status.ERROR;
 }
}

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

/**
 * 通过主键删除数据
 *
 * @param mapping
 * @param pkVal
 * @return
 */
public boolean delete(ESMapping mapping, Object pkVal) {
  BulkRequestBuilder bulkRequestBuilder = transportClient.prepareBulk();
  if (mapping.get_id() != null) {
    bulkRequestBuilder
      .add(transportClient.prepareDelete(mapping.get_index(), mapping.get_type(), pkVal.toString()));
  } 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.prepareDelete(mapping.get_index(), mapping.get_type(), hit.getId()));
    }
  }
  return commitBulkRequest(bulkRequestBuilder);
}

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

for (SearchHit hit : response.getHits()) {
  bulkRequestBuilder.add(transportClient
    .prepareDelete(mapping.get_index(), mapping.get_type(), hit.getId()));

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

/**
 * 插入数据
 * 
 * @param mapping
 * @param pkVal
 * @param esFieldData
 * @return
 */
public boolean insert(ESMapping mapping, Object pkVal, Map<String, Object> esFieldData) {
  BulkRequestBuilder bulkRequestBuilder = transportClient.prepareBulk();
  if (mapping.get_id() != null) {
    bulkRequestBuilder
      .add(transportClient.prepareIndex(mapping.get_index(), mapping.get_type(), pkVal.toString())
        .setSource(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.prepareDelete(mapping.get_index(), mapping.get_type(), hit.getId()));
    }
    bulkRequestBuilder
      .add(transportClient.prepareIndex(mapping.get_index(), mapping.get_type()).setSource(esFieldData));
  }
  return commitBulkRequest(bulkRequestBuilder);
}

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

@Override
public void delete(Object entity, Object pKey)
{
  if (entity != null)
  {
    EntityMetadata metadata = KunderaMetadataManager.getEntityMetadata(kunderaMetadata, entity.getClass());
    MetamodelImpl metaModel = (MetamodelImpl) kunderaMetadata.getApplicationMetadata()
        .getMetamodel(metadata.getPersistenceUnit());
    EntityType entityType = metaModel.entity(metadata.getEntityClazz());
    String keyAsString = getKeyAsString(pKey, metadata, metaModel);
    try
    {
      txClient.prepareDelete(metadata.getSchema().toLowerCase(), metadata.getTableName(),
          keyAsString.toString()/* index, type, id */).setRefresh(isRefreshIndexes()).execute().get();
    }
    catch (InterruptedException iex)
    {
      logger.error("Error while deleting record of {}, Caused by :.", pKey, iex);
      throw new PersistenceException(iex);
    }
    catch (ExecutionException eex)
    {
      logger.error("Error while deleting record of {}, Caused by :.", pKey, eex);
      throw new PersistenceException(eex);
    }
  }
}

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

/**
 * @param index 索引名称
 * @param type  索引类型
 * @param id    需要删除对象ID
 * @return 删除
 */
public DeleteRequestBuilder deleteRequest(String index, String type, String id) {
  return client.prepareDelete(index, type, id);
}

代码示例来源：origin: starcwang/canal_mysql_elasticsearch_sync

@Override
  public void deleteById(String index, String type, String id) {
    transportClient.prepareDelete(index, type, id).get();
  }
}

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

@Override
  public void deleteById(String index, String type, String id) {
    transportClient.prepareDelete(index, type, id).get();
  }
}

代码示例来源：origin: eventuate-tram/eventuate-tram-examples-java-spring-todo-list

public void remove(String id) {
  transportClient.prepareDelete(TodoView.INDEX, TodoView.TYPE, id).get();
 }
}

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

/**
 * 删除
 *
 * @param transportClient
 * @throws IOException
 */
private static void delete(TransportClient transportClient) throws IOException {
  DeleteResponse deleteResponse = transportClient.prepareDelete("product_index", "product", "1").get();
  logger.info("--------------------------------：" + deleteResponse.getResult());
}

代码示例来源：origin: zhongchengxcr/canal-elasticsearch

@Override
public void deleteById(String index, String type, List<ElasticsearchMetadata.EsRowData> esRowDataList) {
  esRowDataList.forEach(esRowData -> {
    String idColumn = esRowData.getIdColumn();
    String id = (String) esRowData.getRowData().get(idColumn);
    transportClient.prepareDelete(index, type, id).get();
    logger.info("Delete into elasticsearch  ====> {} ", index + "." + type + "." + id);
  });
}

代码示例来源：origin: io.leopard/leopard-elasticsearch

@Override
public boolean delete(String indexName, String type, String id) {
  DeleteResponse deleteresponse = client.prepareDelete(indexName, type, id).execute().actionGet();
  return true;
}

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

/**
 * 删除一条索引
 *
 * @param index
 * @param type
 * @param id
 * @return
 */
public static DeleteResponse prepareDelete(String index, String type, String id){
  DeleteResponse deleteResponse = getInstance().prepareDelete(index, type, id).get();
  return deleteResponse;
}

代码示例来源：origin: rstyro/Springboot

@Override
public String deltele(String id) {
  DeleteResponse response = transportClient.prepareDelete(index, type, id).get();
  return response.getId();
}

代码示例来源：origin: souyunku/SpringBootExamples

/**
 * 通过ID删除数据
 *
 * @param index 索引，类似数据库
 * @param type  类型，类似表
 * @param id    数据ID
 */
public static void deleteDataById(String index, String type, String id) {
  DeleteResponse response = client.prepareDelete(index, type, id).execute().actionGet();
  LOGGER.info("deleteDataById response status:{},id:{}", response.status().getStatus(), response.getId());
}

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

/**
 * 删除数据
 */
@Test
public void testDelete(){
  DeleteResponse response=client.prepareDelete("twitter", "tweet", "1").get();
  System.out.println("索引名称："+response.getIndex());
  System.out.println("类型："+response.getType());
  System.out.println("文档ID："+response.getId()); // 第一次使用是1
  System.out.println("当前实例状态："+response.status());
}

代码示例来源：origin: lumifyio/securegraph

private void deleteParentDocument(String indexName, Element element) {
  String id = element.getId();
  LOGGER.debug("deleting parent document " + id);
  DeleteResponse deleteResponse = getClient().delete(
      getClient()
          .prepareDelete(indexName, ELEMENT_TYPE, id)
          .request()
  ).actionGet();
  if (!deleteResponse.isFound()) {
    LOGGER.warn("Could not remove element " + element.getId());
  }
}

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

@Override
protected void deleteDocument(SearchDocument doc)
  throws IOException
{
  ElasticsearchDocument esDoc = (ElasticsearchDocument)doc;
  client.prepareDelete(esDoc.getIndex(), esDoc.getType(), esDoc.getId()).setVersion(
      esDoc.getVersion()).execute().actionGet();
}

代码示例来源：origin: org.neolumin.vertexium/vertexium-elasticsearch-parentchild

private void deleteParentDocument(String indexName, Element element) {
  String id = element.getId();
  LOGGER.debug("deleting parent document " + id);
  DeleteResponse deleteResponse = getClient().delete(
      getClient()
          .prepareDelete(indexName, ELEMENT_TYPE, id)
          .request()
  ).actionGet();
  if (!deleteResponse.isFound()) {
    LOGGER.warn("Could not remove element " + element.getId());
  }
}

代码示例来源：origin: org.securegraph/securegraph-elasticsearch

@Override
public void removeElement(Graph graph, Element element, Authorizations authorizations) {
  String indexName = getIndexName(element);
  String id = element.getId();
  LOGGER.debug("deleting document " + id);
  DeleteResponse deleteResponse = getClient().delete(
      getClient()
          .prepareDelete(indexName, ELEMENT_TYPE, id)
          .request()
  ).actionGet();
  if (!deleteResponse.isFound()) {
    throw new SecureGraphException("Could not remove element " + element.getId());
  }
}

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

TransportClient

相关文章

    查看更多
    微信公众号

    热门标签

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

    最新文章

    更多

    TransportClient类方法

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