diff --git a/pom.xml b/pom.xml
index a78a143..e4d103a 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1,14 +1,15 @@
-<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 	xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
 	<modelVersion>4.0.0</modelVersion>
 
 	<groupId>1.0.0</groupId>
-	<artifactId>java_study</artifactId> 
+	<artifactId>java_study</artifactId>
 	<version>0.0.1-SNAPSHOT</version>
 	<packaging>jar</packaging>
- 
+
 	<name>java_study</name>
-	<url>http://maven.apache.org</url> 
+	<url>http://maven.apache.org</url>
 
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
@@ -28,15 +29,15 @@
 			<artifactId>junit</artifactId>
 			<version>4.12</version>
 		</dependency>
- 
-		
+
+
 		<dependency>
-            <groupId>jdk.tools</groupId>
-            <artifactId>jdk.tools</artifactId>
-            <version>1.8</version>
-            <scope>system</scope>
-            <systemPath>${JAVA_HOME}/lib/tools.jar</systemPath>
-   	 </dependency>
+			<groupId>jdk.tools</groupId>
+			<artifactId>jdk.tools</artifactId>
+			<version>1.8</version>
+			<scope>system</scope>
+			<systemPath>${JAVA_HOME}/lib/tools.jar</systemPath>
+		</dependency>
 
 
 		<!--日志 -->
@@ -102,8 +103,8 @@
 			<artifactId>commons-lang3</artifactId>
 			<version>3.7</version>
 		</dependency>
-		
-		<!-- 压缩使用的  -->
+
+		<!-- 压缩使用的 -->
 		<dependency>
 			<groupId>org.apache.commons</groupId>
 			<artifactId>commons-compress</artifactId>
@@ -319,8 +320,8 @@
 			<artifactId>zkclient</artifactId>
 			<version>0.10</version>
 		</dependency>
-		
-		
+
+
 		<!--hadoop 相关架包 -->
 		<dependency>
 			<groupId>org.apache.hadoop</groupId>
@@ -369,15 +370,15 @@
 			<artifactId>hbase-common</artifactId>
 			<version>1.4.8</version>
 		</dependency>
-		
-		
+
+
 		<!--Hive相关jar -->
 		<dependency>
 			<groupId>org.apache.hive</groupId>
 			<artifactId>hive-jdbc</artifactId>
 			<version>3.1.1</version>
 		</dependency>
-		
+
 		<!--storm相关jar -->
 		<dependency>
 			<groupId>org.apache.storm</groupId>
@@ -391,7 +392,7 @@
 			<version>1.2.2</version>
 		</dependency>
 
-		
+
 		<!--Spark相关jar -->
 		<dependency>
 			<groupId>org.apache.spark</groupId>
@@ -420,7 +421,26 @@
 			<version>2.4.0</version>
 			<scope>provided</scope>
 		</dependency>
+
+
+
+		<!-- ES 相关jar包 -->
 		
+		<!-- ES高级API -->
+		<dependency>
+			<groupId>org.elasticsearch.client</groupId>
+			<artifactId>elasticsearch-rest-high-level-client</artifactId>
+			<version>6.6.1</version>
+		</dependency>
+
+		<!--Jest工具包 -->
+		<dependency>
+			<groupId>io.searchbox</groupId>
+			<artifactId>jest</artifactId>
+			<version>6.3.1</version>
+		</dependency>
+
+
 		<!-- 大数据相关 jar end -->
 
 
