具有自定义集合名称的 Spring Data MongoDB 存储库

Question

我正在使用 Spring Data for MongoDB，我需要能够在运行时配置集合。

我的仓库定义为：

@Repository
public interface EventDataRepository extends MongoRepository<EventData, String> {
}

我尝试了这个愚蠢的例子：

@Document(collection = "${mongo.event.collection}")
public class EventData implements Serializable {

但 mongo.event.collection 并没有像使用 @Value 注释那样解析为名称。

更多的调试和搜索，我尝试了以下方法： @Document(collection = "#{${mongo.event.collection}}")

这产生了一个异常：

Caused by: org.springframework.expression.spel.SpelParseException: EL1041E:(pos 1): After parsing a valid expression, there is still more data in the expression: 'lcurly({)'
    at org.springframework.expression.spel.standard.InternalSpelExpressionParser.doParseExpression(InternalSpelExpressionParser.java:129)
    at org.springframework.expression.spel.standard.SpelExpressionParser.doParseExpression(SpelExpressionParser.java:60)
    at org.springframework.expression.spel.standard.SpelExpressionParser.doParseExpression(SpelExpressionParser.java:32)
    at org.springframework.expression.common.TemplateAwareExpressionParser.parseExpressions(TemplateAwareExpressionParser.java:154)
    at org.springframework.expression.common.TemplateAwareExpressionParser.parseTemplate(TemplateAwareExpressionParser.java:85)

也许我只是不知道如何完全使用 SPel 来访问 Spring 的属性配置器中的值。

在单步执行代码时，我看到有一种方法可以指定集合名称甚至表达式，但是，我不确定应该为此目的使用哪个注释或如何做到这一点。

谢谢。 -AP_

Answer 1

所以，最后，这里有一个解决方法。我想我真的不知道如何使用 SPeL 表达式从 Spring Properties Configurationr 访问数据。

在我的@Configuration 类中：

@Value("${mongo.event.collection}")
private String
    mongoEventCollectionName;

@Bean
public String mongoEventCollectionName() {
    return
        mongoEventCollectionName;
}

在我的文档上：

@Document(collection = "#{mongoEventCollectionName}")

这似乎可以正常工作并正确获取我的 .properties 文件中配置的名称，但是，我仍然不确定为什么我不能像在 @Value 注释中那样使用 $ 访问值。

Answer 2

您只需使用 SPeL 即可解决此问题：

@Document(collection = "#{environment.getProperty('mongo.event.collection')}")
public class EventData implements Serializable {
    ...
}

更新 Spring 5.x：

从 Spring 5.x 左右开始，环境之前需要一个额外的@：

@Document(collection = "#{@environment.getProperty('mongo.event.collection')}")
public class EventData implements Serializable {
    ...
}

文档：

• SpEL: 4.2 Expressions in Bean Definitions
• SpEL: 4.3.12 Bean References
• PropertyResolver::getProperty

Answer 3

定义你的实体类

@Document(collection = "${EventDataRepository.getCollectionName()}")
public class EventData implements Serializable {

使用“collectionName”的 getter 和 setter 方法定义自定义存储库接口

public interface EventDataRepositoryCustom {

    String getCollectionName();

    void setCollectionName(String collectionName);
}

通过“collectionName”实现为自定义存储库提供实现类

public class EventDataRepositoryImpl implements EventDataRepositoryCustom{

    private static String collectionName = "myCollection";

    @Override
    public String getCollectionName() {
        return collectionName;
    }

    @Override
    public void setCollectionName(String collectionName) {
        this.collectionName = collectionName;
    }
}

将EventDataRepositoryImpl 添加到存储库接口的扩展列表中，如下所示

@Repository
public interface EventDataRepository extends MongoRepository<EventData, String>, EventDataRepositoryImpl  {
}

现在在您使用 MongoRepository 的服务类中设置集合名称，它看起来像

@Autowired
EventDataRepository  repository ;

repository.setCollectionName("collectionName");

Answer 4

实体类

@Document    // remove the parameters from here


public class EscalationCase 
{

}

配置类

public class MongoDBConfiguration {

    private final Logger logger = LoggerFactory.getLogger(MongoDBConfiguration.class);

    @Value("${sfdc.mongodb.collection}") //taking collection name from properties file 
    private String collectionName;

    @Bean

    public MongoTemplate mongoTemplate(MongoDbFactory mongoDbFactory, MongoMappingContext context) {

        MappingMongoConverter converter = new MappingMongoConverter(new DefaultDbRefResolver(mongoDbFactory), context);
        converter.setTypeMapper(new DefaultMongoTypeMapper(null));
        MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory, converter);
        if (!mongoTemplate.collectionExists(collectionName)) {
            mongoTemplate.createCollection(collectionName);  // adding the collection name here
        }
        return mongoTemplate;

    }
}