Проекция MongoDB на поле встроенного документа с помощью mongoTemplate

В моем Java-приложении я хочу получить поле встроенного документа. Это мой поджо:

Мой пользовательский класс

public class User implements Comparable<User> {

    @Id
    private String username;

    private String ownerFirstname;

    private String ownerLastname;

    @DBRef
    @CascadeSave
    @JsonInclude(JsonInclude.Include.NON_NULL)
    private Role role;
}

Роль.класс

@Document
@JsonDeserialize(using = RoleDeserializer.class)
public interface Role {

    String getId();

    void setId(String id);

}

общество.класс

@Document(collection = "role")
public class Society implements Role {

    @Id
    private String id;

    private String name;

    @JsonInclude(JsonInclude.Include.NON_NULL)
    private Address societyAddress;

    @JsonInclude(JsonInclude.Include.NON_NULL)
    private String vatNumber;

    @JsonInclude(JsonInclude.Include.NON_NULL)
    private long birthday;

    private List<ProductResearch> productResearches;

    @DBRef
    private List<Advertisement> advertisementOwnedList;

    @DBRef
    private List<OrderRequest> orderRequests;

    private UserType type;
}

Меня интересует поле adsOwnedList, но я не могу его получить. Используя MongoTemplate, я попытался сделать проекцию:

Query query = Query.query(Criteria.where("_id").is(user.getUsername()));
query.fields().include("role.advertisementOwnedList;");
User user1 = mongoTemplate.findOne(query, User.class);

Или с помощью MongoRepository:

@Query(value = "{ '_id' : ?0}", fields = "{ '_id': 0 , 'role' : 1 ,
'role.advertisementOwnedList' : 1 }") 
User getRoleAdvertisementOwnedList(String username);

Однако роль - это интерфейс, и я всегда получаю исключение:

org.springframework.data.mapping.model.MappingInstantiationException: Failed to instantiate it.bmv.backend.model.Role using constructor NO_CONSTRUCTOR with arguments 

    at org.springframework.data.convert.ReflectionEntityInstantiator.createInstance(ReflectionEntityInstantiator.java:64)
    at org.springframework.data.convert.ClassGeneratingEntityInstantiator.createInstance(ClassGeneratingEntityInstantiator.java:83)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:259)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:239)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter.readValue(MappingMongoConverter.java:1222)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter.access$200(MappingMongoConverter.java:85)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter$MongoDbPropertyValueProvider.getPropertyValue(MappingMongoConverter.java:1170)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter.getValueInternal(MappingMongoConverter.java:880)
    at org.springframework.data.mongodb.core.convert.DefaultDbRefResolverCallback.resolve(DefaultDbRefResolverCallback.java:59)
    at org.springframework.data.mongodb.core.convert.DefaultDbRefResolver.resolveDbRef(DefaultDbRefResolver.java:98)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter$2.doWithAssociation(MappingMongoConverter.java:313)
    at org.springframework.data.mapping.model.BasicPersistentEntity.doWithAssociations(BasicPersistentEntity.java:360)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:296)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:239)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:199)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:195)
    at org.springframework.data.mongodb.core.convert.MappingMongoConverter.read(MappingMongoConverter.java:85)
    at org.springframework.data.mongodb.core.MongoTemplate$ReadDbObjectCallback.doWith(MongoTemplate.java:2324)
    at org.springframework.data.mongodb.core.MongoTemplate.executeFindOneInternal(MongoTemplate.java:1925)
    at org.springframework.data.mongodb.core.MongoTemplate.doFindOne(MongoTemplate.java:1736)
    at org.springframework.data.mongodb.core.MongoTemplate.findOne(MongoTemplate.java:606)
    at org.springframework.data.mongodb.core.MongoTemplate.findOne(MongoTemplate.java:601)
    at it.bmv.backend.UserTest.getAdvTest(UserTest.java:93)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
    at java.lang.reflect.Method.invoke(Method.java:498)
    at org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:50)
    at org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
    at org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:47)
    at org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
    at org.springframework.test.context.junit4.statements.RunBeforeTestMethodCallbacks.evaluate(RunBeforeTestMethodCallbacks.java:75)
    at org.springframework.test.context.junit4.statements.RunAfterTestMethodCallbacks.evaluate(RunAfterTestMethodCallbacks.java:86)
    at org.springframework.test.context.junit4.statements.SpringRepeat.evaluate(SpringRepeat.java:84)
    at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:325)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:252)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.runChild(SpringJUnit4ClassRunner.java:94)
    at org.junit.runners.ParentRunner$3.run(ParentRunner.java:290)
    at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:71)
    at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:288)
    at org.junit.runners.ParentRunner.access$000(ParentRunner.java:58)
    at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:268)
    at org.springframework.test.context.junit4.statements.RunBeforeTestClassCallbacks.evaluate(RunBeforeTestClassCallbacks.java:61)
    at org.springframework.test.context.junit4.statements.RunAfterTestClassCallbacks.evaluate(RunAfterTestClassCallbacks.java:70)
    at org.junit.runners.ParentRunner.run(ParentRunner.java:363)
    at org.springframework.test.context.junit4.SpringJUnit4ClassRunner.run(SpringJUnit4ClassRunner.java:191)
    at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
    at com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:68)
    at com.intellij.rt.execution.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:51)
    at com.intellij.rt.execution.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:237)
    at com.intellij.rt.execution.junit.JUnitStarter.main(JUnitStarter.java:70)
