elasticsearch Java API汇总

zoukankan html css js c++ java

elasticsearch Java API汇总
http://blog.csdn.net/changong28/article/details/38445805#comments

3.1 集群的连接

3.1.1 作为Elasticsearch节点
[html] view plain copy

代码：

import static org.elasticsearch.node.NodeBuilder.nodeBuilder;

import org.elasticsearch.client.Client;

import org.elasticsearch.node.Node;



Node node = nodeBuilder().clusterName("escluster2").client(true).

node();

Client client = node.client();
3.1.2 使用Transport连接
[html] view plain copy

代码：

import org.elasticsearch.client.transport.TransportClient;

import org.elasticsearch.common.settings.ImmutableSettings;

import org.elasticsearch.common.settings.Settings;

import org.elasticsearch.common.transport.InetSocketTransportAddress;



Settings settings = ImmutableSettings.settingsBuilder().put("cluster.name", "escluster2").build();

TransportClient client = new TransportClient(settings);

client.addTransportAddress(new InetSocketTransportAddress("127.0.0.1",9300));
3.2 文档的CRUD

3.2.1 查询文档
[java] view plain copy

代码：

GetResponse response = client.prepareGet("library", "book", "1")

.setFields("title", "_source")

.execute().actionGet();
3.2.2 索引文档
[java] view plain copy

代码：

import org.elasticsearch.action.index.IndexResponse;

import org.elasticsearch.client.Client;



IndexResponse response = client.prepareIndex("library", "book", "2")

.setSource("{ "title": "Mastering ElasticSearch"}")

.execute().actionGet();
3.2.3 更新文档
[java] view plain copy

代码：

import org.elasticsearch.action.update.UpdateResponse;

import org.elasticsearch.client.Client;

import java.util.Map;

import org.elasticsearch.common.collect.Maps;



Map<String, Object> params = Maps.newHashMap();

params.put("ntitle", "ElasticSearch Server Book");

UpdateResponse response = client.prepareUpdate("library", "book", "2")

.setScript("ctx._source.title = ntitle")

.setScriptParams(params)

.execute().actionGet();
3.2.4 删除文档
[java] view plain copy

代码：

import org.elasticsearch.action.delete.DeleteResponse;

import org.elasticsearch.client.Client;



DeleteResponse response = client.prepareDelete("library", "book", "2")

.execute().actionGet();
3.3 Elasticsearch检索

3.3.1 Preparing a query
[java] view plain copy

代码：

import org.elasticsearch.action.search.SearchResponse;

import org.elasticsearch.client.Client;

import org.elasticsearch.search.SearchHit;



SearchResponse response = client.prepareSearch("library")

.addFields("title", "_source")

.execute().actionGet();

for(SearchHit hit: response.getHits().getHits()) {

 System.out.println(hit.getId());

 if (hit.getFields().containsKey("title")) {

 System.out.println("field.title: "+ hit.getFields().get("title").getValue());

 }

 System.out.println("source.title: " + hit.getSource().get("title"));

}
3.3.2 Building queries
[java] view plain copy

代码：

import org.elasticsearch.index.query.QueryBuilder;

import org.elasticsearch.index.query.QueryBuilders;



QueryBuilder queryBuilder = QueryBuilders

.disMaxQuery()

.add(QueryBuilders.termQuery("title", "Elastic"))

.add(QueryBuilders.prefixQuery("title", "el"));

System.out.println(queryBuilder.toString());

SearchResponse response = client.prepareSearch("library")

.setQuery(queryBuilder)

.execute().actionGet();
3.3.3 Using the match all documents query
[java] view plain copy

代码：

queryBuilder = QueryBuilders.matchAllQuery()

.boost(11f).normsField("title");
3.3.4 The match query
[java] view plain copy

代码：

queryBuilder = QueryBuilders

.matchQuery("message", "a quick brown fox")

.operator(Operator.AND)

.zeroTermsQuery(ZeroTermsQuery.ALL);
3.3.5 Using the geo shape query
[java] view plain copy

代码：

queryBuilder = QueryBuilders.geoShapeQuery("location",

ShapeBuilder.newRectangle()

.topLeft(13, 53)

.bottomRight(14, 52)

.build());
3.3.6 Paging query
[java] view plain copy

