2. 程式人生 > >Elasticsearch簡單操作（Java程式碼）

Elasticsearch簡單操作（Java程式碼）

阿新 • • 發佈：2019-02-19

1.首先安裝Elasticsearch，配置相關檔案，並啟動服務

2.建立專案，匯入相關Jar包

3.建立ElasticsearchUtils類，裡面包括初始化操作和建立索引、更新索引、刪除索引、查詢索引

（1）初始化操作，需要傳入叢集名稱和ip地址，叢集名稱本例子使用elasticsearch配置檔案中配置的cluster name,IP地址使用localhost

[java] view plain copy print?
  1. publicclass ElasticsearchUtils {  
  2.     private Client client;  
  3.     public ElasticsearchUtils(String clusterName, String ipAddress) {  
  4.         Settings settings = ImmutableSettings  
  5.                 .settingsBuilder()  
  6.                 //設定叢集名稱 
  7.                 .put(”cluster.name”, clusterName)  
  8.                 .put(”client.transport.ignore_cluster_name”, false)  
  9.                 .put(”node.client”, true).put(“client.transport.sniff”, true
    )  
  10.                 .build();  
  11.         client = new TransportClient(settings)  
  12.                 .addTransportAddress(new InetSocketTransportAddress(ipAddress,  
  13.                         9300));//此處埠號為9300
  14.     }  
  15. }  
public class ElasticsearchUtils {

    private Client client;

    public ElasticsearchUtils(String clusterName, String ipAddress) {
        Settings settings = ImmutableSettings
                .settingsBuilder()
                //設定叢集名稱 
                .put("cluster.name", clusterName)
                .put("client.transport.ignore_cluster_name", false)
                .put("node.client", true).put("client.transport.sniff", true)
                .build();
        client = new TransportClient(settings)
                .addTransportAddress(new InetSocketTransportAddress(ipAddress,
                        9300));//此處埠號為9300
    }
}
（2）建立索引 [java] view plain copy print?
  1. /** 
  2.      * 建立索引 
  3.      * @param indexName 索引名稱，相當於資料庫名稱 
  4.      * @param typeName 索引型別，相當於資料庫中的表名 
  5.      * @param id id名稱，相當於每個表中某一行記錄的標識 
  6.      * @param jsonData json資料 
  7.      */
  8.     publicvoid createIndex(String indexName, String typeName, String id,  
  9.             String jsonData) {  
  10.         IndexRequestBuilder requestBuilder = client.prepareIndex(indexName,  
  11.             typeName, id).setRefresh(true);//設定索引名稱，索引型別，id
  12.         requestBuilder.setSource(jsonData).execute().actionGet();//建立索引
  13.     }  
/**
     * 建立索引
     * @param indexName 索引名稱，相當於資料庫名稱
     * @param typeName 索引型別，相當於資料庫中的表名
     * @param id id名稱，相當於每個表中某一行記錄的標識
     * @param jsonData json資料
     */
    public void createIndex(String indexName, String typeName, String id,
            String jsonData) {
        IndexRequestBuilder requestBuilder = client.prepareIndex(indexName,
            typeName, id).setRefresh(true);//設定索引名稱，索引型別，id
        requestBuilder.setSource(jsonData).execute().actionGet();//建立索引
    }
（3）查詢索引 [java] view plain copy print?
  1. /** 
  2.     * 執行搜尋 
  3.     * @param indexname 索引名稱 
  4.     * @param type 索引型別 
  5.     * @param queryBuilder 查詢條件 
  6.     * @return 
  7.     */
  8.    public SearchResponse searcher(String indexName, String typeName,  
  9.            QueryBuilder queryBuilder) {  
  10.        SearchResponse searchResponse = client.prepareSearch(indexName)  
  11.                .setTypes(typeName).setQuery(queryBuilder).execute()  
  12.                .actionGet();//執行查詢
  13.        return searchResponse;  
  14.    }  
 /**
     * 執行搜尋
     * @param indexname 索引名稱
     * @param type 索引型別
     * @param queryBuilder 查詢條件
     * @return
     */
    public SearchResponse searcher(String indexName, String typeName,
            QueryBuilder queryBuilder) {
        SearchResponse searchResponse = client.prepareSearch(indexName)
                .setTypes(typeName).setQuery(queryBuilder).execute()
                .actionGet();//執行查詢
        return searchResponse;
    }

