Skip to content

Commit d036693

Browse files
committed
DATAES-969 - Use ResultProcessor in ElasticsearchPartQuery to build PartTree.
Original PR: #546
1 parent 1a354d8 commit d036693

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

src/main/java/org/springframework/data/elasticsearch/repository/query/ElasticsearchPartQuery.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -54,14 +54,14 @@ public class ElasticsearchPartQuery extends AbstractElasticsearchRepositoryQuery
5454

5555
public ElasticsearchPartQuery(ElasticsearchQueryMethod method, ElasticsearchOperations elasticsearchOperations) {
5656
super(method, elasticsearchOperations);
57-
this.tree = new PartTree(method.getName(), method.getEntityInformation().getJavaType());
57+
this.tree = new PartTree(queryMethod.getName(), queryMethod.getResultProcessor().getReturnedType().getDomainType());
5858
this.elasticsearchConverter = elasticsearchOperations.getElasticsearchConverter();
5959
this.mappingContext = elasticsearchConverter.getMappingContext();
6060
}
6161

6262
@Override
6363
public Object execute(Object[] parameters) {
64-
Class<?> clazz = queryMethod.getEntityInformation().getJavaType();
64+
Class<?> clazz = queryMethod.getResultProcessor().getReturnedType().getDomainType();
6565
ParametersParameterAccessor accessor = new ParametersParameterAccessor(queryMethod.getParameters(), parameters);
6666

6767
CriteriaQuery query = createQuery(accessor);

src/main/java/org/springframework/data/elasticsearch/repository/query/ElasticsearchStringQuery.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ public ElasticsearchStringQuery(ElasticsearchQueryMethod queryMethod, Elasticsea
7171

7272
@Override
7373
public Object execute(Object[] parameters) {
74-
Class<?> clazz = queryMethod.getEntityInformation().getJavaType();
74+
Class<?> clazz = queryMethod.getResultProcessor().getReturnedType().getDomainType();
7575
ParametersParameterAccessor accessor = new ParametersParameterAccessor(queryMethod.getParameters(), parameters);
7676

7777
StringQuery stringQuery = createQuery(accessor);

0 commit comments

Comments
 (0)