代码：

SearchResponse response = client.prepareSearch("library")

.setQuery(QueryBuilders.matchAllQuery())

.setFrom(10)

.setSize(20)

.execute().actionGet();
3.3.7 Sorting
[java] view plain copy

代码：

SearchResponse response = client.prepareSearch("library")

.setQuery(QueryBuilders.matchAllQuery())

.addSort(SortBuilders.fieldSort("title"))

.addSort("_score", SortOrder.DESC)

.execute().actionGet()
3.3.8 Filtering
[java] view plain copy

代码：

FilterBuilder filterBuilder = FilterBuilders

.andFilter(

FilterBuilders.existsFilter("title").filterName("exist"),

FilterBuilders.termFilter("title", "elastic")

);

SearchResponse response = client.prepareSearch("library")

.setFilter(filterBuilder)

.execute().actionGet();
3.3.9 Faceting
[java] view plain copy

代码：

FacetBuilder facetBuilder = FacetBuilders

.filterFacet("test")

.filter(FilterBuilders.termFilter("title", "elastic"));

SearchResponse response = client.prepareSearch("library")

.addFacet(facetBuilder)

.execute().actionGet();
3.3.10 Highlighting
[java] view plain copy

代码：

SearchResponse response = client.prepareSearch("wikipedia")

.addHighlightedField("title")

.setQuery(QueryBuilders.termQuery("title", "actress"))

.setHighlighterPreTags("<1>", "<2>")

.setHighlighterPostTags("</1>", "</2>")

.execute().actionGet();

for(SearchHit hit: response.getHits().getHits()) {

 HighlightField hField = hit.getHighlightFields().get("title");

 for (Text t : hField.fragments()) {

 System.out.println(t.string());

 }

}
3.3.11 Suggestions
[java] view plain copy

代码：

SearchResponse response = client.prepareSearch("wikipedia")

.setQuery(QueryBuilders.matchAllQuery())

.addSuggestion(new TermSuggestionBuilder("first_suggestion")

.text("graphics designer")

.field("_all"))

.execute().actionGet();



for( Entry<? extends Option> entry : response.getSuggest().getSuggestion("first_suggestion").getEntries()) {

 System.out.println("Check for: " + entry.getText() + ". Options:");

 for( Option option : entry.getOptions()) {

 System.out.println(" " + option.getText());

 }

}
3.3.12 Counting
[java] view plain copy

代码：

CountResponse response = client.prepareCount("library")

.setQuery(QueryBuilders.termQuery("title", "elastic"))

.execute().actionGet();
3.3.13 Scrolling
[java] view plain copy

代码：

SearchResponse responseSearch = client.prepareSearch("library")

.setScroll("1m")

.setSearchType(SearchType.SCAN)

.execute().actionGet();

String scrollId = responseSearch.getScrollId();

SearchResponse response = client.prepareSearchScroll(scrollId).execute().actionGet();
3.3.14 Bulk
[java] view plain copy

代码：

BulkResponse response = client.prepareBulk()

.add(client.prepareIndex("library", "book", "5")

.setSource("{ "title" : "Solr Cookbook"}")

.request())

.add(client.prepareDelete("library", "book", "2").request()).execute().actionGet();
3.3.15 The delete by query
[java] view plain copy

代码：

DeleteByQueryResponse response = client.prepareDeleteByQuery("library")

.setQuery(QueryBuilders.termQuery("title", "ElasticSearch"))

.execute().actionGet();
3.3.16 Multi GET
[java] view plain copy

代码：

MultiGetResponse response = client.prepareMultiGet()

.add("library", "book", "1", "2")

.execute().actionGet();
3.3.16 Multi Search
[java] view plain copy

代码：

MultiSearchResponse response = client.prepareMultiSearch()

.add(client.prepareSearch("library", "book").request())

.add(client.prepareSearch("news").

.setFilter(FilterBuilders.termFilter("tags", "important")))

.execute().actionGet();
3.3.17 Building JSON queries and documents
[java] view plain copy

代码：

IndexResponse response = client

