@@ -1002,7 +1002,7 @@ void findEntityWithSelfReferencesInBothDirections(@Autowired ReactivePetReposito
1002
1002
1003
1003
StepVerifier .create (repository .findById (petId )).assertNext (loadedPet -> {
1004
1004
assertThat (loadedPet .getFriends ().get (0 ).getName ()).isEqualTo ("Daphne" );
1005
- assertThat (loadedPet .getFriends ().get (0 ).getFriends ().get (0 ).getName ()).isEqualTo ("Luna " );
1005
+ assertThat (loadedPet .getFriends ().get (0 ).getFriends ().get (0 ).getName ()).isEqualTo ("Tom " );
1006
1006
}).verifyComplete ();
1007
1007
}
1008
1008
@@ -1012,6 +1012,14 @@ void countByPropertyWithPossibleCircles(@Autowired ReactivePetRepository reposit
1012
1012
StepVerifier .create (repository .countByName ("Luna" )).expectNext (1L ).verifyComplete ();
1013
1013
}
1014
1014
1015
+ @ Test // GH-2157
1016
+ void countByPatternPathProperties (@ Autowired ReactivePetRepository repository ) {
1017
+ createFriendlyPets ();
1018
+ StepVerifier .create (repository .countByFriendsNameAndFriendsFriendsName ("Daphne" , "Tom" ))
1019
+ .expectNextCount (1L )
1020
+ .verifyComplete ();
1021
+ }
1022
+
1015
1023
@ Test // GH-2157
1016
1024
void existsByPropertyWithPossibleCircles (@ Autowired ReactivePetRepository repository ) {
1017
1025
createFriendlyPets ();
@@ -1021,7 +1029,7 @@ void existsByPropertyWithPossibleCircles(@Autowired ReactivePetRepository reposi
1021
1029
private long createFriendlyPets () {
1022
1030
try (Session session = createSession ()) {
1023
1031
return session .run ("CREATE (luna:Pet{name:'Luna'})-[:Has]->(daphne:Pet{name:'Daphne'})"
1024
- + "-[:Has]->(luna )" + "RETURN id(luna) as id" ).single ().get ("id" ).asLong ();
1032
+ + "-[:Has]->(:Pet{name:'Tom'} )" + "RETURN id(luna) as id" ).single ().get ("id" ).asLong ();
1025
1033
}
1026
1034
}
1027
1035
}
@@ -2488,6 +2496,8 @@ interface ReactivePetRepository extends ReactiveNeo4jRepository<Pet, Long> {
2488
2496
Mono <Long > countByName (String name );
2489
2497
2490
2498
Mono <Boolean > existsByName (String name );
2499
+
2500
+ Mono <Long > countByFriendsNameAndFriendsFriendsName (String friendName , String friendFriendName );
2491
2501
}
2492
2502
2493
2503
interface ReactiveRelationshipRepository extends ReactiveNeo4jRepository <PersonWithRelationship , Long > {
0 commit comments