Caused by: org.springframework.beans.BeanInstantiationException: Failed to instantiate [it.bmv.backend.model.Role]: Specified class is an interface
    at org.springframework.beans.BeanUtils.instantiateClass(BeanUtils.java:99)
    at org.springframework.data.convert.ReflectionEntityInstantiator.createInstance(ReflectionEntityInstantiator.java:61)
    ... 50 more

Как я могу получить поле вложенного документа роли?


java mongodb mongorepository projection mongotemplate
person Emanuele Vannacci    schedule 28.03.2018    source источник
comment
Я думаю, что из-за того, что из query.fields().include(role.advertisementOwnedList;) драйвер пытается создать экземпляр роли для заполнения рекламного списка. В качестве теста замените User на Society в классе User и попробуйте выполнить запрос.   -  person Graciano    schedule 29.03.2018
comment
@Graciano Замена роли пользователем на «Общество» не работает. Не исключение, но у Общества все поля равны нулю.   -  person Emanuele Vannacci    schedule 29.03.2018
comment
может быть, ни у одного пользователя нет роли в обществе? У вас есть набор данных, которым вы могли бы поделиться?   -  person Graciano    schedule 29.03.2018

Ответы (1)


arrow_upward
1
arrow_downward

Поскольку мой комментарий, вероятно, был недостаточно ясен, я попытаюсь дать более исчерпывающий ответ.

Для внутреннего тестового инструмента, который я пишу, если у меня есть свободное время, я придумал задачи, которые содержат один или несколько разных сценариев. Сценарий — это просто некий предопределенный тест, который необходимо выполнить. Задача также содержит список тест-кейсов, содержащих текущий статус соответствующего теста.

Наша упрощенная модель выглядит примерно так:

@Getter
@Setter
@Document(collection = "task")
public class TaskEntity implements Serializable, NamedResource {

  @Id
  private String id;
  private String name;
  private String testerName;
  ...
  @DBRef
  private List<ScenarioEntity> testsToExecute = new ArrayList<>();
  ...
  private List<TestCase> performedTests = new ArrayList<>();
  ...
}

Сущности сценария хранятся в другой коллекции и доступны только в качестве ссылки в записи задачи. Однако тестовый пример — это встроенный в задачу документ.

Spring Data позволяет определять представления сущностей или вложенных документов, вводя отдельный интерфейс, который содержит подмножество интересующих вас методов получения сущностей.

Например, TaskView содержит следующее содержимое:

public interface TaskView extends NamedResource {

  String getTesterName();

  @Value("#{target.testsToExecute}")
  List<ScenarioView> getTestsToExecute();
}

где ScenarioView выглядит так:

public interface ScenarioView extends NamedResource {

}

поскольку он наследует только методы от NamedResource:

public interface NamedResource {
  String getId();
  String getName();
}

С другой стороны, TestCaseView немного сложнее, так как он также извлекает свойства из содержащейся записи:

public interface TestCaseView {

  String getId();
  String getTaskId();
  Date getStart();
  Date getEnd();
  @Value("#{target.scenario.id}")
  String getScenarioId();
  @Value("#{target.secnario.name}")
  String getScenarioName();
  @Value("#{target.result.result.name()}")
  String getJobResult();
}

Чтобы использовать все эти интерфейсы, TaskRepository определяет следующие запросы:

public interface TaskRepository extends MongoRepository<TaskEntity, String> {

  @Query("{ '_id': ?0 }")
  TaskEntity findById(String id);

  @Query("{ }")
  Page<TaskView> findPageable(Pageable pageable);

  @Query("{ '_id': ?0, 'performedTests': { 'id': ?1 } }")
  TestCase findTestCaseByIdViaTaskId(String id, String uuid);

  @Query("{ '_id': ?0, 'performedTests': { } }")
  List<TestCase> findTestsCasesForTask(String id);

  @Query("{ '_id': ?0, 'performedTests': { } }")
  Page<TestCaseView> findTestCaseViews(String id, Pageable pageable);

  ...
}

Как видно из кода, Spring Data позволяет определять интерфейсы представления непосредственно в интерфейсе репозитория вместо классов сущностей и, таким образом, извлекать только подмножество или совокупность данных.

person Roman Vottner    schedule 29.03.2018