Spring boot中使用ElasticSearch的方法详解

git clone git: //github测试数据/mobz/elasticsearch-head.git

cd elasticsearch-head

npm install

npm run start

open http: //localhost:9100/

connect: {

    server: {

     options: {

      hostname: '0.0.0.0' ,

      port: 9100 ,

      base: '.' ,

      keepalive: true

     }

    }

   }

#===es start===

spring.data.elasticsearch.repositories.enabled = true

spring.data.elasticsearch.cluster-nodes = 127.0 . 0.1 : 9300

#===es end===

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

<project xmlns= "http://maven.apache.org/pom/4.0.0" xmlns:xsi= "http://HdhCmsTestw3.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>

  <parent>

   <groupid>org.springframework.boot</groupid>

   <artifactid>spring-boot-starter-parent</artifactid>

   <version> 2.1 . 1 .release</version>

   <relativepath/> <!-- lookup parent from repository -->

  </parent>

  <groupid>com.example</groupid>

  <artifactid>demo</artifactid>

  <version> 0.0 . 1 -snapshot</version>

  <name>demo</name>

  <description>demo project for spring boot</description>

  <packaging>jar</packaging>

  <properties>

   <java.version> 1.8 </java.version>

  </properties>

  <dependencies>

   <!--swagger-ui api文档生产工具-->

   <dependency>

    <groupid>io.springfox</groupid>

    <artifactid>springfox-swagger2</artifactid>

    <version> 2.6 . 1 </version>

   </dependency>

   <dependency>

    <groupid>io.springfox</groupid>

    <artifactid>springfox-swagger-ui</artifactid>

    <version> 2.6 . 1 </version>

   </dependency>

   <!--swagger-ui api文档生产工具-->

   <dependency>

    <groupid>org.springframework.boot</groupid>

    <artifactid>spring-boot-starter-data-elasticsearch</artifactid>

   </dependency>

   <dependency>

    <groupid>org.springframework.boot</groupid>

    <artifactid>spring-boot-starter</artifactid>

   </dependency>

   <dependency>

    <groupid>org.springframework.boot</groupid>

    <artifactid>spring-boot-starter-test</artifactid>

    <scope>test</scope>

   </dependency>

   <dependency>

    <groupid>org.springframework.boot</groupid>

    <artifactid>spring-boot-starter-web</artifactid>

   </dependency>

  </dependencies>

  <build>

   <plugins>

    <plugin>

     <groupid>org.springframework.boot</groupid>

     <artifactid>spring-boot-maven-plugin</artifactid>

    </plugin>

   </plugins>

  </build>

</project>

package com.example.demo.domain;

import org.springframework.data.elasticsearch.annotations.document;

import java.io.serializable;

@document (indexname = "testgoods" , type = "goods" )

public class goodsinfo implements serializable {

  private long id;

  private string name;

  private string description;

  public long getid() {

   return id;

  }

  public void setid( long id) {

   this .id = id;

  }

  public string getname() {

   return name;

  }

  public void setname(string name) {

   this .name = name;

  }

  public string getdescription() {

   return description;

  }

  public void setdescription(string description) {

   this .description = description;

  }

  public goodsinfo( long id, string name, string description) {

   this .id = id;

   this .name = name;

   this .description = description;

  }

  public goodsinfo() {

  }

}

package com.example.demo.repository;

import com.example.demo.domain.goodsinfo;

import org.springframework.data.elasticsearch.repository.elasticsearchrepository;

import org.springframework.stereotype测试数据ponent;

@component

public interface goodsrepository extends elasticsearchrepository<goodsinfo, long > {

}

package com.example.demo.controller;

import com.example.demo.domain.goodsinfo;

import com.example.demo.repository.goodsrepository;

import io.swagger.annotations.api;

import io.swagger.annotations.apiimplicitparam;

import io.swagger.annotations.apioperation;

import org.elasticsearch.index.query.querybuilder;

import org.elasticsearch.index.query.querybuilders;

import org.elasticsearch.index.query.functionscore.functionscorequerybuilder;

import org.springframework.beans.factory.annotation.autowired;

