如何使用Spring数据从elasticsearch读取文档？

Question

我创建了一个索引（house），其类型为“公寓”，包含20个文档。我使用postman将Json作为二进制文件上传到elasticsearch。我有一个Spring Boot项目，它有以下几个类：

>

埃斯孔菲格。java-我已经配置了clustername，它是应用程序中的默认名称。属性文件。

@Configuration
@EnableElasticsearchRepositories(basePackages = "com.search.repository")
public class EsConfig {

@Value("${elasticsearch.clustername}")
private String EsClusterName;

@Bean
public Client esClient() throws UnknownHostException {
    Settings esSettings = Settings.builder()
            .put("cluster.name", EsClusterName)
            .put("client.transport.sniff", true)
            .put("client.transport.ignore_cluster_name", false)
            .build();


   TransportClient  client = new PreBuiltTransportClient(esSettings)
    .addTransportAddress(new InetSocketTransportAddress(InetAddress.getByName("localhost"), 9300));
    return client;

}

@Bean
public ElasticsearchOperations elasticsearchTemplate() throws Exception{
    return new ElasticsearchTemplate(esClient()); 
  }
}

partments.java-这是我的数据模型。这些文档在elasticsearch中有以下字段。

@Document(indexName = "house", type = "apartments")
@JsonIgnoreProperties(ignoreUnknown=true)
public class Apartments {

   @Id
   private String id;
   @JsonProperty("Apartment_Name")
   private String apartmentName;
   @JsonProperty("Apartment_ID")
   private String apartmentId;
   @JsonProperty("Area_Name")
   private String areaName;

   //constructors along with getters and setters
}

ApartmentSearchRepository.java-这是一个扩展Elasticsearch chRepository接口以执行crud操作的接口。

public interface ApartmentSearchRepository extends ElasticsearchRepository<Apartments, String> {
List<Apartments> findByApartmentName(String apartmentName);
}

ESA部门服务。爪哇-

@Service
public class EsApartmentService {

@Autowired
ApartmentSearchRepository apartmentSearchRepository;

public List<Apartments> getApartmentByName(String apartmentName) {
    return apartmentSearchRepository.findByApartmentName(apartmentName);
   }
}

公寓管理员。java——我创建了一个endpoint，可以从elasticsearch返回这20个文档。（此外，在我的项目中，公寓是POJO，公寓是数据模型。）

@Autowired
EsApartmentService esApartmentService;
@GetMapping(path = "/search",produces = "application/json")
public Set<Apartment> searchApartmentByName(
  @RequestParam(value = "apartmentName", defaultValue = "") String apartmentName) throws IOException {
  List<Apartment> apartments= new ArrayList<>();
  esApartmentService.getApartmentByName(apartmentName).forEach(apartment-> {
        apartments.add(new Apartment(apartment.getApartmentName(), apartment.getApartmentId(), apartment.getAreaName()));
    });
  return apartments.stream()
          .collect(Collectors.toCollection(() -> new TreeSet<>(Comparator.comparing(Apartment::getApartmentId))));
}

此代码返回状态为200，但响应为空。我尝试调试，但似乎无法从elasticsearch中读取这些文档。我经历了几个解决方案，但其中大多数都从代码本身中设置了文档数据。

我无法通过点击控制器中指定的endpoint来检索这些文档。有人能告诉我我错过了什么吗？谢谢！：）

Answer 1

如上@ibexit所述，我删除了@JsonProperty，并在我的服务中使用了本机搜索查询生成器。而且，当我给公寓取名字时，它并没有取公寓的名字，而且起了作用。（看起来Elasticsearch有案例问题，所以我把它放在了Camel案例中。）

我的变化：

>

partments.java-已删除@JsonProperty

@Document(indexName = "house", type = "apartments")
//@JsonIgnoreProperties(ignoreUnknown=true)
public class Apartments {

 @Id
 private String id;

 //@JsonProperty("apartment_ID")
 private String apartment_ID;

 //@JsonProperty("Area_Name")
 private String area_Name;

 //@JsonProperty("Apartment_Name")
 private String apartment_Name;
}

ESA部门服务。爪哇-

@Service
public class EsApartmentService {
@Autowired
private  ElasticsearchTemplate elasticsearchTemplate; 

public List<Apartments> getApartmentByName(String apartmentName) {
   SearchQuery searchQuery = new NativeSearchQueryBuilder()           
  .withQuery(org.elasticsearch.index.query.QueryBuilders
    .matchQuery("apartment_Name", apartmentName)).build();
Page<Apartments> sampleEntities = 
    elasticsearchTemplate.queryForPage(searchQuery,Apartments.class);      
return sampleEntities.getContent();
  }
}

这些变化给了我所需的响应！：）

Answer 2

据我所知，您可以使用@JsonProperty将POJO映射到查询响应，但您正在失去使用Spring数据的动态查找器方法（findBy*）的能力。Spring数据的动态查找器生成依赖于反射，这就是POJO中的字段名称变得重要的地方。

您介意更改POJO或文档中的字段名以验证这一点吗？还是只定义一个自定义查询？还有一个强大的java api，您可以在其中定义更复杂的查询：https://docs.spring.io/spring-data/elasticsearch/docs/current/reference/html/#elasticsearch.misc.filter