（4）更新索引 [java] view plain copy print?
  1. /** 
  2.     * 更新索引 
  3.     * @param indexName 索引名稱 
  4.     * @param typeName 索引型別 
  5.     * @param id id名稱 
  6.     * @param jsonData json資料 
  7.     */
  8.    publicvoid updateIndex(String indexName, String typeName, String id,  
  9.            String jsonData) {  
  10.        UpdateRequest updateRequest = new UpdateRequest();  
  11.        updateRequest.index(indexName);//設定索引名稱
  12.        updateRequest.id(id);//設定id
  13.        updateRequest.type(typeName);//設定索引型別
  14.        updateRequest.doc(jsonData);//更新資料
  15.        client.update(updateRequest).actionGet();//執行更新
  16.    }  
 /**
     * 更新索引
     * @param indexName 索引名稱
     * @param typeName 索引型別
     * @param id id名稱
     * @param jsonData json資料
     */
    public void updateIndex(String indexName, String typeName, String id,
            String jsonData) {
        UpdateRequest updateRequest = new UpdateRequest();
        updateRequest.index(indexName);//設定索引名稱
        updateRequest.id(id);//設定id
        updateRequest.type(typeName);//設定索引型別
        updateRequest.doc(jsonData);//更新資料
        client.update(updateRequest).actionGet();//執行更新
    }

（5）刪除索引 [java] view plain copy print?
  1. /** 
  2.     * 刪除索引 
  3.     * @param indexName 
  4.     * @param typeName 
  5.     * @param id 
  6.     */
  7.    publicvoid deleteIndex(String indexName, String typeName, String id) {  
  8.        client.prepareDelete(indexName, typeName, id).get();  
  9.    }  
 /**
     * 刪除索引
     * @param indexName
     * @param typeName
     * @param id
     */
    public void deleteIndex(String indexName, String typeName, String id) {
        client.prepareDelete(indexName, typeName, id).get();
    }
4.建立測試類 [java] view plain copy print?
  1. package com.elasticsearch.test;  
  2. import org.elasticsearch.action.search.SearchResponse;  
  3. import org.elasticsearch.index.query.QueryBuilder;  
  4. import org.elasticsearch.index.query.QueryBuilders;  
  5. import org.elasticsearch.search.SearchHit;  
  6. import org.elasticsearch.search.SearchHits;  
  7. publicclass Test {  
  8.     publicstaticvoid main(String[] args) {  
  9.         //建立物件，設定叢集名稱和IP地址
  10.         ElasticsearchUtils es = new ElasticsearchUtils(“im_shan”,  
  11.                 ”localhost”);  
  12.         String indexName = ”school”;//索引名稱
  13.         String typeName = ”student”;//型別名稱
  14.         String id = ”1”;  
  15.         String jsonData = ”{“ + “\”name\”:\”kimchy\”,”
  16.                 + ”\”birth\”:\”1995-01-30\”,” + “\”email\”:\”[email protected]\”“
  17.                 + ”}”;//json資料
  18.         //1.建立索引(ID可自定義也可以自動建立，此處使用自定義ID)
  19.         es.createIndex(indexName, typeName, id, jsonData);  
  20.         //2.執行查詢
  21.         //(1)建立查詢條件
  22.         QueryBuilder queryBuilder = QueryBuilders.termQuery(”name”, “kimchy”);//搜尋name為kimchy的資料
  23.         //(2)執行查詢
  24.         SearchResponse searchResponse = es.searcher(indexName, typeName,  
  25.             queryBuilder);  
  26.         //(3)解析結果
  27.         SearchHits hits = searchResponse.getHits();  
  28.         SearchHit[] searchHits = hits.getHits();  
  29.         for (SearchHit searchHit : searchHits) {  
  30.             String name = (String) searchHit.getSource().get(”name”);  
  31.             String birth = (String) searchHit.getSource().get(”birth”);  
  32.             String email = (String) searchHit.getSource().get(”email”);  
  33.             System.out.println(name);  
  34.             System.out.println(birth);  
  35.             System.out.println(email);  
  36.         }  
  37.         //3.更新資料
  38.         jsonData = ”{“ + “\”name\”:\”jack\”,” + “\”birth\”:\”1996-01-30\”,”
  39.                 + ”\”email\”:\”[email protected]\”“ + “}”;//json資料
  40.         es.updateIndex(indexName, typeName, id, jsonData);  
  41.         //4.刪除資料
  42.         es.deleteIndex(indexName, typeName, id);  
  43.     }  
  44. }  
package com.elasticsearch.test;

