Elasticsearch Java API操作（增刪改查，索引創建）

Elasticsearch的Java客戶端非常強大；它可以建立一個嵌入式實例並在必要時運行管理任務。

運行一個Java應用程序和Elasticsearch時，有兩種操作模式可供使用。該應用程序可在Elasticsearch集群中扮演更加主動或更加被動的角色。在更加主動的情況下（稱為Node Client），應用程序實例將從集群接收請求，確定哪個節點應處理該請求，就像正常節點所做的一樣。（應用程序甚至可以託管索引和處理請求。）另一種模式稱為Transport Client，它將所有請求都轉發到另一個Elasticsearch節點，由後者來確定最終目標。

1.1 API基本操作

1.1.1 操作環境準備

1）創建maven工程

2）添加pom文件

junit

junit

3.8.1

test

org.elasticsearch

elasticsearch

5.6.1

org.elasticsearch.client

transport

5.6.1

org.apache.logging.log4j

log4j-core

2.9.0

當直接在ElasticSearch 建立文檔對象時，如果索引不存在的，默認會自動創建，映射採用默認方式

1.1.2 獲取Transport Client

（1）ElasticSearch服務默認端口9300。

（2）Web管理平臺端口9200。

//org.elasticsearch.transport.client.PreBuiltTransportClient@4bff2185

//org.elasticsearch.transport.client.PreBuiltTransportClient@6f099cef

private TransportClient client;

@SuppressWarnings("unchecked")

@Before

public void getClient() throws Exception {

// 1 設置連接的集群名稱

Settings settings = Settings.builder().put("cluster.name", "my-application").build();

// 2 連接集群

client = new PreBuiltTransportClient(settings);

client.addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("bigdata11"), 9300));

// 3 打印集群名稱

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

}

（3）顯示log4j2報錯，在resource目錄下創建一個文件命名為log4j2.xml並添加如下內容

1.1.3 創建索引

1）源代碼

@Test

public void createIndex_blog(){

// 1 創建索引

client.admin().indices().prepareCreate("blog2").get();

// 2 關閉連接

client.close();

}

2）查看結果

{"blog2":{"aliases":{},"mappings":{},"settings":{"index":{"creation_date":"1507466730030","number_of_shards":"5","number_of_replicas":"1","uuid":"lec0xYiBSmStspGVa6c80Q","version":{"created":"5060299"},"provided_name":"blog2"}}}}

1.1.4 刪除索引

1）源代碼

@Test

public void deleteIndex(){

// 1 刪除索引

client.admin().indices().prepareDelete("blog2").get();

// 2 關閉連接

client.close();

}

2）查看結果

瀏覽器查看
http://bigdata11:9200/blog2

沒有blog2索引了。

{"error":{"root_cause":[{"type":"index_not_found_exception","reason":"no such index","resource.type":"index_or_alias","resource.id":"blog2","index_uuid":"_na_","index":"blog2"}],"type":"index_not_found_exception","reason":"no such index","resource.type":"index_or_alias","resource.id":"blog2","index_uuid":"_na_","index":"blog2"},"status":404}

1.1.5 新建文檔（源數據json串）

當直接在ElasticSearch建立文檔對象時，如果索引不存在的，默認會自動創建，映射採用默認方式。

1）源代碼

@Test

public void createIndexByJson() throws UnknownHostException {

// 1 文檔數據準備

String json = "{" + ""id":"1"," + ""title":"基於Lucene的搜索服務器","

+ ""content":"它提供了一個分佈式多用戶能力的全文搜索引擎，基於RESTful web接口"" + "}";

// 2 創建文檔

IndexResponse indexResponse = client.prepareIndex("blog", "article", "1").setSource(json).execute().actionGet();

// 3 打印返回的結果

System.out.println("index:" + indexResponse.getIndex());

System.out.println("type:" + indexResponse.getType());

System.out.println("id:" + indexResponse.getId());

System.out.println("version:" + indexResponse.getVersion());

System.out.println("result:" + indexResponse.getResult());

// 4 關閉連接

client.close();

}

1.1.6 新建文檔（源數據map方式添加json）

1）源代碼

@Test

public void createIndexByMap() {

// 1 文檔數據準備

Map json = new HashMap();

json.put("id", "2");

json.put("title", "基於Lucene的搜索服務器");

json.put("content", "它提供了一個分佈式多用戶能力的全文搜索引擎，基於RESTful web接口");

// 2 創建文檔

IndexResponse indexResponse = client.prepareIndex("blog", "article", "2").setSource(json).execute().actionGet();

// 3 打印返回的結果

System.out.println("index:" + indexResponse.getIndex());

System.out.println("type:" + indexResponse.getType());

System.out.println("id:" + indexResponse.getId());

System.out.println("version:" + indexResponse.getVersion());

System.out.println("result:" + indexResponse.getResult());

// 4 關閉連接

client.close();

}