diff --git a/src/main/java/com/pancm/sql/easticsearch/JestTest.java b/src/main/java/com/pancm/sql/easticsearch/JestTest.java
new file mode 100644
index 0000000..13c4127
--- /dev/null
+++ b/src/main/java/com/pancm/sql/easticsearch/JestTest.java
@@ -0,0 +1,370 @@
+package com.pancm.sql.easticsearch;
+
+import java.io.Serializable;
+import java.util.ArrayList;
+import java.util.List;
+
+import org.elasticsearch.index.query.QueryBuilders;
+import org.elasticsearch.search.builder.SearchSourceBuilder;
+
+import io.searchbox.client.JestClient;
+import io.searchbox.client.JestClientFactory;
+import io.searchbox.client.JestResult;
+import io.searchbox.client.config.HttpClientConfig;
+import io.searchbox.core.Bulk;
+import io.searchbox.core.BulkResult;
+import io.searchbox.core.Delete;
+import io.searchbox.core.DocumentResult;
+import io.searchbox.core.Index;
+import io.searchbox.core.Search;
+import io.searchbox.indices.CreateIndex;
+import io.searchbox.indices.DeleteIndex;
+import io.searchbox.indices.mapping.GetMapping;
+import io.searchbox.indices.mapping.PutMapping;
+
+/**
+ * 
+* @Title: JestTest
+* @Description: es 的  Jest 测试类
+* @Version:1.0.0  
+* @author pancm
+* @date 2019年2月28日
+ */
+public class JestTest {  
+	    private static JestClient jestClient;  
+	    private static String indexName = "userindex";  
+	    private static String typeName = "user";  
+	    private static String elasticIps="http://127.0.0.1:9200";
+		
+	    
+	    public static void main(String[] args) throws Exception {
+	        jestClient = getJestClient();  
+	        insertBatch();
+	        serach1();
+	        serach2();
+	        serach3();
+	        jestClient.close();  
+	        
+		}
+	    
+	    private static  JestClient getJestClient() {  
+	    	JestClientFactory factory = new JestClientFactory();  
+			factory.setHttpClientConfig(new HttpClientConfig.Builder(elasticIps).connTimeout(60000).readTimeout(60000).multiThreaded(true).build());  
+	        return factory.getObject();  
+	    }  
+	    
+	    public static void insertBatch() {
+			List<Object> objs = new ArrayList<Object>();
+			objs.add(new User(1L, "张三", 20, "张三是个Java开发工程师","2018-4-25 11:07:42"));
+			objs.add(new User(2L, "李四", 24, "李四是个测试工程师","1980-2-15 19:01:32"));
+			objs.add(new User(3L, "王五", 25, "王五是个运维工程师","2016-8-21 06:11:32"));
+			boolean result = false;
+			try {
+				result = insertBatch(jestClient,indexName, typeName,objs);
+			} catch (Exception e) {
+				e.printStackTrace();
+			}
+			System.out.println("批量新增:"+result);
+		}
+	    
+	    
+	    /**
+	     * 全文搜索
+	     */
+	    public static void serach1() {
+			String query ="工程师";
+			try {
+				SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); 
+		    	 searchSourceBuilder.query(QueryBuilders.queryStringQuery(query)); 
+		    	 //分页设置
+		    	 searchSourceBuilder.from(0).size(2); 
+		        System.out.println("全文搜索查询语句:"+searchSourceBuilder.toString());
+				System.out.println("全文搜索返回结果:"+search(jestClient,indexName, typeName, searchSourceBuilder.toString()));
+			} catch (Exception e) {
+				e.printStackTrace();
+			}
+		}
+	    
+	    /**
+	     * 精确搜索
+	     */
+	    public static void serach2() {
+			try {
+				SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); 
+		    	searchSourceBuilder.query(QueryBuilders.termQuery("age", 24)); 
+		    	System.out.println("精确搜索查询语句:"+searchSourceBuilder.toString());
+				System.out.println("精确搜索返回结果:"+search(jestClient,indexName, typeName, searchSourceBuilder.toString()));
+			} catch (Exception e) {
+				e.printStackTrace();
+			}
+		}
+	    
+	    
+	    /**
+	     * 区间搜索
+	     */
+	    public static void serach3() {
+			String createtm="createtm";
+			String from="2016-8-21 06:11:32";
+			String to="2018-8-21 06:11:32";
+			
+			try {
+				SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder(); 
+		    	searchSourceBuilder.query(QueryBuilders.rangeQuery(createtm).gte(from).lte(to)); 
+		    	System.out.println("区间搜索语句:"+searchSourceBuilder.toString());
+				System.out.println("区间搜索返回结果:"+search(jestClient,indexName, typeName, searchSourceBuilder.toString()));
+			} catch (Exception e) {
+				e.printStackTrace();
+			}
+		}
+	    
+	    
+	    /**
+	     * 创建索引
+	     * @param indexName
+	     * @return
+	     * @throws Exception
+	     */
+	    public boolean createIndex(JestClient jestClient,String indexName) throws Exception {  
+	        JestResult jr = jestClient.execute(new CreateIndex.Builder(indexName).build());  
+	        return jr.isSucceeded();  
+	    }  
+	      
+	    /**
+	     * 新增数据
+	     * @param indexName
+	     * @param typeName
+	     * @param source
+	     * @return
+	     * @throws Exception
+	     */
+	    public boolean insert(JestClient jestClient,String indexName, String typeName, String source) throws Exception {  
+	        PutMapping putMapping = new PutMapping.Builder(indexName, typeName, source).build();  
+	        JestResult jr = jestClient.execute(putMapping);  
+	        return jr.isSucceeded();  
+	    }  
+	      
+	    
+	     /**
+	      * 查询数据
+	      * @param indexName
+	      * @param typeName
+	      * @return
+	      * @throws Exception
+	      */
+	    public static String getIndexMapping(JestClient jestClient,String indexName, String typeName) throws Exception {  
+	        GetMapping getMapping = new GetMapping.Builder().addIndex(indexName).addType(typeName).build();  
+	        JestResult jr =jestClient.execute(getMapping);  
+	        return jr.getJsonString();  
+	     }  
+	      
+	    
+	    
+	   /**
+	    * 批量新增数据
+	    * @param indexName
+	    * @param typeName
+	    * @param objs
+	    * @return
+	    * @throws Exception
+	    */
+	    public static boolean insertBatch(JestClient jestClient,String indexName, String typeName, List<Object> objs) throws Exception {  
+	        Bulk.Builder bulk = new Bulk.Builder().defaultIndex(indexName).defaultType(typeName);  
+	        for (Object obj : objs) {  
+	            Index index = new Index.Builder(obj).build();  
+	             bulk.addAction(index);  
+	        }  
+	        BulkResult br = jestClient.execute(bulk.build());  
+	        return br.isSucceeded();  
+	       }  
+	      
+	    /**
+	     * 全文搜索
+	     * @param indexName
+	     * @param typeName
+	     * @param query
+	     * @return
+	     * @throws Exception
+	     */
+	    public static String search(JestClient jestClient,String indexName, String typeName, String query) throws Exception {  
+	    	 Search search = new Search.Builder(query)
+	    	 .addIndex(indexName)
+	    	 .addType(typeName)  
+	    	 .build(); 
+	        JestResult jr = jestClient.execute(search);  
+//	        System.out.println("--"+jr.getJsonString());
+//	        System.out.println("--"+jr.getSourceAsObject(User.class));
+	        return jr.getSourceAsString();  
+	     }  
+	      
+	      
+	    
+	   
+	      
+	   /**
+	    * 删除索引
+	    * @param indexName
+	    * @return
+	    * @throws Exception
+	    */
+	    public boolean delete(JestClient jestClient,String indexName) throws Exception {  
+	        JestResult jr = jestClient.execute(new DeleteIndex.Builder(indexName).build());  
+	        return jr.isSucceeded();  
+	    }  
+	      
+	   /**
+	    * 删除数据
+	    * @param indexName
+	    * @param typeName
+	    * @param id
+	    * @return
+	    * @throws Exception
+	    */
+	    public boolean delete(JestClient jestClient,String indexName, String typeName, String id) throws Exception {  
+	        DocumentResult dr = jestClient.execute(new Delete.Builder(id).index(indexName).type(typeName).build());  
+	        return dr.isSucceeded();  
+	    }  
+	      
+}
+
+
+ class User implements Serializable{
+	 /**
+	 * 
+	 */
+	private static final long serialVersionUID = 1L;
+	/** 编号 */
+	 private Long id;
+	 /** 姓名 */
+	 private String name;
+	 
+	 /** 年龄 */
+	 private Integer age;
+	 
+	 /** 描述 */  
+	 private String description;
+	 
+	 /** 创建时间 */
+	 private String createtm;
+	 
+	 
+	 public User(){
+	 }
+
+	 
+	 
+	 
+	public User(Long id, String name, Integer age, String description, String createtm) {
+		super();
+		this.id = id;
+		this.name = name;
+		this.age = age;
+		this.description = description;
+		this.createtm = createtm;
+	}
+
+
+
+
+	/**  
+	 * 获取编号  
+	 * @return  id  
+	 */
+	public Long getId() {
+		return id;
+	}
+
+
+	/**  
+	 * 设置编号  
+	 * @param Long id  
+	 */
+	public void setId(Long id) {
+		this.id = id;
+	}
+
+
+	/**  
+	 * 获取姓名  
+	 * @return  name  
+	 */
+	public String getName() {
+		return name;
+	}
+
+
+	/**  
+	 * 设置姓名  
+	 * @param String name  
+	 */
+	public void setName(String name) {
+		this.name = name;
+	}
+
+
+	/**  
+	 * 获取年龄  
+	 * @return  age  
+	 */
+	public Integer getAge() {
+		return age;
+	}
+
+
+	/**  
+	 * 设置年龄  
+	 * @param Integer age  
+	 */
+	public void setAge(Integer age) {
+		this.age = age;
+	}
+
+
+	/**  
+	 * 获取描述  
+	 * @return  description  
+	 */
+	public String getDescription() {
+		return description;
+	}
+
+
+	/**  
+	 * 设置描述  
+	 * @param String description  
+	 */
+	public void setDescription(String description) {
+		this.description = description;
+	}
+
+
+	/**  
+	 * 获取创建时间  
+	 * @return  createtm  
+	 */
+	public String getCreatetm() {
+		return createtm;
+	}
+
+
+	/**  
+	 * 设置创建时间  
+	 * @param String createtm  
+	 */
+	public void setCreatetm(String createtm) {
+		this.createtm = createtm;
+	}
+
+
+
+
+	@Override
+	public String toString() {
+		return "User [id=" + id + ", name=" + name + ", age=" + age + ", description=" + description + ", createtm="
+				+ createtm + "]";
+	}
+	 
+	
+
+}
+