weizai025
diff --git a/‎codes/javadb/elasticsearch/elasticsearch6/pom.xml
Lines changed: 5 additions & 0 deletions b/‎codes/javadb/elasticsearch/elasticsearch6/pom.xml
Lines changed: 5 additions & 0 deletions
diff --git a/‎codes/javadb/elasticsearch/elasticsearch6/src/main/java/io/github/dunwu/javadb/elasticsearch/Demo.java
Lines changed: 10 additions & 3 deletions b/‎codes/javadb/elasticsearch/elasticsearch6/src/main/java/io/github/dunwu/javadb/elasticsearch/Demo.java
Lines changed: 10 additions & 3 deletions
diff --git a/‎codes/javadb/elasticsearch/elasticsearch6/src/main/java/io/github/dunwu/javadb/elasticsearch/entity/EsEntity.java
Lines changed: 6 additions & 1 deletion b/‎codes/javadb/elasticsearch/elasticsearch6/src/main/java/io/github/dunwu/javadb/elasticsearch/entity/EsEntity.java
Lines changed: 6 additions & 1 deletion
diff --git a/‎codes/javadb/elasticsearch/elasticsearch6/src/main/java/io/github/dunwu/javadb/elasticsearch/entity/Page.java
Lines changed: 36 additions & 0 deletions b/‎codes/javadb/elasticsearch/elasticsearch6/src/main/java/io/github/dunwu/javadb/elasticsearch/entity/Page.java
Lines changed: 36 additions & 0 deletions
diff --git a/‎codes/javadb/elasticsearch/elasticsearch6/src/main/java/io/github/dunwu/javadb/elasticsearch/entity/User.java
Lines changed: 6 additions & 0 deletions b/‎codes/javadb/elasticsearch/elasticsearch6/src/main/java/io/github/dunwu/javadb/elasticsearch/entity/User.java
Lines changed: 6 additions & 0 deletions
@@ -32,6 +32,11 @@
       <artifactId>hutool-all</artifactId>
       <version>5.7.20</version>
     </dependency>
+    <dependency>
+      <groupId>com.fasterxml.jackson.core</groupId>
+      <artifactId>jackson-databind</artifactId>
+      <version>2.15.2</version>
+    </dependency>
 
     <dependency>
       <groupId>ch.qos.logback</groupId>
 
@@ -2,15 +2,21 @@
 
 import io.github.dunwu.javadb.elasticsearch.entity.User;
 import io.github.dunwu.javadb.elasticsearch.mapper.UserEsMapper;
+import io.github.dunwu.javadb.elasticsearch.util.ElasticsearchUtil;
+import org.elasticsearch.client.RestHighLevelClient;
 
 import java.io.IOException;
 import java.util.Arrays;
 import java.util.List;
 
-
 public class Demo {
+
+    private static final String HOSTS = "127.0.0.1:9200";
+    private static final RestHighLevelClient restHighLevelClient = ElasticsearchUtil.newRestHighLevelClient(HOSTS);
+
     public static void main(String[] args) throws IOException, InterruptedException {
-        UserEsMapper mapper = new UserEsMapper();
+
+        UserEsMapper mapper = new UserEsMapper(restHighLevelClient);
 
         System.out.println("索引是否存在：" + mapper.isIndexExists());
 
@@ -24,6 +30,7 @@ public static void main(String[] args) throws IOException, InterruptedException
         System.out.println("根据ID批量查询：" + mapper.pojoListByIds(Arrays.asList("1", "2")).toString());
 
         Thread.sleep(1000);
-        System.out.println("根据ID批量删除：" + mapper.deleteByIds(Arrays.asList("1", "2")));
+        System.out.println("根据ID批量删除：" + mapper.batchDeleteById(Arrays.asList("1", "2")));
     }
+
 }
@@ -7,5 +7,10 @@
  * @since 2023-06-28
  */
 public interface EsEntity {
-    Long getId();
+
+    /**
+     * 获取 ES 主键
+     */
+    String getDocId();
+
 }
@@ -0,0 +1,36 @@
+package io.github.dunwu.javadb.elasticsearch.entity;
+
+import lombok.Data;
+
+import java.util.ArrayList;
+import java.util.Collection;
+import java.util.List;
+
+/**
+ * 分页实体
+ *
+ * @author <a href="mailto:forbreak@163.com">Zhang Peng</a>
+ * @date 2023-06-28
+ */
+@Data
+public class Page<T> {
+
+    private long total;
+    private int page;
+    private int size;
+    private List<T> content = new ArrayList<>();
+
+    public Page(long total, int page, int size) {
+        this.total = total;
+        this.page = page;
+        this.size = size;
+    }
+
+    public Page(long total, int page, int size, Collection<T> list) {
+        this.total = total;
+        this.page = page;
+        this.size = size;
+        this.content.addAll(list);
+    }
+
+}
@@ -12,10 +12,16 @@
 @Data
 @Builder
 public class User implements EsEntity {
+
     private Long id;
     private String username;
     private String password;
     private Integer age;
     private String email;
 
+    @Override
+    public String getDocId() {
+        return null;
+    }
+
 }