Spring 中的 ElasticSearch 与 @Query
ElasticSearch in Spring with @Query
我已经使用 ElasticSearch 的 _plugin/head 接口成功创建了一个查询。该查询旨在 return 特定位置特定设备的最新时间戳。查询如下所示:
{
"query":{
"bool":{
"must":[
{
"term":{
"deviceevent.location.id":"1"
}
},
{
"term":{
"deviceevent.deviceId":"AHE1LDD01"
}
}
]
}
},
"from":0,
"size":1,
"sort":{
"timestamp":{
"order":"desc"
}
}
}
以上查询按预期工作。
现在使用 Spring-Boot 和 Spring-Data-ElasticSearch,我定义了自己的 ElasticSearchRepository
,如下所示:
package com.repository.elasticsearch;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.elasticsearch.annotations.Query;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import com.domain.DeviceEvent;
public interface DeviceEventRepository extends ElasticsearchRepository<DeviceEvent, String>
{
@Query("{\"bool\":{\"must\":[{\"term\":{\"deviceevent.location.id\": \"?0\"}},{\"term\":{\"deviceevent.deviceId\": \"?1\"}}]}},\"from\": 0,\"size\": 1,\"sort\":{\"timestamp\":{\"order\":\"desc\"}}")
DeviceEvent findLatestCheckInAtLocation(Long locationId, String deviceId);
}
上面的代码被破坏主要是因为我希望它是 return 一个 DeviceEvent
,但它实际上是 return 计数 = 10 的设备事件(默认页面大小).似乎结果也没有按时间戳降序排列。就好像查询的 size
和 order
部分没有被提取。
我做错了什么?
而不是在查询注释中控制结果大小。
使用Pageable接口,以下摘自文档
public interface BookRepository extends ElasticsearchRepository<Book, String> {
@Query("{"bool" : {"must" : {"field" : {"name" : "?0"}}}}")
Page<Book> findByName(String name,Pageable pageable);
}
这将使您能够:
findByName("foo-name", new PageRequest(0,1));
如果你也想排序:
findByName("foo-name", new PageRequest(0,1, new Sort(new Sort.Order(Sort.Direction.ASC,"name")))).getContent().get(0);
我已经使用 ElasticSearch 的 _plugin/head 接口成功创建了一个查询。该查询旨在 return 特定位置特定设备的最新时间戳。查询如下所示:
{
"query":{
"bool":{
"must":[
{
"term":{
"deviceevent.location.id":"1"
}
},
{
"term":{
"deviceevent.deviceId":"AHE1LDD01"
}
}
]
}
},
"from":0,
"size":1,
"sort":{
"timestamp":{
"order":"desc"
}
}
}
以上查询按预期工作。
现在使用 Spring-Boot 和 Spring-Data-ElasticSearch,我定义了自己的 ElasticSearchRepository
,如下所示:
package com.repository.elasticsearch;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.Pageable;
import org.springframework.data.elasticsearch.annotations.Query;
import org.springframework.data.elasticsearch.repository.ElasticsearchRepository;
import com.domain.DeviceEvent;
public interface DeviceEventRepository extends ElasticsearchRepository<DeviceEvent, String>
{
@Query("{\"bool\":{\"must\":[{\"term\":{\"deviceevent.location.id\": \"?0\"}},{\"term\":{\"deviceevent.deviceId\": \"?1\"}}]}},\"from\": 0,\"size\": 1,\"sort\":{\"timestamp\":{\"order\":\"desc\"}}")
DeviceEvent findLatestCheckInAtLocation(Long locationId, String deviceId);
}
上面的代码被破坏主要是因为我希望它是 return 一个 DeviceEvent
,但它实际上是 return 计数 = 10 的设备事件(默认页面大小).似乎结果也没有按时间戳降序排列。就好像查询的 size
和 order
部分没有被提取。
我做错了什么?
而不是在查询注释中控制结果大小。
使用Pageable接口,以下摘自文档
public interface BookRepository extends ElasticsearchRepository<Book, String> {
@Query("{"bool" : {"must" : {"field" : {"name" : "?0"}}}}")
Page<Book> findByName(String name,Pageable pageable);
}
这将使您能够:
findByName("foo-name", new PageRequest(0,1));
如果你也想排序:
findByName("foo-name", new PageRequest(0,1, new Sort(new Sort.Order(Sort.Direction.ASC,"name")))).getContent().get(0);