Read domain type when returning an implemented interface from repository query methods.

We now read the domain type instead of trying to materialize an interface if the type returned from the query method is implemented by the domain object handled by the repository.

Closes #519

Author: mp911de

src/main/java/org/springframework/data/r2dbc/repository/query/AbstractR2dbcQuery.java

@@ -129,6 +129,10 @@ Class<?> resolveResultType(ResultProcessor resultProcessor) {
 
 		ReturnedType returnedType = resultProcessor.getReturnedType();
 
+		if (returnedType.getReturnedType().isAssignableFrom(returnedType.getDomainType())) {
+			return returnedType.getDomainType();
+		}
+
 		return returnedType.isProjecting() ? returnedType.getDomainType() : returnedType.getReturnedType();
 	}
 

src/test/java/org/springframework/data/r2dbc/repository/AbstractR2dbcRepositoryIntegrationTests.java

@@ -394,11 +394,16 @@ interface LegoSetRepository extends ReactiveCrudRepository<LegoSet, Integer> {
 		Mono<Boolean> existsByName(String name);
 	}
 
+	public interface Buildable {
+
+		String getName();
+	}
+
 	@Getter
 	@Setter
 	@Table("legoset")
 	@NoArgsConstructor
-	public static class LegoSet extends Lego {
+	public static class LegoSet extends Lego implements Buildable {
 		String name;
 		Integer manual;
 

src/test/java/org/springframework/data/r2dbc/repository/H2R2dbcRepositoryIntegrationTests.java

@@ -142,8 +142,19 @@ public void shouldInsertIdOnlyEntity() {
 			}).verifyComplete();
 	}
 
+	@Test // gh-519
+	public void shouldReturnEntityThroughInterface() {
+
+		shouldInsertNewItems();
+
+		repository.findByName("SCHAUFELRADBAGGER").map(Buildable::getName).as(StepVerifier::create)
+				.expectNext("SCHAUFELRADBAGGER").verifyComplete();
+	}
+
 	interface H2LegoSetRepository extends LegoSetRepository {
 
+		Mono<Buildable> findByName(String name);
+
 		@Query("SELECT MAX(manual) FROM legoset WHERE name = :name")
 		Mono<Integer> findMax(String name);