Elasticsearch的JavaAPI

桃扇骨 2022-04-25 01:44 237阅读 0赞

Elasticsearch的JavaAPI：

## 获取客户端对象 ##

## 创建索引

## 新建文档 ##

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 </pre></td> 
 <td><pre>//新建文档 @Test public void createIndexByJson() {
 //创建文档内容 String json = "{" + "\"id\":\"1\"," + "\"title\":\"基于Lucene的搜索服务器\"," + "\"content\":\"它提供了一个分布式多用户能力的全文搜索引擎，基于RESTful web接口\"" + "}"; //创建 IndexResponse response = client.prepareIndex("blog", "article", "1").setSource(json).execute().actionGet(); //打印返回值 System.out.println("索引" + response.getIndex()); System.out.println("类型" + response.getType()); System.out.println("id" + response.getId()); System.out.println("结果" + response.getResult()); client.close(); } //创建文档以hashmap @Test public void createIndexBymap() {
 HashMap&lt;String, Object&gt; json = new HashMap&lt;String, Object&gt;(); json.put("id", "2"); json.put("title", "hph"); json.put("content", "博客 hph.blog"); IndexResponse response = client.prepareIndex("blog", "article", "2").setSource(json).execute().actionGet(); //打印返回值 System.out.println("索引" + response.getIndex()); System.out.println("类型" + response.getType()); System.out.println("id" + response.getId()); System.out.println("结果" + response.getResult()); client.close(); } //创建文档以hashmap @Test public void createIndexBymap() {
 HashMap&lt;String, Object&gt; json = new HashMap&lt;String, Object&gt;(); json.put("id", "2"); json.put("title", "hph"); json.put("content", "博客 hph.blog"); IndexResponse response = client.prepareIndex("blog", "article", "2").setSource(json).execute().actionGet(); //打印返回值 System.out.println("索引" + response.getIndex()); System.out.println("类型" + response.getType()); System.out.println("id" + response.getId()); System.out.println("结果" + response.getResult()); client.close(); } //创建文档已bulder @Test public void createIndexbyBulider() throws IOException {
 XContentBuilder builder = XContentFactory.jsonBuilder().startObject().field("id", "4").field("title", "博客").field("content", "hphblog.cn").endObject(); IndexResponse response = client.prepareIndex("blog", "article", "3").setSource(builder).execute().actionGet(); //打印返回值 System.out.println("索引" + response.getIndex()); System.out.println("类型" + response.getType()); System.out.println("id" + response.getId()); System.out.println("结果" + response.getResult()); client.close(); } </pre></td> 
 </tr> 
 </tbody> 
</table>

## 查询索引 ##

## 更新文档 ##

## 删除文档 ##

## 查询所有 ##

## 通配符查询 ##

## 模糊查询 ##

## 添加mapping ##

<table> 
 <tbody> 
 <tr> 
 <td><pre>1 2 3 4 5 6 7 8 </pre></td> 
 <td><pre> // 2 添加mapping PutMappingRequest mapping = Requests.putMappingRequest("blog1").type("article").source(builder); client.admin().indices().putMapping(mapping).get(); // 3 关闭资源 client.close(); } </pre></td> 
 </tr> 
 </tbody> 
</table>