SpringBoot直接MongoRepository到特定MongoTemplate

Question

我有一个应用程序有多个mongo配置。这是通过一些@Configuration类实现的，比如

public abstract class AbstractMongoConfig {
    private String database;
    private String uri;

    public void setUri(String uri) {
        this.uri = uri;
    }

    public void setDatabase(String database) {
        this.database = database;
    }

    public MongoDbFactory mongoDbFactory() throws Exception {
        return new SimpleMongoDbFactory(new MongoClient(new MongoClientURI(this.uri)), this.database);
    }

    abstract public MongoTemplate getMongoTemplate() throws Exception;
}

配置1——应用程序

@Configuration
@ConfigurationProperties(prefix="app.mongodb")
public class AppMongoConfig extends AbstractMongoConfig {
    @Primary
    @Override
    @Bean(name="appMongoTemplate")
    public MongoTemplate getMongoTemplate() throws Exception {
        return new MongoTemplate(mongoDbFactory());
    }
}

配置2--测试

@Configuration
@ConfigurationProperties(prefix="test.mongodb")
public class TestMongoConfig extends AbstractMongoConfig {
    @Override
    @Bean(name="testMongoTemplate")
    public MongoTemplate getMongoTemplate() throws Exception {
        return new MongoTemplate(mongoDbFactory());
    }
}

然后在我的房子里

test.mongodb.uri=mongodb://127.0.0.1/test
test.mongodb.database=test
app.mongodb.uri=mongodb://127.0.0.1/app
app.mongodb.database=app

因此，两个mongo配置连接到本地运行但具有不同数据库的实例。我也尝试过使用不同的地址，但它的行为相同。

不管怎么说，这将通过实体和MongoRepository来使用

@Document(collection="collname")
public class TestObj {

    @Id
    private String id;

    private String username;
    private int age;
    // getters & setters
}

回购

@Repository
public interface TestObjRepository extends MongoRepository<TestObj, String> {
    public TestObj findByUsername(String username);
}

然而，当我在某个地方的课堂上使用它时

@Service
public class ThingDoer {

    @Autowired
    TestObjRepository toRepo;

    public void doStuff() {
        TestObj to = new TestObj("name", 123);
        toRepo.save(to);
    }
}    

此对象被写入TestMongoConfig，而不是我所期望的AppMongoConfig，因为它是用@Prime注释的对象。此外，如果我在ThingDoer上添加@EnableMongoRepositories注释，例如：

@EnableMongoRepositories(basePackages={"com.whatever.package"}, mongoTemplateRef="appMongoTemplate")

它仍然不起作用。它仍然写入“test”引用的db。

如果我直接在MongoTemplate中@Autowire，并使用它，它就会像我预期的那样工作。所有东西都会被“应用”回购。我如何告诉它TestObjRepository应该向哪个数据库写入数据和从哪个数据库读取数据？

Answer 1

因此，如果其他人仍然有这个问题，解决方案是：

@EnableMongoRepositories(basePackages={"com.whatever.package"}, mongoTemplateRef="appMongoTemplate")

你必须把它放在你的自定义mongo属性上。其中basePackages是您的回购协议的包路径。每个mongo数据库都必须有一个包，因此它会查找预期的存储库和模型引用。当使用多个DBs时，您还必须在spring之前禁用mongo自动配置：

spring。自动配置。排除：org。springframework。靴子自动配置。蒙戈。Mongouto配置

这是一个很棒的教程：https://dzone.com/articles/multiple-mongodb-connectors-with-spring-boot