ElasticSearch(5.5.2)在java中的使用

https://blog.csdn.net/didiaodeabing/article/details/79310710

pom.xml:

<?xml version="1.0" encoding="UTF-8"?>

<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>com.stono</groupId>

  <artifactId>es01</artifactId>

  <version>1.0-SNAPSHOT</version>

  <name>es01</name>

  <!-- FIXME change it to the project's website -->

  <url>http://www.example.com</url>

  <properties>

    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

    <maven.compiler.source>1.7</maven.compiler.source>

    <maven.compiler.target>1.7</maven.compiler.target>

  </properties>

  <dependencies>

    <!-- https://mvnrepository.com/artifact/org.elasticsearch/elasticsearch -->

    <dependency>

      <groupId>org.elasticsearch</groupId>

      <artifactId>elasticsearch</artifactId>

      <version>5.5.1</version>

    </dependency>

    <!-- https://mvnrepository.com/artifact/org.elasticsearch.client/transport -->

    <dependency>

      <groupId>org.elasticsearch.client</groupId>

      <artifactId>transport</artifactId>

      <version>5.5.1</version>

    </dependency>

    <dependency>

      <groupId>junit</groupId>

      <artifactId>junit</artifactId>

      <version>4.12</version>

      <scope>test</scope>

    </dependency>

    <dependency>

      <groupId>org.apache.logging.log4j</groupId>

      <artifactId>log4j-core</artifactId>

      <version>2.7</version>

    </dependency>

    <dependency>

      <groupId>org.apache.logging.log4j</groupId>

      <artifactId>log4j-api</artifactId>

      <version>2.7</version>

    </dependency>

    <dependency>

      <groupId>com.google.code.gson</groupId>

      <artifactId>gson</artifactId>

      <version>2.8.0</version>

    </dependency>

    <dependency>

      <groupId>org.springframework.data</groupId>

      <artifactId>spring-data-elasticsearch</artifactId>

    </dependency>

  </dependencies>

  <build>

    <pluginManagement><!-- lock down plugins versions to avoid using Maven defaults (may be moved to parent pom) -->

      <plugins>

        <plugin>

          <artifactId>maven-clean-plugin</artifactId>

          <version>3.0.0</version>

        </plugin>

        <!-- see http://maven.apache.org/ref/current/maven-core/default-bindings.html#Plugin_bindings_for_jar_packaging -->

        <plugin>

          <artifactId>maven-resources-plugin</artifactId>

          <version>3.0.2</version>

        </plugin>

        <plugin>

          <artifactId>maven-compiler-plugin</artifactId>

          <version>3.7.0</version>

        </plugin>

        <plugin>

          <artifactId>maven-surefire-plugin</artifactId>

          <version>2.20.1</version>

        </plugin>

        <plugin>

          <artifactId>maven-jar-plugin</artifactId>

          <version>3.0.2</version>

        </plugin>

        <plugin>

          <artifactId>maven-install-plugin</artifactId>

          <version>2.5.2</version>

        </plugin>

        <plugin>

          <artifactId>maven-deploy-plugin</artifactId>

          <version>2.8.2</version>

        </plugin>

      </plugins>

    </pluginManagement>

  </build>

</project>

java:

package com.stono;

import org.elasticsearch.action.delete.DeleteRequest;

import org.elasticsearch.action.delete.DeleteResponse;

import org.elasticsearch.action.get.GetResponse;

import org.elasticsearch.action.index.IndexResponse;

import org.elasticsearch.action.search.SearchResponse;

import org.elasticsearch.client.transport.TransportClient;

import org.elasticsearch.common.settings.Settings;

import org.elasticsearch.common.transport.InetSocketTransportAddress;

import org.elasticsearch.common.xcontent.XContentBuilder;

import org.elasticsearch.common.xcontent.XContentFactory;

import org.elasticsearch.index.query.QueryBuilders;

import org.elasticsearch.rest.RestStatus;

import org.elasticsearch.search.SearchHit;

import org.elasticsearch.search.SearchHits;

import org.elasticsearch.transport.client.PreBuiltTransportClient;

import org.junit.After;

import org.junit.Before;

import org.junit.Test;

import java.io.IOException;

import java.net.InetAddress;

import java.net.UnknownHostException;

import java.util.HashMap;

import java.util.Iterator;

import java.util.Map;

public class ElasticSearchTest {

    public final static String HOST = "127.0.0.1";

    public final static int PORT = 9300;

    private TransportClient client = null;

    @Before

    public void getConnect() throws UnknownHostException {

        client = new PreBuiltTransportClient(Settings.EMPTY).addTransportAddresses(

                new InetSocketTransportAddress(InetAddress.getByName(HOST), PORT)

        );

        System.out.println("连接信息：" + client.toString());

    }

    @After

    public void closeConnect() {

        if (null != client) {

            System.out.println("执行关闭连接操作");

            client.close();

        }

    }

    // 使用XContentBuilder创建索引

    @Test

