MongoRepository动态查询

我有以下问题。假设我有以下模型对象：

class Person {
    String id;
    String firstName;
    String lastName;
    Map<String, String> properties;
}

在属性映射中，您可以插入任何类型的属性，没有任何限制。

上面的对象保存在 MongoDB 中，如下所示：

public interface PersonRepo extends MongoRepository<Person, String> {
}

当一个人被保存到存储库中时Map<String, String> properties被压平了。举个例子，如果我们有以下对象：

Person: {
    id := 1;
    firstName := John,
    lastName  := Doe,
    properties := {
        age: 42
    }
}

保存在 MongoRepository 中的文档如下：

Person: {
    id := 1;
    firstName := John,
    lastName  := Doe,
    age := 42
}

现在我的问题是，我必须根据（例如）寻找对象，如果它们具有特定的属性或没有。假设我想要所有已定义年龄属性的人。一个重要的附加要求是我应该返回一份分页结果.

我尝试过使用

findAll(Example<Person> example, Pageable pageable)

但由于某种原因这不起作用。我怀疑我的模型对象和 MongoDB 文档具有不同的结构。

我也尝试过使用 QueryDsl （这里有一个例子：http://www.baeldung.com/queries-in-spring-data-mongodb http://www.baeldung.com/queries-in-spring-data-mongodb）但也没有成功，而且对我来说这个解决方案并不优雅（必须维护生成的类等。而且我有一种感觉它不会工作，因为我Map<String, String> properties对象成员）。

我想到的另一个足够优雅的解决方案是具有以下功能：

@Query(value = "?0")
Page<Query> findByQuery(String query, Pageable pageable)

在这种情况下，我将能够手动构建查询，并且不必对运行搜索的密钥进行硬编码。 我现在的问题是，如何将查询值设置为我的第一个参数？通过上面显示的示例，我收到以下错误

java.lang.ClassCastException: java.lang.String cannot be cast to com.mongodb.DBObject

另一种解决方案是使用mongoTemplate并查询给定一些Criteria如以下示例所示：

    final Query query = new Query();
    query.addCriteria(Criteria.where("age").regex(".*"));

    mongoTemplate. find(query, Person.class);

此解决方案的问题在于它返回对象列表而不是分页结果。如果我添加，它还会返回特定页面query.with(new PageRequest(3, 2));但在这种情况下，我无法手动构造“分页”结果，因为我不知道元素的总数。

您还有其他想法可以帮助我吗？

提前致谢！

贝娄是我想出的解决方案。回顾一下，我遇到的问题是，我无法执行给定查询对象作为输入的查询，以提高过滤条件的灵活性。事实证明，解决方案非常简单，我只需仔细阅读文档即可:)。

1. step

扩展 MongoRepository 并添加您的自定义函数：

@NoRepositoryBean
public interface ResourceRepository<T, I extends Serializable> extends MongoRepository<T, I> {

    Page<T> findAll(Query query, Pageable pageable);
}

2. step

创建该接口的实现：

public class ResourceRepositoryImpl<T, I extends Serializable> extends SimpleMongoRepository<T, I> implements ResourceRepository<T, I> {

    private MongoOperations mongoOperations;
    private MongoEntityInformation entityInformation;

    public ResourceRepositoryImpl(final MongoEntityInformation entityInformation, final MongoOperations mongoOperations) {
        super(entityInformation, mongoOperations);

        this.entityInformation = entityInformation;
        this.mongoOperations = mongoOperations;
    }

    @Override
    public Page<T> findAll(final Query query, final Pageable pageable) {
        Assert.notNull(query, "Query must not be null!");

        return new PageImpl<T>(
                mongoOperations.find(query.with(pageable), entityInformation.getJavaType(), entityInformation.getCollectionName()),
                pageable,
                mongoOperations.count(query, entityInformation.getJavaType(), entityInformation.getCollectionName())
        );
    }
}

3. step

将您的实现设置为默认的 MongoRepository 实现：

@EnableMongoRepositories(repositoryBaseClass = ResourceRepositoryImpl.class)
public class MySpringApplication {
    public static void main(final String[] args) {
        SpringApplication.run(MySpringApplication.class, args);
    }
}

4. step

为您的自定义对象创建存储库：

public interface CustomObjectRepo extends ResourceRepository<CustomObject, String> {
}

现在，如果您想将多个对象保存在 mongo 文档存储中，那么定义一个扩展您的接口就足够了ResourceRepository（如步骤 4 所示），您将可以使用Page<T> findAll(Query query, Pageable pageable)自定义查询方法。我发现这个解决方案是我尝试过的最优雅的解决方案。

如果您有任何改进建议，请与社区分享。

问候， 克里斯蒂安