import org.elasticsearch.action.search.SearchResponse;
import org.elasticsearch.index.query.QueryBuilder;
import org.elasticsearch.index.query.QueryBuilders;
import org.elasticsearch.search.SearchHit;
import org.elasticsearch.search.SearchHits;

public class Test {
    public static void main(String[] args) {
        //建立物件，設定叢集名稱和IP地址
        ElasticsearchUtils es = new ElasticsearchUtils("im_shan",
                "localhost");
        String indexName = "school";//索引名稱
        String typeName = "student";//型別名稱
        String id = "1";
        String jsonData = "{" + "\"name\":\"kimchy\","
                + "\"birth\":\"1995-01-30\"," + "\"email\":\"[email protected]\""
                + "}";//json資料
        //1.建立索引(ID可自定義也可以自動建立，此處使用自定義ID)
        es.createIndex(indexName, typeName, id, jsonData);

        //2.執行查詢
        //(1)建立查詢條件
        QueryBuilder queryBuilder = QueryBuilders.termQuery("name", "kimchy");//搜尋name為kimchy的資料
        //(2)執行查詢
        SearchResponse searchResponse = es.searcher(indexName, typeName,
            queryBuilder);
        //(3)解析結果
        SearchHits hits = searchResponse.getHits();
        SearchHit[] searchHits = hits.getHits();
        for (SearchHit searchHit : searchHits) {
            String name = (String) searchHit.getSource().get("name");
            String birth = (String) searchHit.getSource().get("birth");
            String email = (String) searchHit.getSource().get("email");
            System.out.println(name);
            System.out.println(birth);
            System.out.println(email);
        }

        //3.更新資料
        jsonData = "{" + "\"name\":\"jack\"," + "\"birth\":\"1996-01-30\","
                + "\"email\":\"[email protected]\"" + "}";//json資料
        es.updateIndex(indexName, typeName, id, jsonData);

        //4.刪除資料
        es.deleteIndex(indexName, typeName, id);
    }
}

1.建立索引之後，可以在瀏覽器輸入http://localhost:9200/_plugin/head/ 進行檢視，可以發現索引已建立，index名稱為school,type為student，id為1


2.查詢索引，控制檯會輸出name為kimchy的birth、email的值

3.更新索引，此時再次進入http://localhost:9200/_plugin/head/ 進行檢視，發現內容已經改變



4.刪除索引，程式碼執行後輸入http://localhost:9200/_plugin/head/ 檢視，內容已清空

相關推薦

Elasticsearch簡單操作（Java程式碼）

1.首先安裝Elasticsearch，配置相關檔案，並啟動服務 2.建立專案，匯入相關Jar包 3.建立ElasticsearchUtils類，裡面包括初始化操作和建立索引、更新索引、刪除索引、查詢索引 （1）初始化操作，需要傳入叢集名稱和ip地址，叢集名稱本例子使用elasticsearch配置檔

常見檔案操作（java程式碼）

位元組流和字元流概念 位元組流：位元組流讀取的時候，讀到一個位元組就返回一個位元組；主要用於讀取圖片，MP3，AVI視訊檔案。 字元流：字元流使用了位元組流讀到一個或多個位元組，如讀取

求較大整數n的階乘，因為n較大時n的階乘超出了正常類型的表示範圍，采用數組進行操作（java實現）