.prepareIndex("library", "book", "2")

.setSource("{ "title": "Mastering ElasticSearch"}")

.execute().actionGet();



Map<String, Object> m = Maps.newHashMap();

m.put("1", "Introduction");

m.put("2", "Basics");

m.put("3", "And the rest");

XContentBuilder json = XContentFactory.jsonBuilder().prettyPrint()

.startObject()

.field("id").value("2123")

.field("lastCommentTime", new Date())

.nullField("published")

.field("chapters").map(m)

.field("title", "Mastering ElasticSearch")

.array("tags", "search", "ElasticSearch", "nosql")

.field("values")

.startArray()

.value(1)

.value(10)

.endArray()

.endObject();
3.4 The administration API

3.4.1 The cluster administration API

3.4.1.1 The cluster and indices health API
[java] view plain copy

代码：

ClusterHealthResponse response = client.admin().cluster()

.prepareHealth("library")

.execute().actionGet();
3.4.1.2 The cluster state API
[java] view plain copy

代码：

ClusterStateResponse response = client.admin().cluster()

.prepareState()

.execute().actionGet();
3.4.1.3 The update settings API
[java] view plain copy

代码：

Map<String, Object> map = Maps.newHashMap();

map.put("indices.ttl.interval", "10m");

ClusterUpdateSettingsResponse response = client.admin().cluster()

.prepareUpdateSettings()

.setTransientSettings(map)

.execute().actionGet();
3.4.1.4 The reroute API
[java] view plain copy

代码：

ClusterRerouteResponse response = client.admin().cluster()

.prepareReroute()

.setDryRun(true)