    public void addIndex() throws IOException {

        System.out.println("测试中，使用XContentBuilder创建索引");

        /*

        建立文档对象

        参数一blog1: 表示索引对象

        参数二article: 类型

        参数三1: 建立id

         */

        XContentBuilder builder = XContentFactory.jsonBuilder()

                .startObject()

                .field("id", 1)

                .field("title", "elasticSearch引擎")

                .field("content", "全球搜索服务器")

                .endObject();

        IndexResponse indexResponse = client.prepareIndex("blog1", "article", Integer.toString(1)).setSource(builder).get();

        // 结果获取

        String index = indexResponse.getIndex();

        String type = indexResponse.getType();

        String id = indexResponse.getId();

        long version = indexResponse.getVersion();

        RestStatus status = indexResponse.status();

        System.out.println("索引：" + index + "; 类型：" + type + "; id：" + id + "; 版本：" + version + "; 状态：" + status);

    }

    // 使用JSON创建索引

    @Test

    public void addIndex2() throws IOException {

        System.out.println("测试中，使用JSON创建索引");

        String json = "{" +

                "\"name\":\"深入浅出Node.js\"," +

                "\"author\":\"朴灵 \"," +

                "\"pubinfo\":\"人民邮电出版社 \"," +

                "\"pubtime\":\"2013-12-1 \"," +

                "\"desc\":\"本书从不同的视角介绍了 Node 内在的特点和结构。由首章Node 介绍为索引，涉及Node 的各个方面，主要内容包含模块机制的揭示、异步I/O 实现原理的展现、异步编程的探讨、内存控制的介绍、二进制数据Buffer 的细节、Node 中的网络编程基础、Node 中的Web 开发、进程间的消息传递、Node 测试以及通过Node 构建产品需要的注意事项。最后的附录介绍了Node 的安装、调试、编码规范和NPM 仓库等事宜。本书适合想深入了解 Node 的人员阅读。\"" +

                "}";

        IndexResponse indexResponse = client.prepareIndex("blog2", "goods").setSource(json).get();

        // 结果获取

        String index = indexResponse.getIndex();

        String type = indexResponse.getType();

        String id = indexResponse.getId();

        long version = indexResponse.getVersion();

        RestStatus status = indexResponse.status();

        System.out.println("索引：" + index + "; 类型：" + type + "; id：" + id + "; 版本：" + version + "; 状态：" + status);

    }

    // 使用Map创建索引

    @Test

    public void addIndex3() throws IOException {

        System.out.println("测试中，使用Map创建索引");

        Map<String, Object> map = new HashMap<>();

        map.put("name", "Go Web编程");

        map.put("author", "谢孟军 ");

        map.put("pubinfo", "电子工业出版社");

        map.put("pubtime", "2013-6");

        map.put("desc", "《Go Web编程》介绍如何使用Go语言编写Web，包含了Go语言的入门、Web相关的一些知识、Go中如何处理Web的各方面设计（表单、session、cookie等）、数据库以及如何编写GoWeb应用等相关知识。通过《Go Web编程》的学习能够让读者了解Go的运行机制，如何用Go编写Web应用，以及Go的应用程序的部署和维护等，让读者对整个的Go的开发了如指掌。");

        IndexResponse indexResponse = client.prepareIndex("blog2", "goods").setSource(map).execute().actionGet();

        // 结果获取

        String index = indexResponse.getIndex();

        String type = indexResponse.getType();

        String id = indexResponse.getId();

        long version = indexResponse.getVersion();

        RestStatus status = indexResponse.status();

        System.out.println("索引：" + index + "; 类型：" + type + "; id：" + id + "; 版本：" + version + "; 状态：" + status);

    }

    // 删除索引

//    @Test

    public void deleteByObject() throws Exception {

        DeleteResponse deleteResponse = client.delete(new DeleteRequest("blog1", "article", Integer.toString(1))).get();

    }

    // 获取文档信息

    @Test

    public void getIndexNoMapping() throws Exception {

        GetResponse actionGet = client.prepareGet("blog1", "article", "1").execute().actionGet();

        System.out.println(actionGet.getSourceAsString());

    }

    // 查询所有文档信息

    @Test

    public void getMatchAll() throws IOException {

        SearchResponse searchResponse = client.prepareSearch("blog1")

                .setTypes("article").setQuery(QueryBuilders.matchAllQuery())

                .get(); // get() === execute().actionGet()

        // 获取命中次数，查询结果有多少对象

        SearchHits hits = searchResponse.getHits();

        System.out.println("查询结果有：" + hits.getTotalHits() + "条");

        Iterator<SearchHit> iterator = hits.iterator();

        while (iterator.hasNext()) {

            // 查询每个对象

            SearchHit searchHit = iterator.next();

            System.out.println(searchHit.getSourceAsString()); // 获取字符串格式打印

            System.out.println("title:" + searchHit.getSource().get("title"));

        }

    }

    // 关键字查询

    @Test

