MongoDB Spring-data-mongodb 连接到一个 MongoDB 实例中的多个数据库

在本文中，我们将介绍如何使用 Spring-data-mongodb 在一个 MongoDB 实例中连接到多个数据库。MongoDB 是一个流行的面向文档的 NoSQL 数据库，而 Spring-data-mongodb 是一个用于与 MongoDB 进行交互的 Spring 框架模块。

阅读更多：MongoDB 教程

连接到 MongoDB 实例

要连接到一个 MongoDB 实例，我们首先需要在 Spring Boot 项目的配置文件中配置 MongoDB 的连接信息。在 application.properties 或 application.yml 文件中添加以下配置：

spring.data.mongodb.uri=mongodb://localhost:27017

上述配置将连接到本地 MongoDB 实例的默认端口 27017。如果 MongoDB 运行在其他主机或端口上，需要相应地修改上述连接串。

连接到多个数据库

默认情况下，Spring-data-mongodb 将连接到 MongoDB 实例的默认数据库。但是，如果我们希望连接到其他数据库，可以通过配置额外的 MongoTemplate 对象实现。

在 Spring Boot 项目中创建一个扩展了 AbstractMongoConfiguration 的类，并覆盖 MongoClient 的 mongoClient() 方法，以创建一个自定义的 MongoClient 实例。在该方法中，我们可以使用 MongoClientOptions 配置类来自定义连接。

@Configuration
public class MultipleMongoConfig extends AbstractMongoConfiguration {

    @Value("${spring.data.mongodb.uri}")
    private String mongoUri;

    @Override
    protected String getDatabaseName() {
        // 返回默认数据库名
        return "defaultDb";
    }

    @Override
    public MongoClient mongoClient() {
        // 创建自定义的 MongoClient 实例
        MongoClientOptions options = MongoClientOptions.builder()
                .connectionsPerHost(10)
                .build();

        return new MongoClient(new MongoClientURI(mongoUri, options));
    }

    @Primary
    @Bean(name = "defaultMongoTemplate")
    public MongoTemplate defaultMongoTemplate() {
        // 默认 MongoTemplate，连接到默认数据库
        return new MongoTemplate(mongoClient(), getDatabaseName());
    }

    @Bean(name = "secondMongoTemplate")
    public MongoTemplate secondMongoTemplate() {
        // 使用第二个数据库的 MongoTemplate
        String databaseName = "secondDb";
        return new MongoTemplate(mongoClient(), databaseName);
    }
}

在上述代码中，我们创建了一个名为 MultipleMongoConfig 的配置类。在该类中，我们使用了 AbstractMongoConfiguration 类并覆盖了 getDatabaseName() 方法，指定了默认数据库的名称。我们还覆盖了 mongoClient() 方法，以创建一个自定义的 MongoClient 实例。

在上面的代码中，我们还创建了两个 MongoTemplate 对象：defaultMongoTemplate 和 secondMongoTemplate。defaultMongoTemplate 连接到默认数据库，而 secondMongoTemplate 连接到名为 secondDb 的第二个数据库。

使用多个数据库连接

在项目中的任何位置，我们都可以使用 @Autowired 注解将 MongoTemplate 对象注入到其他 Spring Bean 中。然后，我们可以使用注入的 MongoTemplate 对象执行与 MongoDB 相关的操作。

@Service
public class UserService {

    @Autowired
    @Qualifier("defaultMongoTemplate")
    private MongoTemplate defaultMongoTemplate;

    @Autowired
    @Qualifier("secondMongoTemplate")
    private MongoTemplate secondMongoTemplate;

    public User findUserByIdFromDefaultDatabase(String id) {
        Query query = Query.query(Criteria.where("_id").is(id));
        return defaultMongoTemplate.findOne(query, User.class);
    }

    public User findUserByIdFromSecondDatabase(String id) {
        Query query = Query.query(Criteria.where("_id").is(id));
        return secondMongoTemplate.findOne(query, User.class);
    }
}

在上述代码中，我们创建了一个名为 UserService 的服务类。该类使用 @Autowired 注解将 defaultMongoTemplate 和 secondMongoTemplate 注入到类中。我们使用这些 MongoTemplate 对象来执行数据库操作。

总结

本文介绍了如何通过 Spring-data-mongodb 连接到一个 MongoDB 实例的多个数据库。我们首先在项目的配置文件中配置了 MongoDB 的连接信息。然后，我们通过创建自定义的 MongoTemplate 对象连接到多个数据库。最后，我们展示了如何在项目中使用注入的 MongoTemplate 对象执行数据库操作。

通过上述步骤，您可以轻松地使用 Spring-data-mongodb 连接到一个 MongoDB 实例中的多个数据库，并在项目中进行必要的数据库操作。