1.1.7 新建文檔（源數據es構建器添加json）

1）源代碼

@Test

public void createIndex() throws Exception {

// 1 通過es自帶的幫助類，構建json數據

XContentBuilder builder =
XContentFactory.jsonBuilder().startObject().field("id", 3).field("title", "基於Lucene的搜索服務器").field("content", "它提供了一個分佈式多用戶能力的全文搜索引擎，基於RESTful web接口。")

.endObject();

// 2 創建文檔

IndexResponse indexResponse = client.prepareIndex("blog", "article", "3").setSource(builder).get();

// 3 打印返回的結果

System.out.println("index:" + indexResponse.getIndex());

System.out.println("type:" + indexResponse.getType());

System.out.println("id:" + indexResponse.getId());

System.out.println("version:" + indexResponse.getVersion());

System.out.println("result:" + indexResponse.getResult());

// 4 關閉連接

client.close();

}

1.1.8 搜索文檔數據（單個索引）

1）源代碼

@Test

public void getData() throws Exception {

// 1 查詢文檔

GetResponse response = client.prepareGet("blog", "article", "1").get();

// 2 打印搜索的結果

System.out.println(response.getSourceAsString());

// 3 關閉連接

client.close();

}

1.1.9 搜索文檔數據（多個索引）

1）源代碼

@Test

public void

// 1 查詢多個文檔

MultiGetResponse response = client.prepareMultiGet().add("blog", "article", "1").add("blog", "article", "2", "3").add("blog", "article", "2").get();

// 2 遍歷返回的結果

for(MultiGetItemResponse itemResponse:response){

GetResponse getResponse = itemResponse.getResponse();

// 如果獲取到查詢結果

if (getResponse.isExists()) {

String sourceAsString = getResponse.getSourceAsString();

System.out.println(sourceAsString);

}

}

// 3 關閉資源

client.close();

}

2）結果查看

{"id":"1","title":"基於Lucene的搜索服務器","content":"它提供了一個分佈式多用戶能力的全文搜索引擎，基於RESTful web接口"}

{"content":"它提供了一個分佈式多用戶能力的全文搜索引擎，基於RESTful web接口","id":"2","title":"基於Lucene的搜索服務器"}

{"id":3,"titile":"ElasticSearch是一個基於Lucene的搜索服務器","content":"它提供了一個分佈式多用戶能力的全文搜索引擎，基於RESTful web接口。"}

{"content":"它提供了一個分佈式多用戶能力的全文搜索引擎，基於RESTful web接口","id":"2","title":"基於Lucene的搜索服務器"}

1.1.10 更新文檔數據（update）

1）源代碼 注：只能對已有得文件進行更改

@Test

public void updateData() throws Throwable {

// 1 創建更新數據的請求對象

UpdateRequest updateRequest = new UpdateRequest();

updateRequest.index("blog");

updateRequest.type("article");

updateRequest.id("3");

updateRequest.doc(XContentFactory.jsonBuilder().startObject()

// 對沒有的字段添加, 對已有的字段替換

.field("title", "基於Lucene的搜索服務器")

.field("content","它提供了一個分佈式多用戶能力的全文搜索引擎，基於RESTful web接口。大數據前景無限")

.field("createDate", "2017-8-22").endObject());

// 2 獲取更新後的值

UpdateResponse indexResponse = client.update(updateRequest).get();

// 3 打印返回的結果

System.out.println("index:" + indexResponse.getIndex());

System.out.println("type:" + indexResponse.getType());

System.out.println("id:" + indexResponse.getId());

System.out.println("version:" + indexResponse.getVersion());

System.out.println("create:" + indexResponse.getResult());

// 4 關閉連接

client.close();

}

1.1.11 更新文檔數據（upsert）

設置查詢條件, 查找不到則添加IndexRequest內容，查找到則按照UpdateRequest更新。

@Test

public void testUpsert() throws Exception {

// 設置查詢條件, 查找不到則添加

IndexRequest indexRequest = new IndexRequest("blog", "article", "5")

.source(XContentFactory.jsonBuilder().startObject().field("title", "搜索服務器").field("content","它提供了一個分佈式多用戶能力的全文搜索引擎，基於RESTful web接口。Elasticsearch是用Java開發的，並作為Apache許可條款下的開放源碼發佈，是當前流行的企業級搜索引擎。設計用於雲計算中，能夠達到實時搜索，穩定，可靠，快速，安裝使用方便。").endObject());

// 設置更新, 查找到更新下面的設置

UpdateRequest upsert = new UpdateRequest("blog", "article", "5")

.doc(XContentFactory.jsonBuilder().startObject().field("user", "李四").endObject()).upsert(indexRequest);

client.update(upsert).get();

client.close();

}

第一次執行

bigdata11:9200/blog/article/5

