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

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

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

TransportClient.prepareDeleteByQuery介绍

暂无

代码示例

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

@Override
public void deleteByColumn(String schemaName, String tableName, String columnName, Object columnValue)
{
  Map<String,Object> querySource = new HashMap<String, Object>();
  querySource.put(columnName, columnValue);
  
  DeleteByQueryRequestBuilder deleteQueryBuilder = txClient.prepareDeleteByQuery(schemaName.toLowerCase()).setQuery(querySource).setTypes(tableName);
  
  deleteQueryBuilder.execute().actionGet();
}

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

private void deleteChildDocuments(String indexName, Element element) {
  String parentId = element.getId();
  DeleteByQueryResponse response = getClient()
      .prepareDeleteByQuery(indexName)
      .setTypes(PROPERTY_TYPE)
      .setQuery(
          QueryBuilders.termQuery("_parent", ELEMENT_TYPE + "#" + parentId)
      )
      .execute()
      .actionGet();
  if (response.status() != RestStatus.OK) {
    throw new SecureGraphException("Could not remove child elements " + element.getId() + " (status: " + response.status() + ")");
  }
  if (LOGGER.isDebugEnabled()) {
    for (IndexDeleteByQueryResponse r : response) {
      LOGGER.debug("deleted child document " + r.toString());
    }
  }
}

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

private void deleteChildDocuments(String indexName, Element element) {
  String parentId = element.getId();
  DeleteByQueryResponse response = getClient()
      .prepareDeleteByQuery(indexName)
      .setTypes(PROPERTY_TYPE)
      .setQuery(
          QueryBuilders.termQuery("_parent", ELEMENT_TYPE + "#" + parentId)
      )
      .execute()
      .actionGet();
  if (response.status() != RestStatus.OK) {
    throw new VertexiumException("Could not remove child elements " + element.getId() + " (status: " + response.status() + ")");
  }
  if (LOGGER.isDebugEnabled()) {
    for (IndexDeleteByQueryResponse r : response) {
      LOGGER.debug("deleted child document " + r.toString());
    }
  }
}

相关文章

微信公众号

最新文章

更多