.add(new MoveAllocationCommand(new ShardId("library", 3), "G3czOt4HQbKZT1RhpPCULw",PvHtEMuRSJ6rLJ27AW3U6w"),

 new CancelAllocationCommand(new ShardId("library", 2), "G3czOt4HQbKZT1RhpPCULw",rue))

.execute().actionGet();
3.4.1.5 The nodes information API
[java] view plain copy

代码：

NodesInfoResponse response = client.admin().cluster()

.prepareNodesInfo()

.setNetwork(true)

.setPlugin(true)

.execute().actionGet();
3.4.1.6 The node statistics API
[java] view plain copy

代码：

NodesStatsResponse response = client.admin().cluster()

.prepareNodesStats()

.all()

.execute().actionGet();
3.4.1.7 The nodes hot threads API
[java] view plain copy

代码：

NodesHotThreadsResponse response = client.admin().cluster()

.prepareNodesHotThreads()

.execute().actionGet();
3.4.1.8 The nodes shutdown API
[java] view plain copy

代码：

NodesShutdownResponse response = client.admin().cluster()

.prepareNodesShutdown()

.execute().actionGet();
3.4.1.9 The search shards API
[java] view plain copy

代码：

ClusterSearchShardsResponse response = client.admin().cluster()

.prepareSearchShards()

.setIndices("library")

.setRouting("12")

.execute().actionGet();
3.4.2 The Indices administration API

3.4.2.1 The index existence API
[java] view plain copy

代码：

IndicesExistsResponse response = client.admin().indices()

.prepareExists("books", "library")

.execute().actionGet();
3.4.2.2 The Type existence API
[java] view plain copy

代码：

TypesExistsResponse response = client.admin().indices()

.prepareTypesExists("library")

.setTypes("book")

.execute().actionGet();
3.4.2.3 The indices stats API
[java] view plain copy

代码：

IndicesStatsResponse response = client.admin().indices()

.prepareStats("library")

.all()

.execute().actionGet();
3.4.2.4 Index status
[java] view plain copy

代码：

IndicesStatusResponse response = client.admin().indices()

.prepareStatus("library")

.setRecovery(true)

.setSnapshot(true)

.execute().actionGet();
3.4.2.5 Segments information API
[java] view plain copy

代码：

IndicesSegmentResponse response = client.admin().indices()

.prepareSegments("library")

.execute().actionGet();
3.4.2.6 Creating an index API
[java] view plain copy

代码：

CreateIndexResponse response = client.admin().indices()

.prepareCreate("news")

.setSettings(ImmutableSettings.settingsBuilder()

.put("number_of_shards", 1))

.addMapping("news", XContentFactory.jsonBuilder()

.startObject()

.startObject("news")

.startObject("properties")

.startObject("title")

.field("analyzer", "whitespace")

.field("type", "string")

.endObject()

.endObject()

.endObject()

.endObject())

.execute().actionGet();
3.4.2.7 Deleting an index
[java] view plain copy

代码：

DeleteIndexResponse response = client.admin().indices()

.prepareDelete("news")

.execute().actionGet();
3.4.2.8 Closing an index
[java] view plain copy

代码：

CloseIndexResponse response = client.admin().indices()

.prepareClose("library")

.execute().actionGet();
3.4.2.9 Opening an index
[java] view plain copy

代码：

OpenIndexResponse response = client.admin().indices()

.prepareOpen("library")

.execute().actionGet();
3.4.2.10 The Refresh API
[java] view plain copy

代码：

RefreshResponse response = client.admin().indices()

.prepareRefresh("library")

.execute().actionGet();
3.4.2.11 The Flush API
[java] view plain copy

代码：

FlushResponse response = client.admin().indices()

.prepareFlush("library")

.setFull(false)

.execute().actionGet();
3.4.2.12 The Optimize API
[java] view plain copy

代码：

OptimizeResponse response = client.admin().indices()

.prepareOptimize("library")

.setMaxNumSegments(2)

.setFlush(true)

.setOnlyExpungeDeletes(false)

.execute().actionGet();
3.4.2.13 The put mapping API
[java] view plain copy

代码：

PutMappingResponse response = client.admin().indices()

.preparePutMapping("news")

.setType("news")

.setSource(XContentFactory.jsonBuilder()

.startObject()

.startObject("news")

.startObject("properties")

.startObject("title")

.field("analyzer", "whitespace")

.field("type", "string")

.endObject()

.endObject()

.endObject()

.endObject())

.execute().actionGet();
3.4.2.14 The delete mapping API
[java] view plain copy

代码：

DeleteMappingResponse response = client.admin().indices()

.prepareDeleteMapping("news")

.setType("news")

.execute().actionGet();
3.4.2.15 The gateway snapshot API
[java] view plain copy

代码：

GatewaySnapshotResponse response = client.admin().indices()

.prepareGatewaySnapshot("news")

.execute().actionGet();
3.4.2.16 The aliases API
[java] view plain copy

代码：

IndicesAliasesResponse response = client.admin().indices()

.prepareAliases()

.addAlias("news", "n")

.addAlias("library", "elastic_books",

FilterBuilders.termFilter("title", "elasticsearch"))

.removeAlias("news", "current_news")

.execute().actionGet();
3.4.2.17 The get aliases API
[java] view plain copy

代码：

IndicesGetAliasesResponse response = client.admin().indices()

.prepareGetAliases("elastic_books", "n")

.execute().actionGet();
3.4.2.18 The aliases exists API
[java] view plain copy

代码：

AliasesExistResponse response = client.admin().indices()

.prepareAliasesExist("elastic*", "unknown")

.execute().actionGet();
3.4.2.19 The clear cache API
[java] view plain copy

代码：

ClearIndicesCacheResponse response = client.admin().indices()

.prepareClearCache("library")

.setFieldDataCache(true)

.setFields("title")

.setFilterCache(true)

.setIdCache(true)

.execute().actionGet();
3.4.2.20 The update settings API
[java] view plain copy

代码：

UpdateSettingsResponse response = client.admin().indices()

.prepareUpdateSettings("library")

.setSettings(ImmutableSettings.builder()

.put("index.number_of_replicas", 2))

.execute().actionGet();
3.4.2.21 The analyze API
[java] view plain copy

代码：

AnalyzeResponse response = client.admin().indices()

.prepareAnalyze("library", "ElasticSearch Servers")

.setTokenizer("whitespace")

.setTokenFilters("nGram")

.execute().actionGet();
3.4.2.22 The put template API
[java] view plain copy

代码：

PutIndexTemplateResponse response = client.admin().indices()

.preparePutTemplate("my_template")

.setTemplate("product*")

.setSettings(ImmutableSettings.builder()

.put("index.number_of_replicas", 2)

.put("index.number_of_shards", 1))

.addMapping("item", XContentFactory.jsonBuilder()

.startObject()

.startObject("item")

.startObject("properties")

.startObject("title")

.field("type", "string")

.endObject()

.endObject()

.endObject()

.endObject())

.execute().actionGet();
3.4.2.23 The delete template API
[java] view plain copy

代码：

DeleteIndexTemplateResponse response = client.admin().indices()

.prepareDeleteTemplate("my_*")

.execute().actionGet();
3.4.2.24 The validate query API
[java] view plain copy

代码：

ValidateQueryResponse response = client.admin().indices()

.prepareValidateQuery("library")

.setExplain(true)

.setQuery(XContentFactory.jsonBuilder()

.startObject()

.field("name").value("elastic search")

.endObject().bytes())

.execute().actionGet();
3.4.2.25 The put warmer API
[java] view plain copy

代码：

PutWarmerResponse response = client.admin().indices()

.preparePutWarmer("library_warmer")

.setSearchRequest(client.prepareSearch("library")

.addFacet(FacetBuilders

.termsFacet("tags").field("tags")))

.execute().actionGet();
3.4.2.26 The delete warmer API
[java] view plain copy

代码：

DeleteWarmerResponse response = client.admin().indices()

.prepareDeleteWarmer()

.setName("library_*")

.execute().actionGet();
查看全文

相关阅读:
QString 与 string转换
 Lua 判断表是否为空方法
 QT 继承QWidget && 继承QDialog
QNetworkAccessManager
Lua语言特色
 Lua逻辑操作符
 Lua语言总结
 Lua 函数
 Lua数据类型
 QT 通过QNetworkReply *获取对应请求的URL地址

原文地址：https://www.cnblogs.com/majw/p/5972980.html

elasticsearch Java API汇总

3.1 集群的连接

3.1.1 作为Elasticsearch节点

3.1.2 使用Transport连接

3.2 文档的CRUD

3.2.1 查询文档

3.2.2 索引文档

3.2.3 更新文档

3.2.4 删除文档

3.3 Elasticsearch检索

3.3.1 Preparing a query

3.3.2 Building queries

3.3.3 Using the match all documents query

3.3.4 The match query

3.3.5 Using the geo shape query

3.3.6 Paging query

3.3.7 Sorting

3.3.8 Filtering

3.3.9 Faceting

3.3.10 Highlighting

3.3.11 Suggestions

3.3.12 Counting

3.3.13 Scrolling

3.3.14 Bulk

3.3.15 The delete by query

3.3.16 Multi GET

3.3.16 Multi Search

3.3.17 Building JSON queries and documents

3.4 The administration API

3.4.1 The cluster administration API

3.4.1.1 The cluster and indices health API

3.4.1.2 The cluster state API

3.4.1.3 The update settings API

3.4.1.4 The reroute API

3.4.1.5 The nodes information API

3.4.1.6 The node statistics API

3.4.1.7 The nodes hot threads API

3.4.1.8 The nodes shutdown API

3.4.1.9 The search shards API

3.4.2 The Indices administration API

3.4.2.1 The index existence API

3.4.2.2 The Type existence API

3.4.2.3 The indices stats API

3.4.2.4 Index status

3.4.2.5 Segments information API

3.4.2.6 Creating an index API

3.4.2.7 Deleting an index

3.4.2.8 Closing an index

3.4.2.9 Opening an index

3.4.2.10 The Refresh API

3.4.2.11 The Flush API

3.4.2.12 The Optimize API

3.4.2.13 The put mapping API

3.4.2.14 The delete mapping API

3.4.2.15 The gateway snapshot API

3.4.2.16 The aliases API

3.4.2.17 The get aliases API

3.4.2.18 The aliases exists API

3.4.2.19 The clear cache API

3.4.2.20 The update settings API

3.4.2.21 The analyze API

3.4.2.22 The put template API

3.4.2.23 The delete template API

3.4.2.24 The validate query API

3.4.2.25 The put warmer API

3.4.2.26 The delete warmer API