第二次執行

bigdata11:9200/blog/article/5

1.1.12 刪除文檔數據（prepareDelete）

1）源代碼

@Test

public void deleteData() {

// 1 刪除文檔數據

DeleteResponse indexResponse = client.prepareDelete("blog", "article", "5").get();

// 2 打印返回的結果

System.out.println("index:" + indexResponse.getIndex());

System.out.println("type:" + indexResponse.getType());

System.out.println("id:" + indexResponse.getId());

System.out.println("version:" + indexResponse.getVersion());

System.out.println("found:" + indexResponse.getResult());

// 3 關閉連接

client.close();

}

1.2 條件查詢QueryBuilder

1.2.1 查詢所有（matchAllQuery）

1）源代碼

@Test

public void matchAllQuery() {

// 1 執行查詢

SearchResponse searchResponse = client.prepareSearch("blog").setTypes("article")

.setQuery(QueryBuilders.matchAllQuery()).get();

// 2 打印查詢結果

SearchHits hits = searchResponse.getHits(); // 獲取命中次數，查詢結果有多少對象

System.out.println("查詢結果有：" + hits.getTotalHits() + "條");

for (SearchHit hit : hits) {

System.out.println(hit.getSourceAsString());//打印出每條結果

}

// 3 關閉連接

client.close();

}

1.2.2 對所有字段分詞查詢（queryStringQuery）

1）源代碼

@Test

public void query() {

// 1 條件查詢

SearchResponse searchResponse = client.prepareSearch("blog").setTypes("article")

.setQuery(QueryBuilders.queryStringQuery("全文")).get();

// 2 打印查詢結果

SearchHits hits = searchResponse.getHits(); // 獲取命中次數，查詢結果有多少對象

System.out.println("查詢結果有：" + hits.getTotalHits() + "條");

for (SearchHit hit : hits) {

System.out.println(hit.getSourceAsString());//打印出每條結果

}

// 3 關閉連接

client.close();

}

1.2.3 通配符查詢（wildcardQuery）

* ：表示多個字符（0個或多個字符）

？：表示單個字符

1）源代碼

@Test

public void wildcardQuery() {

// 1 通配符查詢

SearchResponse searchResponse = client.prepareSearch("blog").setTypes("article")

.setQuery(QueryBuilders.wildcardQuery("content", "*全*")).get();

// 2 打印查詢結果

SearchHits hits = searchResponse.getHits(); // 獲取命中次數，查詢結果有多少對象

System.out.println("查詢結果有：" + hits.getTotalHits() + "條");

for (SearchHit hit : hits) {

System.out.println(hit.getSourceAsString());//打印出每條結果

}

// 3 關閉連接

client.close();

}

1.2.4 詞條查詢（TermQuery）

1）源代碼

@Test

public void termQuery() {

// 1 第一field查詢

SearchResponse searchResponse = client.prepareSearch("blog").setTypes("article")

.setQuery(QueryBuilders.termQuery("content", "全文")).get();

// 2 打印查詢結果

SearchHits hits = searchResponse.getHits(); // 獲取命中次數，查詢結果有多少對象

System.out.println("查詢結果有：" + hits.getTotalHits() + "條");

for (SearchHit hit : hits) {

System.out.println(hit.getSourceAsString());//打印出每條結果

}

// 3 關閉連接

client.close();

}

1.2.5 模糊查詢（fuzzy）

@Test

public

// 1 模糊查詢

SearchResponse searchResponse = client.prepareSearch("blog").setTypes("article")

.setQuery(QueryBuilders.fuzzyQuery("title", "lucene")).get();

// 2 打印查詢結果

SearchHits hits = searchResponse.getHits(); // 獲取命中次數，查詢結果有多少對象

System.out.println("查詢結果有：" + hits.getTotalHits() + "條");

Iterator iterator = hits.iterator();

while (iterator.hasNext()) {

SearchHit searchHit = iterator.next(); // 每個查詢對象

System.out.println(
searchHit.getSourceAsString()); // 獲取字符串格式打印

}

// 3 關閉連接

client.close();

}

1.3 映射相關操作

1）源代碼

@Test

public void createMapping() throws Exception {

// 1設置mapping

XContentBuilder builder = XContentFactory.jsonBuilder()

.startObject()

.startObject("article")

.startObject("properties")

.startObject("id1")

.field("type", "string")

.field("store", "yes")

.endObject()

.startObject("title2")

.field("type", "string")

.field("store", "no")

.endObject()

.startObject("content")

.field("type", "string")

.field("store", "yes")

.endObject()

.endObject()

.endObject()

.endObject();

// 2 添加mapping

PutMappingRequest mapping = Requests.putMappingRequest("blog4").type("article").source(builder);

client.admin().indices().putMapping(mapping).get();

// 3 關閉資源

client.close();

}