spring boot 2.5 mongodb连接多数据库

简介: spring boot 2.5 mongodb连接多数据库

依赖



compile "org.springframework.boot:spring-boot-starter-data-mongodb"

maven

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-data-mongodb</artifactId>
</dependency>
mongo uri使用
mongodb://<username>:<password>@<host>:<port>/<db_name>
application.properties配置
#--- Primary MongoDB ---#
spring.data.mongodb.uri=mongodb://admin:root@127.0.0.1:27017/primary
#--- Secondary MongoDB ---#
mongodb.uri=mongodb://admin:root@127.0.0.1:27017/secondary
bean配置
package com.futve.common.config
import org.springframework.boot.autoconfigure.mongo.MongoProperties
import org.springframework.boot.context.properties.ConfigurationProperties
import org.springframework.context.annotation.Bean
import org.springframework.context.annotation.Configuration
import org.springframework.context.annotation.Primary
import org.springframework.data.mongodb.MongoDatabaseFactory
import org.springframework.data.mongodb.core.MongoTemplate
import org.springframework.data.mongodb.core.SimpleMongoClientDatabaseFactory
@Configuration
open class MultipleMongoConfig {
   @Primary
   @Bean(name = ["primaryMongoProperties"])
   @ConfigurationProperties(prefix = "spring.data.mongodb")
   open fun getPrimary() : MongoProperties {
       return MongoProperties()
   }
   @Bean(name = ["secondaryMongoProperties"])
   @ConfigurationProperties(prefix = "mongodb")
   open fun getSecondary() : MongoProperties {
       return MongoProperties()
   }
   @Primary
   @Bean(name = ["primaryMongoTemplate"])
   open fun primaryMongoTemplate() : MongoTemplate {
       return MongoTemplate(primaryMongoDatabaseFactory(getPrimary()))
   }
   @Bean(name = ["secondaryMongoTemplate"])
   open fun secondaryMongoTemplate() : MongoTemplate {
       return MongoTemplate(secondaryMongoDatabaseFactory(getSecondary()))
   }
   @Primary
   @Bean
   open fun primaryMongoDatabaseFactory(mongo : MongoProperties) : MongoDatabaseFactory {
       return SimpleMongoClientDatabaseFactory(
           mongo.uri
       )
   }
   @Bean
   open fun secondaryMongoDatabaseFactory(mongo : MongoProperties) : MongoDatabaseFactory {
       return SimpleMongoClientDatabaseFactory(
           mongo.uri
       )
   }
}
package com.futve.common.config;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.mongo.MongoProperties;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.data.mongodb.MongoDatabaseFactory;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.SimpleMongoClientDatabaseFactory;
@Configuration
public class MultipleMongoConfig2 {
    @Primary
    @Bean("primaryMongoProperties")
    @ConfigurationProperties("spring.data.mongodb")
    MongoProperties getPrimary() {
        return new  MongoProperties();
    } 
    @Bean("secondaryMongoProperties")
    @ConfigurationProperties("mongodb")
    MongoProperties getSecondary() {
        return new  MongoProperties();
    }
    @Primary
    @Bean("primaryMongoTemplate")
    public MongoTemplate primaryMongoTemplate() {
        return new MongoTemplate(primaryMongoDatabaseFactory(getPrimary()));
    }
    @Bean("secondaryMongoTemplate")
    public MongoTemplate secondaryMongoTemplate() {
        return new MongoTemplate(secondaryMongoDatabaseFactory(getSecondary()));
    }
    @Primary
    @Bean
    public MongoDatabaseFactory primaryMongoDatabaseFactory(MongoProperties mongo1) {
        return new SimpleMongoClientDatabaseFactory(
                mongo1.getUri()
        );
    }
    @Bean
    public MongoDatabaseFactory secondaryMongoDatabaseFactory(MongoProperties mongo2) {
        return new SimpleMongoClientDatabaseFactory(
                mongo2.getUri()
        );
    }
}

启动类配置

@SpringBootApplication(exclude = [
  MongoAutoConfiguration::class,
  MongoDataAutoConfiguration::class
])
dao使用
@Repository
class AuthorDao {
   @Autowired
   @Qualifier("secondaryMongoTemplate")
   protected lateinit var secondaryMongoTemplate : MongoTemplate
   fun findBySurname(surname): List<Author> {
       val query = Query()
      query.addCriteria(
          Criteria.where("surname").`is`(surname)
      )
      return secondaryMongoTemplate.find(query, Author::class.java)
   }
}
目录
相关文章
|
4月前
|
SQL Java 关系型数据库
Java连接MySQL数据库环境设置指南
请注意,在实际部署时应该避免将敏感信息(如用户名和密码)硬编码在源码文件里面;应该使用配置文件或者环境变量等更为安全可靠地方式管理这些信息。此外,在处理大量数据时考虑使用PreparedStatement而不是Statement可以提高性能并防止SQL注入攻击;同时也要注意正确处理异常情况,并且确保所有打开过得资源都被正确关闭释放掉以防止内存泄漏等问题发生。
195 13
|
4月前
|
SQL 关系型数据库 MySQL
MySQL数据库连接过多(Too many connections)错误处理策略
综上所述,“Too many connections”错误处理策略涉及从具体参数配置到代码层面再到系统与架构设计全方位考量与改进。每项措施都需根据具体环境进行定制化调整,并且在执行任何变更前建议先行测试评估可能带来影响。
1332 11
|
4月前
|
缓存 Java 应用服务中间件
Spring Boot配置优化:Tomcat+数据库+缓存+日志,全场景教程
本文详解Spring Boot十大核心配置优化技巧,涵盖Tomcat连接池、数据库连接池、Jackson时区、日志管理、缓存策略、异步线程池等关键配置,结合代码示例与通俗解释,助你轻松掌握高并发场景下的性能调优方法,适用于实际项目落地。
723 5
|
10月前
|
关系型数据库 MySQL Java
【YashanDB知识库】原生mysql驱动配置连接崖山数据库
【YashanDB知识库】原生mysql驱动配置连接崖山数据库
【YashanDB知识库】原生mysql驱动配置连接崖山数据库
|
10月前
|
数据库连接 应用服务中间件 PHP
|
9月前
|
安全 Linux 网络安全
YashanDB数据库服务端SSL连接配置
YashanDB支持通过SSL连接确保数据传输安全,需在服务端生成根证书、服务器证书及DH文件,并将根证书提供给客户端以完成身份验证。服务端配置包括使用OpenSSL工具生成证书、设置SSL参数并重启数据库;客户端则需下载根证书并正确配置环境变量与`yasc_env.ini`文件。注意:启用SSL后,所有客户端必须持有根证书才能连接,且SSL与密码认证独立运行。
|
6月前
|
安全 Java Nacos
0代码改动实现Spring应用数据库帐密自动轮转
Nacos作为国内被广泛使用的配置中心,已经成为应用侧的基础设施产品,近年来安全问题被更多关注,这是中国国内软件行业逐渐迈向成熟的标志,也是必经之路,Nacos提供配置加密存储-运行时轮转的核心安全能力,将在应用安全领域承担更多职责。
|
6月前
|
SQL XML Java
配置Spring框架以连接SQL Server数据库
最后,需要集成Spring配置到应用中,这通常在 `main`方法或者Spring Boot的应用配置类中通过加载XML配置或使用注解来实现。
538 0

推荐镜像

更多