diff --git a/agents-flex-search-engine/agents-flex-search-engine-es/src/test/java/com/agentsflex/search/engines/es/ElasticSearcherTest.java b/agents-flex-search-engine/agents-flex-search-engine-es/src/test/java/com/agentsflex/search/engines/es/ElasticSearcherTest.java new file mode 100644 index 0000000..20b5f0d --- /dev/null +++ b/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 res = esUtil.searchDocuments("客服"); + res.forEach(System.out::println); + System.out.println("查询结束--------"); + + document1.setTitle("document 3"); + esUtil.updateDocument(document1); + +// esUtil.deleteDocument(1); + + } +}