基于Spring数据的多租户mongoDB数据库

Question

我想让我的web应用程序使用mongodb和spring data multitenat。

基本上，我希望将所有实体（集合）复制到不同的数据库中。然后（基于一些规则，例如登录系统的用户），我想将一些实体实例（文档）存储到正确的数据库中。

例如，我有一个名为DBNameProviderService的服务。动态返回数据库名称的getDbName（）。如何使用此服务动态选择正确的数据库？

编辑

抱歉，如果不够清楚。也许举个例子会更清楚。

在我的系统中，我可以注册/登录用户（他们存储在名为general_db的数据库中的用户集合中）。

我还有一个实体A（标记为多租户，只是扩展了一个接口）。如果我以用户1的身份登录，我希望在集合A的数据库User1_db中始终存储一个A实例，而如果我以用户2的身份登录，我希望在集合A的User2_db中存储一个A实例。

所以在这个场景中，问题是我无法为每个用户创建mongotemplate bean，因为用户可以在系统中注册，所以它是动态的。我需要MongoTemplate动态选择数据库。

Answer 1

在使用spring mongodb作为多租户时，我也遇到了类似的问题。最后，我找到了一种方法，使用Adapter在静态集合中管理MongoTemplates。

SpringMongoConfigadapter是一个示例片段，可以帮助您进行概述。

Spring配置：

<bean id="springConfig"  class="com.company.config.SpringMongoConfigAdapater"  >

<!-- default db initialization -->

    <property name="defaultDBName" value="${MONGOHQ_DB:db}"></property> 

<!-- mongo instance is referred to http://www.springframework.org/schema/data/mongo/spring-mongo-1.0.xsd  -->

     <property name="mongo" ref="mongo"></property>

        </bean>

SpringMongoConfigAdapter：

public class SpringMongoConfigAdapater {
   // Each Tenant is referenced to MongoTemplate
 static HashMap<String, MongoTemplate> templateMap = new HashMap<>();
 // Each Tenant is referenced to GridFS Template
    static  HashMap<String, GridFsTemplate> gridfsMap = new HashMap<>();
    // @Autowired
    Mongo mongo;
    @Autowired
    private MongoConverter mappingMongoConverter;
    public HashMap<String, MongoTemplate> getTemplateMap() {
        return templateMap;
    }
    /**
     * @return the defaultDBName
     */
    public String getDefaultDBName() {
        return defaultDBName;
    }   /**
     * @param defaultDBName the defaultDBName to set
     */
    public void setDefaultDBName(String defaultDBName) {
        this.defaultDBName = defaultDBName;
    }
    String defaultDBName;
    @Produces
    @ApplicationScoped
    public MongoTemplate templateManager() throws Exception {
        String dbName = MyThreadLocal.getDBName();
        if (StringUtils.isBlank(dbName)) {
            dbName = defaultDBName;
        }
        if (templateMap.get(dbName) == null) {
            MongoTemplate template = mongoTemplate(dbName);
            templateMap.put(dbName, template);
        }
        return templateMap.get(dbName);
    }
    //this is for gridfs template.
    public GridFsTemplate gridfsTemplateManager() throws Exception {
        String dbName = MyThreadLocal.getDBName();
        if (StringUtils.isBlank(dbName)) {
            dbName = defaultDBName;
        }
        if (gridfsMap.get(dbName) == null) {
            GridFsTemplate template = new GridFsTemplate(mongoDbFactory(dbName), mappingMongoConverter);
            gridfsMap.put(dbName, template);
        }
        return gridfsMap.get(dbName);
    }
    MongoTemplate mongoTemplate(String name) throws Exception {
        MongoTemplate mongoTemplate = new MongoTemplate(mongoDbFactory(name));
        return mongoTemplate;
    }
    MongoDbFactory mongoDbFactory(String name) throws Exception {
        return new SimpleMongoDbFactory(mongo, name);
    }
    /**
     * @return the gridfsMap
     */
    public HashMap<String, GridFsTemplate> getGridfsMap() {
        return gridfsMap;
    }
    /**
     * @param gridfsMap the gridfsMap to set
     */
    public void setGridfsMap(HashMap<String, GridFsTemplate> gridfsMap) {
        this.gridfsMap = gridfsMap;
    }
}

现在当你用你的代码打电话的时候，

 springMongoConfigAdapater .templateManager().getMongoOps().findAll(User.class); 

最重要的是，使用线程本地初始化多租户标识符（可能是dbName）我给了一个详细的信息，这可能会帮助你，点击这里！

Answer 2

查看类似问题Spring data mongodb连接到一个Mongo实例中的多个数据库也有可能进行切分，并将要使用和搜索的id设置为密钥的一部分。

Answer 3

你应该看看我的github项目，我有一个非常类似的问题。

https://github.com/Loki-Afro/multi-tenant-spring-mongodb