package?cn.yan.study.es;

/**
?*?Created?沒有用
?*?User??wankunYan
?*?Date??2018/6/26
?*?Time??14:21
?*/

import?java.io.IOException;
import?java.io.InputStream;
import?java.io.InputStreamReader;
import?java.util.ArrayList;
import?java.util.List;
import?java.util.Properties;

import?cn.yan.study.es.client.EsClient;
import?cn.yan.study.es.index.Index;
import?org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsRequest;
import?org.elasticsearch.action.admin.indices.exists.indices.IndicesExistsResponse;
import?org.elasticsearch.client.Client;
import?org.elasticsearch.client.IndicesAdminClient;
import?org.elasticsearch.common.settings.Settings;

public?class?Elasticsearch?{
????private?Client?client;
????private?IndicesAdminClient?adminClient;
????/**
?????*?集群配置初始化方法
?????*?@throws?Exception
?????*/
????private?void?init（）?throws?Exception{
????????client?=?EsClient.getTransportClient（）;
????}
????/**
?????*?構造方法
?????*/
????public?Elasticsearch（）?{
????????try?{
????????????init（）;
????????}?catch?（Exception?e）?{
????????????System.out.println（“init（）?exception!“）;
????????????e.printStackTrace（）;
????????}
????????adminClient?=?client.admin（）.indices（）;
????}
????/**
?????*?判斷集群中{index}是否存在
?????*?@param?index
?????*?@return?存在（true）、不存在（false）
?????*/
????public?boolean?indexExists（String?index）{
????????IndicesExistsRequest?request?=?new?IndicesExistsRequest（index）;
????????IndicesExistsResponse?response?=?adminClient.exists（request）.actionGet（）;
????????if?（response.isExists（））?{
????????????return?true;
????????}
????????return?false;
????}
????/**
?????*?讀取es配置信息
?????*?@return
?????*/
????private?Properties?readElasticsearchConfig（）?{
????????Properties?properties?=?new?Properties（）;
????????try?{
????????????InputStream?is?=?this.getClass（）.getClassLoader（）.getResourceAsStream（“elasticsearch.properties“）;
????????????properties.load（new?InputStreamReader（is“UTF-8“））;
????????}?catch?（IOException?e）?{
????????????System.out.println（“readEsConfig?exception!“）;
????????????e.printStackTrace（）;
????????}
????????return?properties;
????}
????/**
?????*?獲取要創建的index列表
?????*?@return?List
?????*/
????public?List?getIndexList（）{
????????List?indexList?=?new?ArrayList<>（）;
????????Index?index1?=?new?Index（“index_one“?“type_one“?4?5?“{\“initType\“:{\“properties\“:{\“date\“:{\“format\“:\“yyy-MM-dd?HH:mm:ss||yyyy-MM-dd||epoch_millis\“\“type\“:\“date\“}\“name\“:{\“type\“:\“String\“}}}}“）;
????????indexList.add（index1）;
????????return?indexList;
????}
????/**
?????*?創建Index
?????*/
????public?void?CreateIndex（）{
????????int?i?=?0;
????????List?list?=?getIndexList（）;
????????IndicesAdminClient?adminClient?=?client.admin（）.indices（）;
????????for（Index?index?:?list）{
????????????if?（indexExists（index.getIndex（）））?{
????????????????continue;
????????????}
????????????adminClient.prepareCreate（index.getIndex（））
????????????????????.setSettings（Settings.builder（）.put（“index.number_of_shards“?index.getNumber_of_shar

?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\
?????文件?????????106??2019-02-19?02:37??yan-study-dev\.gitignore
?????文件??????????49??2019-02-19?02:37??yan-study-dev\README.md
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\
?????文件????????2848??2019-02-19?02:37??yan-study-dev\elasticsearch-study\pom.xml
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\
?????文件????????3506??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\Elasticsearch.java
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\client\
?????文件????????1259??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\client\EsClient.java
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\index\
?????文件????????1639??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\index\Index.java
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\test\
?????文件????????3667??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\test\EsParentChildTest.java
?????文件????????1501??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\test\School.java
?????文件????????1500??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\test\Student.java
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\utils\
?????文件????????4051??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\utils\EsAdminClientUtils.java
?????文件????????9055??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\java\cn\yan\study\es\utils\EsClientUtils.java
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\resources\
?????文件??????????65??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\resources\elasticsearch.properties
?????文件?????????675??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\resources\index.json
?????文件?????????399??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\resources\log4j2.xml
?????文件?????????679??2019-02-19?02:37??yan-study-dev\elasticsearch-study\src\main\resources\me.txt
?????文件?????????757??2019-02-19?02:37??yan-study-dev\pom.xml
?????目錄???????????0??2019-02-19?02:37??yan-study-dev\queue-study\
............此處省略170個文件信息