Add File

agents-flex-search-engine/agents-flex-search-engine-es/src/test/java/com/agentsflex/search/engines/es/ElasticSearcherTest.java

@@ -0,0 +1,42 @@
+package com.agentsflex.search.engines.es;
+
+import com.agentsflex.core.document.Document;
+import com.agentsflex.engine.es.ESConfig;
+import com.agentsflex.engine.es.ElasticSearcher;
+
+import java.math.BigInteger;
+import java.util.List;
+
+public class ElasticSearcherTest {
+    public static void main(String[] args) throws Exception {
+        // 创建工具类实例 (忽略SSL证书，如果有认证则提供用户名密码)
+        ESConfig searcherConfig = new ESConfig();
+        searcherConfig.setHost("https://127.0.0.1:9200");
+        searcherConfig.setUserName("elastic");
+        searcherConfig.setPassword("elastic");
+        searcherConfig.setIndexName("aiknowledge");
+        ElasticSearcher esUtil = new ElasticSearcher(searcherConfig);
+        Document document1 = new Document();
+        document1.setContent("平台客服工具：是指拼多多平台开发并向商家提供的功能或工具，商家通过其专属账号登录平台客服工具后，可以与平台消费者取得\\n\" +\n" +
+            "                \"联系并为消费者提供客户服务");
+        document1.setId(BigInteger.valueOf(1));
+        esUtil.addDocument(document1);
+
+        Document document2 = new Document();
+        document2.setId(2);
+        document2.setContent("document 2 的内容");
+        document2.setTitle("document 2");
+        esUtil.addDocument(document2);
+
+        System.out.println("查询开始--------");
+        List<Document> res = esUtil.searchDocuments("客服");
+        res.forEach(System.out::println);
+        System.out.println("查询结束--------");
+
+        document1.setTitle("document 3");
+        esUtil.updateDocument(document1);
+
+//        esUtil.deleteDocument(1);
+
+    }
+}