第3講:3.1 ElasticSearch建立索引,增刪改查文件
阿新 • • 發佈:2018-11-15
1.新建一個testIndex類,設定ip和埠,寫getClient(){} 方法,新增@Before註解
package com.cruise; import java.net.InetAddress; import org.elasticsearch.action.delete.DeleteResponse; import org.elasticsearch.action.get.GetResponse; import org.elasticsearch.action.index.IndexResponse; import org.elasticsearch.action.update.UpdateResponse; import org.elasticsearch.client.transport.TransportClient; import org.elasticsearch.common.settings.Settings; import org.elasticsearch.common.transport.InetSocketTransportAddress; import org.elasticsearch.common.xcontent.XContentType; import org.elasticsearch.transport.client.PreBuiltTransportClient; import org.junit.After; import org.junit.Before; import org.junit.Test; import com.google.gson.JsonObject; public class TestIndex { private static String host="192.168.245.40"; private static int port=9300; private TransportClient client =null; @SuppressWarnings({ "resource", "unchecked" }) @Before public void getClient() throws Exception{ client = new PreBuiltTransportClient(Settings.EMPTY) .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName(host),port)); } } |
2.新增JUnit,寫close()方法,新增@After註解
@After public void close(){ if(client!=null){ client.close(); } } |
3.寫testIndex()方法,執行測試;去掉id,測試
@Test public void testIndex() throws Exception{ JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("name", "java程式設計思想"); jsonObject.addProperty("publishDate", "2011-11-11"); jsonObject.addProperty("pirce", "100"); IndexResponse indexResponse = client.prepareIndex("book","java","1") .setSource(jsonObject.toString(), XContentType.JSON).get(); System.out.println("索引名稱:"+indexResponse.getIndex()); System.out.println("型別:"+indexResponse.getType()); System.out.println("id:"+indexResponse.getId()); System.out.println("當前索引狀態:"+indexResponse.status()); } |
測試:
修改(去掉id "1")
@Test public void testIndex() throws Exception{ JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("name", "java程式設計思想"); jsonObject.addProperty("publishDate", "2011-11-11"); jsonObject.addProperty("pirce", "100"); IndexResponse indexResponse = client.prepareIndex("book","java") .setSource(jsonObject.toString(), XContentType.JSON).get(); System.out.println("索引名稱:"+indexResponse.getIndex()); System.out.println("型別:"+indexResponse.getType()); System.out.println("id:"+indexResponse.getId()); System.out.println("當前索引狀態:"+indexResponse.status()); } |
測試:(為了後面的操作方便,測試之後改回"1")