階乘 大數字package net.yk.mlgorithm; /** * 求較大數的階乘 * @author Administrator * * @param <T> */ public class ArraysMul<T> { public static void

時間操作（Java版）—獲取給定日期N天后的日期

        獲取給定日期N天后的日期 import java.util.Calendar; public class Test { public static void main(String[] args) { Syst

2017.12 CCF第一題：最小差值 （Java程式碼）

問題描述 　　給定n個數，請找出其中相差（差的絕對值）最小的兩個數，輸出它們的差值的絕對值。 輸入格式 　　輸入第一行包含一個整數n。 　　第二行包含n個正整數，相鄰整數之間使用一個空格分隔。 輸出格式 　　輸出一個整數，表示答案。 樣例輸入 5 1 5 4 8 20

CCF2018.3 第一題：跳一跳 （Java程式碼）

問題描述 　　近來，跳一跳這款小遊戲風靡全國，受到不少玩家的喜愛。 　　簡化後的跳一跳規則如下：玩家每次從當前方塊跳到下一個方塊，如果沒有跳到下一個方塊上則遊戲結束。 　　如果跳到了方塊上，但沒有跳到方塊的中心則獲得1分；跳到方塊中心時，若上一次的得分為1分或這是本局遊戲的第一次跳躍則此次得分為

CCF2018.9 第一題賣菜 （Java程式碼）

問題描述 　　在一條街上有n個賣菜的商店，按1至n的順序排成一排，這些商店都賣一種蔬菜。 　　第一天，每個商店都自己定了一個價格。店主們希望自己的菜價和其他商店的一致，第二天，每一家商店都會根據他自己和相鄰商店的價格調整自己的價格。具體的，每家商店都會將第二天的菜價設定為自己和相鄰商店第一天菜價

LeetCode-118.楊輝三角（java程式碼）

此處僅貼參考程式碼（程式碼可繼續調優，但平臺Accepted了，留點思考空間~） public List<List<Integer>> generate(int numRows) { List<List<Inte

記錄一個演算法題（java程式碼）：統計正整數n的二進位制寫法中有多少個1

package ludims.main; import java.util.Scanner; public class myMain {     public static void main(String[] args) {         System.out.pri

File 程式（Java程式碼）

 public static void main(String[] args) {   /*    * 宣告流物件    */   FileReader fr = null;   BufferedReader br = null;   StringBuffer sb = new StringBuffer();

Echarts餅圖柱形圖調整文字大小（java程式碼）

1.餅圖：    Pie pie = new Pie();         pie.center("50%", "50%").radius(100);         ItemStyle style = new ItemStyle();         Normal nor

散列表查詢（雜湊表）的基本操作 （完整程式碼）

表和二叉樹的排序，是利用元素之間的關係，逐個查詢，或按一定的規律查詢。 而散列表（雜湊表），元素之間沒有關係，它是利用了元素與儲存地址之間的關係。 說白了，就是利用雜湊函式建立 元素->地址

二叉排序樹的基本操作（完整程式碼）

以下是二叉排序樹的基本操作，函式基本與《大話資料結構》裡的程式碼類似，包括查詢、插入、刪除操作。完整程式碼，可直接執行。 //二叉排序樹 //其中有插入、刪除、查詢操作 #include<s

順序線性表的插入,刪除操作（完整程式碼）

1..插入 ：在順序線性表l的第i個位置前插入元素e  。     第一步判斷插入位置是否合法，如果不合法則異常退出。第二步判斷線性表儲存空間是否不足，如果不足則增加儲存容量。第三步將插入位置及之後元素後移。第四步將待插入元素插入。  2..刪除：從順序線性表l中刪除第

如何通過程式（java程式碼）提高你的部落格訪問量

最近對寫部落格比較感興趣，我想對於每一個寫部落格的人來說，都渴望自己寫的部落格能夠被別人看到，或者在搜尋引擎中搜索時容易被搜尋到，如何讓你的部落格容易被人搜尋到，從而提高訪問量呢？這裡我最推薦大家的方法是儘量原創，寫一些新鮮有趣，別人沒有寫過的內容，然後標題，關

設計模式簡單介紹（Java語言）-- 工廠方法模式

設計模式簡單介紹（Java語言) – 工廠方法模式 1.工廠方法模式的定義： 工廠方法模式（FACTORY METHOD）是一種常用的物件建立型設計模式,此模式的核心精神是封裝類中不變的部分，提取其中個性化善變的部分為獨立類，通過依賴注入以達到解耦

格拉布斯準則（java程式碼）

package rule; import java.util.HashMap; import java.util.List; import java.util.Map; //格拉布斯準則 public class GLBS { static Map<Double,

設計模式簡單介紹（java語言）-- 模板方法模式

設計模式簡單介紹（java語言）– 模板方法模式 模板方法模式的定義 模板方法模式：定義一個操作中的演算法的框架，而將一些步驟延遲到子類中。使得子類可以不改變一個演算法的結構即可重定義該演算法的某些特定步驟。 類圖： 類圖中，Abstrac

矩陣式比較兩文字字串相似度（包含漢字）方法兩則（java程式碼）

package com.gsww.ctyxy.util; import java.text.NumberFormat;   import java.util.Locale;    /**  * 比較兩個字串的相似度  */   public class AutomaticRating {   /*    pu

藍橋杯-----------------基礎訓練 數列排序（Java程式碼）

一、數列排序   問題描述：給定一個長度為n的數列，將這個數列按從小到大的順序排列。1<=n<=200。 二、解題思想： 對於排序，無論是資料結構還是自己手寫都有很多種方法進行解決。但是，