Frühling MongoDB + QueryDSL Abfrage von @DBRef bezogene Liste

Question

@Document(collection="users") 
public class User{ 
    @Id 
    private int id; 

    private String name; 
    ... 
    //getters-setters 
} 

@Document(collection="models") 
public class Model{ 
    @Id 
    private int id; 
    private String name; 
    @DBRef 
    private List<User> users; 
    ... 
    //getters-setters 
} 

habe ich versucht, diese Lösung aber es tut nichts zurück:

QMODEL Modell = new QMODEL(); Auslagerbare Auslagerungsdatei = neue Seitenanforderung (0, 100);

Rückgabe modelsRepository.findAll (model.users.any(). Id.eq (anUserId), pageable);

Answer 1

Ich denke, es hängt alles von den JSON-Daten in der MongoDB-Sammlung ab.

In Ihrem Fall sollte die Sammlung "models" das Attribut "users" Array haben. Solange der Schlüsselname übereinstimmt (d. H. "Benutzer"), sollte es funktionieren.

Detailliertes Beispiel: -

Das folgende Beispiel funktioniert gut.

Menschen Sammlung: -

{ 
    "_id" : ObjectId("57c8269b3ee7df409d4d2b64"), 
    "name" : "Erin", 
    "places" : [ 
     { 
      "$ref" : "places", 
      "$id" : ObjectId("57c813b33ee7df409d4d2b58")     
     } 
    ], 
    "url" : "bc.example.net/Erin" 
} 

Orte Sammlung: -

{ 
    "_id" : ObjectId("57c813b33ee7df409d4d2b58"), 
    "name" : "Broadway Center", 
    "url" : "bc.example.net" 
} 

Klassen: -

Orte Klasse: -

@Document(collection = "places") 
public class Places implements Serializable { 

    private static final long serialVersionUID = -5500334641079164017L; 

    @Id 
    private String id; 

    private String name; 

    private String url; 

    ...get and setters 
} 

Menschen Klasse: -

@Document(collection = "people") 
public class People implements Serializable { 

    private static final long serialVersionUID = 6308725499894643034L; 

    @Id 
    private String id; 

    private String name; 

    @DBRef 
    private List<Places> places; 

    private String url; 

    ...get and setters 
} 

Repository-Klasse: -

@Repository 
public interface PeopleRepository extends PagingAndSortingRepository<People, String> { 

    public People findById(String id); 

    @Query(value = "{ 'status' : ?0 }") 
    public Page<People> findByStatus(String status, Pageable pageable); 

} 

FindAll: -

public Boolean findAllPeople() { 

     Page<People> peoplePage = peopleRepository.findAll(new PageRequest(0, 20)); 

     System.out.println("Total elements :" + peoplePage.getTotalElements()); 

     for (People people : peoplePage) { 
      System.out.println("People id :" + people.getId()); 
      System.out.println("Place size :" + people.getPlaces().size()); 
      people.getPlaces().forEach(p -> System.out.println(p.getName())); 
     } 

     return true; 

    }