    public void getKeyWord() throws IOException {

        long time1 = System.currentTimeMillis();

        SearchResponse searchResponse = client.prepareSearch("blog1")

                .setTypes("article").setQuery(QueryBuilders.queryStringQuery("你们"))

                .get();

        // 获取命中次数，查询结果有多少对象

        SearchHits hits = searchResponse.getHits();

        System.out.println("查询结果有：" + hits.getTotalHits() + "条");

        Iterator<SearchHit> iterator = hits.iterator();

        while (iterator.hasNext()) {

            // 查询每个对象

            SearchHit searchHit = iterator.next();

            // 获取字符串格式打印

            System.out.println(searchHit.getSourceAsString());

            System.out.println("title:" + searchHit.getSource().get("title"));

        }

        long time2 = System.currentTimeMillis();

        System.out.println("花费" + (time2 - time1) + "毫秒");

    }

    // 通配符、词条查询

    @Test

    public void getByLike() throws IOException {

        long time1 = System.currentTimeMillis();

        SearchResponse searchResponse = client.prepareSearch("blog1")

                .setTypes("article").setQuery(QueryBuilders.wildcardQuery("desc", "你们*")) // 通配符查询

                .setTypes("article").setQuery(QueryBuilders.wildcardQuery("content", "服务器"))

                .setTypes("article").setQuery(QueryBuilders.termQuery("content", "全文")) // 词条查询

                // 一般情况下只显示十条数据

                // from + size must be less than or equal to: [10000]

                // Scroll Search 支持1万以上的数据量

                // .setSize(10000)

                .get();

        // 获取命中次数，查询结果有多少对象

        SearchHits hits = searchResponse.getHits();

        System.out.println("查询结果有：" + hits.getTotalHits() + "条");

        Iterator<SearchHit> iterator = hits.iterator();

        while (iterator.hasNext()) {

            // 查询每个对象

            SearchHit searchHit = iterator.next();

            // 获取字符串格式打印

            System.out.println(searchHit.getSourceAsString());

            System.out.println("title:" + searchHit.getSource().get("title"));

        }

        long time2 = System.currentTimeMillis();

        System.out.println("花费" + (time2 - time1) + "毫秒");

    }

    // 组合查询

    @Test

    public void combinationQuery() throws Exception {

        SearchResponse searchResponse = client.prepareSearch("blog1").setTypes("article")

                .setQuery(QueryBuilders.boolQuery().must(QueryBuilders.termQuery("title", "搜索"))// 词条查询

//                        .must(QueryBuilders.rangeQuery("id").from(1).to(5)) // 范围查询

                                // 因为IK分词器，在存储的时候将英文都转成了小写

                                .must(QueryBuilders.wildcardQuery("content", "Rest*".toLowerCase())) // 模糊查询

                                .must(QueryBuilders.queryStringQuery("服电风扇丰盛的电器")) // 关键字（含有）

                ).get();

        SearchHits hits = searchResponse.getHits();

        System.out.println("总记录数：" + hits.getTotalHits());

        Iterator<SearchHit> iterator = hits.iterator();

        while (iterator.hasNext()) {

            SearchHit searchHit = iterator.next();

            System.out.println(searchHit.getSourceAsString());

            Map<String, Object> source = searchHit.getSource();

            System.out.println(source.get("id") + ";" + source.get("title") + ";" + source.get("content"));

        }

    }

}

最新文章

  1. SQL SERVER 中is null 和 is not null 将会导致索引失效吗？
  2. python 面向对象-笔记
  3. org.apache.commons.lang.StringUtils中常用的方法
  4. 【ajax】FormData
  5. 1.6.7 Detecting Languages During Indexing
  6. HDU 5407 CRB and Candies
  7. 在企业级开发中使用Try...Catch...会影响效率吗？
  8. js中关于一个数组中最大、最小值以及它们的下标的输出的一种解决办法
  9. javascript-变量-作用域
  10. 面试经典算法题集锦——《剑指 offer》小结
  11. C#爬虫系列（二）——食品安全国家标准数据检索平台
  12. Win7 64位操作系统中搭建C/C++的编译环境
  13. Android开发学习之路--UI之简单聊天界面
  14. Android NDK开发三：java和C\C++交互
  15. Restful API设计规范及实战
  16. windows cmd.exe 将程序 stdout 输出到文件中
  17. 加载样式TTFB waiting时间长
  18. MyBatisPlus环境下使用MyBatis的配置类
  19. 【代码审计】YUNUCMS_v1.0.6 后台代码执行漏洞分析
  20. cocos2dx 3.x(绘制线条)

热门文章

  1. 解决for循环下变量显示一致的问题
  2. Java以组的数量将字符串分组
  3. QT_仅仅直接在构造函数中创建对象的不可行的原因
  4. linux 查看分区UUID的两种方法
  5. dubbo负载均衡策略和集群容错策略
  6. 深入Linux内核架构——进程管理和调度（上）
  7. 前端面试绝对会考的JS问题！【已经开源】
  8. jquery validate基本
  9. 【HDU 6006】Engineer Assignment（状压DP）
  10. 创意、实现和合作：一次原创H5的尝试