import org.springframework.data.domain.page;

import org.springframework.data.domain.pagerequest;

import org.springframework.data.domain.pageable;

import org.springframework.data.elasticsearch.core.query.nativesearchquery;

import org.springframework.data.elasticsearch.core.query.nativesearchquerybuilder;

import org.springframework.data.elasticsearch.core.query.searchquery;

import org.springframework.stereotype.controller;

import org.springframework.web.bind.annotation.*;

import java.util.list;

import java.util.optional;

import static org.elasticsearch.index.query.querybuilders.querystringquery;

@controller

@api (value = "helloworldcontroller|一个用来测试swagger注解的控制器" ,tags = "helloworldcontroller" , description = "helloworldcontroller" )

public class helloworldcontroller {

  @autowired

  private goodsrepository goodsrepository;

  @responsebody

  @requestmapping (value = "/hello" , method = requestmethod.get)

  @apioperation (value = "根据用户编号获取用户姓名" , notes = "test: 仅1和2有正确返回" )

  @apiimplicitparam (paramtype= "query" , name = "usernumber" , value = "用户编号" , required = true , datatype = "integer" )

  public string index( @requestparam integer usernumber){

   if (usernumber == 1 ){

    return "小白" ;

   }

   else if (usernumber == 2 ){

    return "小红" ;

   }

   else {

    return "未知" ;

   }

  }

  @responsebody

  @requestmapping (value = "/save" , method = requestmethod.post)

  @apioperation (value = "新增商品" )

  public string save(){

   goodsinfo goodsinfo = new goodsinfo(system.currenttimemillis(), "商品" + system.currenttimemillis(), "这是一个测试商品" );

   goodsrepository.save(goodsinfo);

   return "success" ;

  }

  @responsebody

  @requestmapping (value = "/delete" , method = requestmethod.post)

  @apioperation (value = "删除商品" )

  @apiimplicitparam (paramtype= "query" , name = "id" , value = "商品id" , required = true , datatype = "long" )

  public string delete( @requestparam (required = true ) long id){

   goodsrepository.deletebyid(id);

   return "success" ;

  }

  @responsebody

  @requestmapping (value = "/update" , method = requestmethod.post)

  @apioperation (value = "更新商品" )

  @apiimplicitparam (paramtype= "query" , name = "id" , value = "商品id" , required = true , datatype = "long" )

  public string update( @requestparam (required = true ) long id,

        @requestparam (required = false ) string name,

        @requestparam (required = false ) string description){

   optional<goodsinfo> goodsinfo = goodsrepository.findbyid(id);

   if (goodsinfo.ispresent()){

    if (name != null ){

     goodsinfo.get().setname(name);

    }

    if (description != null ){

     goodsinfo.get().setdescription(description);

    }

    goodsrepository.save(goodsinfo.get());

    return "success" ;

   } else {

    return "no find" ;

   }

  }

  @responsebody

  @requestmapping (value = "/getone" , method = requestmethod.get)

  @apioperation (value = "得到一个商品" )

  @apiimplicitparam (paramtype= "query" , name = "id" , value = "商品id" , required = true , datatype = "long" )

  public optional<goodsinfo> getone( @requestparam (required = true ) long id){

   optional<goodsinfo> goodsinfo = goodsrepository.findbyid(id);

   return goodsinfo;

  }

  private searchquery getentitysearchquery( int pagenumber, string searchcontent){

   pageable pageable = pagerequest.of(pagenumber, 20 );

   searchquery searchquery = new nativesearchquerybuilder().withquery(querystringquery(searchcontent)).withpageable(pageable).build();

   return searchquery;

  }

  @responsebody

  @requestmapping (value = "/search" , method = requestmethod.get)

  @apioperation (value = "搜索商品" )

  public list<goodsinfo> search( @requestparam (required = true ) integer pagenumber, @requestparam (required = true ) string query){

   searchquery searchquery = getentitysearchquery(pagenumber, query);

   page<goodsinfo> goodspage = goodsrepository.search(searchquery);

   return goodspage.getcontent();

  }

}