带Spring boot的MongoDB配置-抽象MongoConfiguration

Question

我正在开发一个REST API与Spring引导v2.0.0。RELEASE与mongoDB耦合。使用sping-boot-starter-data-mongob连接MongoDB im。

正在申请中。属性我可以更改与mongodb相关的基本配置，但我的问题是，当涉及高级属性时，管理这些配置的最佳方式应该是什么。例如，不能通过应用程序更改每个主机的连接属性。财产。

因此，我使用了AbstractMongoConfigance并扩展了它，以便提供上面提到的配置，例如每个主机的连接。这是正确的方法吗？

Answer 1

我过去常常创建外部属性文件，可以尽可能多地添加这些文件。我把属性读入地图

@PostConstruct
public void properties() throws Exception{
    // read properties and put them into map
    crmPropertiesMap.put(key, properties);
}

@Bean(name = "crmPropertiesMap")
public Map<String, CRMProperties> getCrmPropertiesMap() {

    return crmPropertiesMap;
}

并为每个属性文件创建新的数据源，然后将它们放入另一个mapMap

@Bean
public Map<String, DataSource> dataSourceMap() {

Map<String, DataSource> dataSourceMap = new HashMap<>();

for( CRMProperties crmProperties : crmPropertiesMap.values())
{
    // create DataSource
    dataSourceMap.put(crmProperties.getHotelName(),
                    DataSourceBuilder.create()
                            .url(crmProperties.getSpringDatasourcePrimaryUrl())
                            .driverClassName(crmProperties.getSpringDatasourcePrimaryDriverClassName())
                            .username(crmProperties.getSpringDatasourcePrimaryUsername())
                            .password(crmProperties.getSpringDatasourcePrimaryPassword())
                            .build());

然后创建SQL会话

private SqlSession createSqlSession(String id) {

        TransactionFactory transactionFactory = new JdbcTransactionFactory();
        Environment environment = new Environment(id, transactionFactory, dataSourceMap.get(id));
        Configuration configuration = new Configuration(environment);
        configuration.addMapper(SaleInfoMapper.class);

        return new SqlSessionTemplate(sqlSessionFactoryBuilder.build(configuration));
    }

    @Bean
    public Map<String, SqlSession> sqlSessionMap() {

        Map<String, SqlSession> sqlSessionMap = new HashMap<>();

        for ( String id : dataSourceMap.keySet() )
        {
            sqlSessionMap.put(id, createSqlSession(id));
        }

        return sqlSessionMap;
    }

然后动态获取SqlSession。

SqlSession sqlSession = sqlSessionMap.get(key);

希望这对你有帮助。