Springboot集成spring data elasticsearch過程詳解

spring:
 data:
  elasticsearch:
   repositories:
    enabled: true
   #多實例集群擴展時需要配置以下兩個參數
   #cluster-name: datab-search
   #cluster-nodes: 127.0.0.1:9300,127.0.0.1:9301　　

<!---開箱即用，版本默認和springboot版本對應-->
 <dependency>
     <groupId>org.springframework.boot</groupId>
     <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
  </dependency>

@Document(indexName = "cp_doc", type = "doc", shards = 10, replicas = 0)
public class CpDocument extends BaseEntity {
 
　　@Id//作用在成員變量，標記一個字段作為id主鍵
　　private long id ;
　　@Field(type = FieldType.Text)
　　private String name ;
　　@Field(type = FieldType.Text)
　　private String address ;
　　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 getAddress() {
　　return address;
　　}
　　public void setAddress(String address) {
　　this.address = address;
}

/**
 * 基本操作repository-curd
 * @author 滾動的蛋
 *
 */
public interface CpRepository extends ElasticsearchRepository<CpDocument, Integer> {
}

@RunWith(SpringRunner.class)
@SpringBootTest
public class ElasticSearchTest {
  @Autowired
   CpRepository cpRepository;
  @Autowired
  ElasticsearchTemplate elsTemplate;//ElasticsearchTemplate中提供了創建索引的API<br data-filtered="filtered"><br data-filtered="filtered">
  @Test
  public void addIndexTest() {
    //創建索引
    boolean indexRes = elsTemplate.createIndex(CpDocument.class);
    System.out.println("======創建索引結果："+indexRes+"=========");
    //添加索引
    CpDocument cpTest = new CpDocument();
    cpTest.setId(1);
    cpTest.setName("阿里巴巴");
    cpTest.setAddress("北京路12號");
    cpRepository.save(cpTest);
  }
   
  @Test
  public void srarchTest() {
    //這個只做一個多字段的匹配查詢示例，其它的可以查看API文檔使用
    //"name","address" 為匹配的字段
     MultiMatchQueryBuilder multiMatchQuery = QueryBuilders.multiMatchQuery("阿里巴巴","address","name");//多字段匹配QueryBuilder
     SearchQuery searchQuery = new NativeSearchQueryBuilder()//構建查詢對象
         .withQuery(multiMatchQuery)
         .withIndices("cp_doc")//索引名
         .withPageable(PageRequest.of(0, 10))//分頁
         .build();
     Iterable<CpDocument> productDtos = cpRepository.search(searchQuery);
     ArrayList<CpDocument> CpDocuments = Lists.newArrayList(productDtos);
     for (CpDocument cpDocument : CpDocuments) {
      System.out.printf("企業名稱：%s，企業地址：%s\n",cpDocument.getName(),cpDocument.getAddress());
    }
  }