<dependency>

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

            <artifactId>transport</artifactId>

            <version>5.4.0</version>

        </dependency>

    <dependency>

            <groupId>org.springframework.boot</groupId>

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

        </dependency>

<!--版本是和Spring Boot的parent同步的，默认2.2.4RELEASE,里面的spring-data-lasticsearch版本为3.2.4.RELEASE,
再里面的elasticsearch-rest-high-level-client和transport版本为6.8.6-->

SELECT post_bar_id postBarId, catalogue_id catalogueId, post_bar_name postBarName,

post_bar_explain postBarExplain, post_bar_logo_url postBarLogoUrl, user_id userId,

post_count postCount, user_count userCount, create_time createTime, post_bar_status postBarStatus

 FROM post_bar_info WHERE post_bar_status = 1

SELECT post_id postId, post_bar_id postBarId, post_title postTitle, post_content postContent,

user_id userId, top_post topPost, wonderful_post wonderfulPost,audit,

visit_count visitCount, post_status postStatus, create_time createTime

FROM post_info WHERE post_status = 1

package ……；

import com.seven.forum.entity.zyl.PostBarInfoEntity;

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

import java.util.List;

public interface PostBarInfoRepository extends ElasticsearchRepository<PostBarInfoEntity, Long> {


　　// 我看它模板里面用的是Iterable<T>接收数据的，不过我这里写的是List， 
　　// 这里的PostBarName他只会到elasticsearch中找到mapping中名字为postBarName，
　　// 不管是postbarname还是post_bar_name都是不行的，所以前面 数据库要给有下划线的列取别名，并且要设置不使用默认的小写转换

    List<PostBarInfoEntity> queryByPostBarNameContains(String postBarName);

    List<PostBarInfoEntity> getByCatalogueId(Long id);

}

package ……;

import lombok.Data;

import org.springframework.data.annotation.Id;

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

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

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

import java.util.Date;

@Data
// 我用的elasticsearch，type不设置的话，mapping用的就是用的类名小写，这个我目前还没去研究有什么区别，之前看的那本书上的知识没记住……

@Document(indexName = "post_bar_info", type = "_doc")

public class PostBarInfoEntity {

    @Id

    @Field(type = FieldType.Long)

    private Long postBarId;

    @Field(type = FieldType.Long)

    private Long catalogueId;

    @Field(type = FieldType.Text, analyzer = "ik_max_word")

    private String postBarName;

    @Field(type = FieldType.Text, analyzer = "ik_max_word")

    private String postBarExplain;

    @Field(type = FieldType.Text)

    private String postBarLogoUrl;

    @Field(type = FieldType.Long)

    private Long userId;

    @Field(type = FieldType.Long)

    private Long postCount;

    @Field(type = FieldType.Long)

    private Long userCount;

    @Field(type = FieldType.Date)

    private Date createTime;

    @Field(type = FieldType.Integer)

    private Integer postBarStatus;

    @Override

    public String toString() {

        return "PostBarInfoEntity{" +

                "postBarId=" + postBarId +

                ", catalogueId=" + catalogueId +

                ", postBarName='" + postBarName + '\'' +

                ", postBarExplain='" + postBarExplain + '\'' +

                ", postBarLogoUrl='" + postBarLogoUrl + '\'' +

                ", userId=" + userId +

                ", postCount=" + postCount +

                ", userCount=" + userCount +

                ", createTime=" + createTime +

                ", postBarStatus=" + postBarStatus +

                '}';

    }

}

import com.seven.forum.SpringBootApp;import org.junit.Test;

import org.junit.runner.RunWith;

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

import org.springframework.boot.test.context.SpringBootTest;

import org.springframework.data.elasticsearch.core.ElasticsearchRestTemplate;

import org.springframework.test.context.junit4.SpringRunner;

import java.util.List;

@RunWith(SpringRunner.class)

@SpringBootTest(classes = SpringBootApp.class)

public class ElasticsearchTest {

    @Autowired

    private ElasticsearchRestTemplate template;

　　// 这里有个坑，在使用createIndex方法的时候，它有时候会顺便一起把putMapping一起执行（不是一起执行，是创建index的时候把mapping一起映射了出来，
　　// 之前我刚学的时候就在这里栽了个坑，两份一样的代码，都只有createIndex方法，一个会创建出mapping，一个就只有index而没有mapping）我目前觉得它是随机的效果。

    @Test

    public void testCreatePostBar() {

        template.createIndex(PostBarInfoEntity.class);

    }

　　// 同步logstash的时候，没有mapping也可以，只要有index就可以

    @Test

    public void testCreatePostBarMapping() {

        template.putMapping(PostBarInfoEntity.class);

    }