ElasticSearch創建、修改、獲取、刪除、索引Indice mapping和Index Template案例

為什么80%的碼農都做不了架構師?>>> ??hot3.png

The best elasticsearch highlevel java rest api-----bboss

ElasticSearch客戶端框架bboss的ClientInterface 接口提供了創建/修改、獲取、刪除索引Indice和IndexTemplate的方法,本文舉例說明其使用方法。

1 準備工作

參考文檔在項目中導入Elasticsearch客戶端:集成Elasticsearch Restful API案例分享

本文除了介紹索引Indice和Index Template的創建修改方法,還可以看到如何在dsl中添加注釋的用法:

單行注釋

## 注釋內容

多行注釋

#*。。。。注釋內容。。。*#

更多bboss dsl配置和定義的內容,參考文檔:高性能elasticsearch ORM開發庫使用介紹?章節【5.3 配置es查詢dsl腳本語法

2 定義創建Indice的dsl腳本

在配置文件-esmapper/demo.xml中定義一個名稱為createDemoIndice的dsl腳本:

    <!--創建demo需要的索引表結構--><property name="createDemoIndice"><![CDATA[{"settings": {"number_of_shards": 6,"index.refresh_interval": "5s"},"mappings": {"demo": {"properties": {"demoId":{"type":"long"},"contentbody": {"type": "text" ##定義text類型的全文檢索字段},"agentStarttime": {"type": "date"## ,"format":"yyyy-MM-dd HH:mm:ss.SSS||yyyy-MM-dd'T'HH:mm:ss.SSS||yyyy-MM-dd HH:mm:ss||epoch_millis"},"applicationName": {"type": "text",##定義text類型的全文檢索字段"fields": { ##定義精確查找的內部keyword字段"keyword": {"type": "keyword"}}},"name": {"type": "keyword"}}}}}]]></property>

3 創建indice/判斷indice是否存在/刪除indice

根據上面定義的dsl腳本文件初始化ClientInterface對象,并創建索引表demo:

	public void testCreateIndice(){//創建加載配置文件的客戶端工具,單實例多線程安全ClientInterface clientUtil = ElasticSearchHelper.getConfigRestClientUtil("esmapper/demo.xml");try {//判讀索引表demo是否存在,存在返回true,不存在返回falseboolean exist = clientUtil.existIndice("demo");//如果索引表demo已經存在先刪除mappingif(exist)clientUtil.dropIndice("demo");//創建索引表democlientUtil.createIndiceMapping("demo",//索引表名稱"createDemoIndice");//索引表mapping dsl腳本名稱,在esmapper/demo.xml中定義createDemoIndice//獲取修改后的索引mapping結構String mapping = clientUtil.getIndice("demo");System.out.println(mapping);} catch (ElasticSearchException e) {// TODO Auto-generated catch blocke.printStackTrace();}}

4 定義索引Template dsl腳本

通過定義索引模板,定義表結構相同,但是索引表名稱不同的索引表的建表模板,通過index_patterns中對應的模式名稱來匹配索引模板適用的索引表:

   <property name="demoTemplate"><![CDATA[{"index_patterns": "demo-*", ## 5.x版本中請使用語法:"template": "demo-*""settings": {"number_of_shards": 30, ##定義分片數"number_of_replicas" : 2, ##定義副本數"index.refresh_interval": "5s" ## 定義索引寫入刷新時間間隔},"mappings": {"demo": {"properties": {"contentbody": {"type": "text","fields": {"keyword": {"type": "keyword","ignore_above": 256}}},"agentStarttime": {"type": "date","format":"yyyy-MM-dd HH:mm:ss.SSS||yyyy-MM-dd'T'HH:mm:ss.SSS||yyyy-MM-dd HH:mm:ss||epoch_millis"},"applicationName": {"type": "text","fields": {"keyword": {"type": "keyword","ignore_above": 256}}}}}}}]]></property>

5 創建/獲取/刪除索引表模板

	public void testCreateTempate() throws ParseException{ClientInterface clientUtil = ElasticSearchHelper.getConfigRestClientUtil("esmapper/demo.xml");//創建模板String response = clientUtil.createTempate("demotemplate_1",//模板名稱"demoTemplate");//模板對應的腳本名稱,在esmapper/demo.xml中配置System.out.println("createTempate-------------------------");System.out.println(response);//創建結果//獲取模板/*** 指定模板* /_template/demoTemplate_1* /_template/demoTemplate** 所有模板 /_template**/String template = clientUtil.executeHttp("/_template/demotemplate_1",ClientUtil.HTTP_GET);System.out.println("HTTP_GET-------------------------");System.out.println(template);ElasticSearchHelper.getRestClientUtil().deleteTempate("demotemplate_1"); }

6 修改和獲取索引表結構

修改先前創建的demo表,為其中的type demo增加email關鍵字段

定義dsl結構-esmapper/demo.xml

    <!--修改demo 索引表的結構,增加email字段https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-put-mapping.html--><property name="updateDemoIndice"><![CDATA[{"properties": {"email": {"type": "keyword"}}}]]></property>

修改和獲取mapping結構的方法:

	public void updateDemoIndice(){ClientInterface clientUtil = ElasticSearchHelper.getConfigRestClientUtil(mappath);//修改索引表demo中type為demo的mapping結構,增加email字段,對應的dsl片段updateDemoIndice定義在esmapper/demo.xml文件中String response = clientUtil.executeHttp("demo/_mapping/demo","updateDemoIndice",ClientUtil.HTTP_PUT);System.out.println(response);//獲取修改后的索引mapping結構String mapping = clientUtil.getIndice("demo");System.out.println(mapping);}

7 案例源碼工程下載

https://github.com/bbossgroups/eshelloword-booter

https://gitee.com/bboss/eshelloword-booter

8 參考文檔

https://my.oschina.net/bboss/blog/1556866

9 開發交流

elasticsearch技術交流:166471282

elasticsearch:

轉載于:https://my.oschina.net/bboss/blog/1807473

本文來自互聯網用戶投稿,該文觀點僅代表作者本人,不代表本站立場。本站僅提供信息存儲空間服務,不擁有所有權,不承擔相關法律責任。
如若轉載,請注明出處:http://www.pswp.cn/news/254672.shtml
繁體地址,請注明出處:http://hk.pswp.cn/news/254672.shtml
英文地址,請注明出處:http://en.pswp.cn/news/254672.shtml

如若內容造成侵權/違法違規/事實不符,請聯系多彩編程網進行投訴反饋email:809451989@qq.com,一經查實,立即刪除!

相關文章

ASCII碼與string的相互轉換

ASCII碼與string的相互轉換 思路&#xff1a; 1&#xff09;ASCII碼轉string&#xff1a;把字符&#xff08;串&#xff09;直接轉換為int類型&#xff0c;即可得到ASCII碼&#xff1b; 2&#xff09;string轉ASCII碼&#xff1a;將數字轉換為字符串轉出&#xff1b; {//將字…

X264代碼中一些參數的意義

Main&#xff08;int argc&#xff0c;char *argv[]&#xff09;; 為了方便起見&#xff0c;不妨改寫為&#xff1a; Main(void){ ...... intargc5; char*argv[]{ "main","-o","test.264","foreman.yuv","352x288" }; …

spring mvc注解@RequestMapping

1、url路徑映射 基本功能 2、窄化請求映射 根路徑子路徑 注意setViewName的路徑。 3、限制http請求方法 get和 post 如果是get 轉載于:https://www.cnblogs.com/jway1101/p/5773923.html

Start application automatically during controller boot-up

&#xfeff;&#xfeff; Tip English ?German Start application automatically during controller boot-up Description It is possible to start any program automatically during the boot-up procedure of the KR C4 controller. Precondition ?User group “Exper…

C#using static

平常用法&#xff1a; using 命名空間&#xff1b; using System; Console.WriteLine("Hello&#xff0c;World&#xff01;");using static用法&#xff1a; C#6中支持這種寫法&#xff0c;這樣定義后可以可以訪問類的靜態成員 WriteLine是Console類的靜態函數&am…

redis數據遷移

一&#xff1a;AOF方式 需求&#xff1a; 一個沒有數據的redis。 清空redis數據方法 bash> echo "keys *" | redis-cli --raw -p 6378 |sed -r s/(.*)/redis-cli --raw -p 6378 del \1 /g |bash 1.備份 bash> redis-cli --raw -p 6378 redis> config get di…

阿里云OSS 上傳文件SDK

Aliyun OSS SDK for C# 上傳文件 另外&#xff1a;查找的其他實現C#上傳文件功能例子&#xff1a; 1、WPF用流的方式上傳/顯示/下載圖片文件(保存在數據庫) &#xff08;文末有案例下載鏈接&#xff09; 2、WPF中利用WebClient向服務器上傳文件 3、C#文件上傳的簡單實現 4、C#實…

關于level_idc和Profile_IDC的解釋

2010-01-21 15:51:40| 分類&#xff1a; windows mobile開 |字號 訂閱 Description: Set bitstream Profile IDC. Default is 88. Note: Some profiles cannot support certain features. See MPEG-4 AVC for supported features for each profile. Reference software may…

老婆的駕照要下來了,形容下我此刻的心情

&#xfeff;&#xfeff; 老婆的駕照要下來了&#xff0c;形容下我此刻的心情&#xff1a; 路上遇到的女人&#xff0c;大部分是不用眼睛和腦子開車的&#xff0c;完全是憑自己的感覺開車。凡是看到前車奇慢、路口猶豫不決、不打燈緩慢變線、不該…

ADO.NET改進防注入

static void Main1(string[] args) { //用戶輸入一個需要查詢的條件 car表 Console.WriteLine("請輸入"); string code Console.ReadLine(); SqlConnection conn new SqlConnection("server.;databasemydb;usersa;pwd100867"); SqlCommand cmd conn.Crea…

poj 2139

Floyd-Warshall模板題&#xff0c;我才剛學最短路。。。。 #include <iostream> #include <cstdio> #include <algorithm> #include <cstring> using namespace std; const int maxn30050; int d[maxn][maxn]; int v,m,n; int a[maxn]; const int inf0…

C#使用了未賦值的局部變量

錯誤原因&#xff1a; 我們先看下例子&#xff1a; int A; Console.WriteLine("數字&#xff1a;{0:d}", A);//在控制臺輸出文本這時提示錯誤&#xff1a;錯誤 1 使用了未賦值的局部變量“A” 原因是C#在使用變量前必須要進行初始化。 解決 解決方案有兩個 1、在…

EtherCAT伺服驅動器-如何選擇硬件開發方案

&#xfeff;&#xfeff;EtherCAT伺服驅動器-如何選擇硬件開發方案

Codevs 1689 建造高塔

1689 建造高塔時間限制: 1 s空間限制: 128000 KB題目等級 : **鉆石 Diamond** 題目描述 Description n有n種石塊&#xff0c;石塊能無限供應。每種石塊都是長方體&#xff0c;其中第i種石塊的長、寬、高分別為li、wi、hi。石塊可以旋轉&#xff0c;使得其中兩維成為長度和寬度&…

windows環境下OpenLDAP安裝與客戶端連接配置

2019獨角獸企業重金招聘Python工程師標準>>> 1.下載安裝OpenLDAP版本 C:\Users\Administrator>slapd -V OpenLDAP 2.4.42 Standalone LDAP Server (slapd) 2.安裝過程中&#xff0c;全部用默認的操作執行即可。 3.修改OpenLDAP文件如下&#xff1a; # MDB Backen…

主流開源編解碼器Xvid,x264,ffmpeg 性能對比

如有轉載請注明出處&#xff1a;孔祥文博客http://kswapd.cublog.cn Xvid是基于MPEG4協議的編解碼器&#xff0c;x264是基于H.264協議的編碼器&#xff0c;ffmpeg集合了各種音頻&#xff0c;視頻編解碼協議&#xff0c;通過設置參數可以完成基于MPEG4,H.264等協議的編解碼&…

halcon標定后改變世界坐標系參考點方法

halcon相機標定完成后&#xff0c;世界坐標系原點在標定板的中間&#xff0c;如果要自定義坐標系原點該如何操作 如圖&#xff1a; 方法1 使用仿射變換 *pose_to_hom_mat3d (FinalPose, HomMat3D) *hom_mat3d_translate_local (HomMat3D, dx, dy, 0, HomMat3DTranslate) *hom_…

Oracle 【IT實驗室】數據庫備份與恢復之:如何對Oracle數據庫文件進行恢復與備份...

任何數據庫在長期使用過程中&#xff0c;都會存在一定的安全隱患。對于數據庫管理員來說不能僅寄希望于計算機操作系統的安全運行&#xff0c;而是要建立一整套的數據庫備份與恢復機制。當數據庫發生故障后&#xff0c;希望能重新建立一個完整的數據庫&#xff0c;該處理稱為數…

vue刷新當前路由:router-view 復用組件時不刷新的3種解決方案總結

vue-router是Vue.js官方的路由插件&#xff0c;它和vue.js是深度集成的&#xff0c;適合用于構建單頁面應用。vue的單頁面應用是基于路由和組件的&#xff0c;路由用于設定訪問路徑&#xff0c;并將路徑和組件映射起來。傳統的頁面應用&#xff0c;是用一些超鏈接來實現頁面切換…

KUKA---US2電源的安全屬性-------老款硬線連接實現的DRIVE安全STO SBC 、新款基于Safety over EtherCAT 網絡幀實現的DRIVE安全STO SBC

安全雙回路的監控&#xff1a;&#xff08;工業上的安全&#xff0c;是指安全等級&#xff0c;沒有絕對的安全&#xff09; 1. 機械式&#xff1a;監控關斷繼電器的輔助反饋觸點&#xff0c;這個關斷繼電器包含機械聯鎖觸點&#xff0c;這樣反饋觸點和主觸點可以同步開關動…