时间:2021-05-19
这篇文章主要介绍了Spring-boot集成pg、mongo多数据源过程详解,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
修改POM文件,增加相应Jar包
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb</artifactId> </dependency><dependency> <groupId>org.postgresql</groupId> <artifactId>postgresql</artifactId> <scope>runtime</scope> </dependency><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-jdbc</artifactId></dependency>修改启动类,去除原有的数据源自动加载机制
@SpringBootApplication( exclude = {DataSourceAutoConfiguration.class, PageHelperAutoConfiguration.class , MongoAutoConfiguration.class, MongoDataAutoConfiguration.class//禁用数据源自动配置 })@EnableEurekaClientpublic class MainApplication {、、、编写application.yml文件,增加配置信息
spring: # 默认的postgreSQL库 datasource: pg: url: jdbc:postgresql://127.0.0.1:5432/pgdb username: us_wu password: netcool@919 driver-class-name: org.postgresql.Driver mg: host: 127.0.0.1 username: aaa password: aaa database: mgdb port: 27017分别手动增加PG、mongo的数据源以及使用样例
pg
1、手动加载数据源
@Configurationpublic class DataSourceConfig { final String cmspg="spring.datasource.pg"; @Bean(name = "pgDS") @ConfigurationProperties(prefix =pg) public DataSource dataSource() { return DataSourceBuilder.create().build(); }2、创建pg配置文件,指定SqlSessionFactory以及要扫描的Dao
@Configuration@MapperScan(basePackages = {"com.**.mapper.pg"}, sqlSessionFactoryRef = "sqlSessionFactory")public class PostgresDBConfig { @Autowired @Qualifier("pgDS") private DataSource pgDS; @Bean public SqlSessionFactory sqlSessionFactory() throws Exception { SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean(); factoryBean.setDataSource(pgDS); return factoryBean.getObject(); } @Bean public SqlSessionTemplate sqlSessionTemplate() throws Exception { SqlSessionTemplate template = new SqlSessionTemplate(sqlSessionFactory()); // 使用上面配置的Factory return template; }}3、编写Dao--注解形式
@Repository@Mapperpublic interface StCableFiberMapper { @Select("SELECT * FROM st_cable_fiber WHERE id = #{id}") St_cable_fiber findById(@Param("id") String id);mongo
1、加载mongo配置信息
public abstract class AbstractMongoConfigure { private String host, database, username, password; private int port; // Setter methods go here.. /* * Method that creates MongoDbFactory Common to both of the MongoDb * connections */ public MongoDbFactory mongoDbFactory() throws Exception { ServerAddress serverAddress = new ServerAddress(host, port); List<MongoCredential> mongoCredentialList = new ArrayList<>(); mongoCredentialList.add(MongoCredential.createScramSha1Credential(username, database, password.toCharArray())); return new SimpleMongoDbFactory(new MongoClient(serverAddress,mongoCredentialList), database); } /* * Factory method to create the MongoTemplate */ abstract public MongoTemplate getMongoTemplate() throws Exception;}@Configuration@EnableMongoRepositories(basePackages = {"com.**.mapper.mg"},mongoTemplateRef = "mongoTemplate") @ComponentScan@ConfigurationProperties(prefix = "spring.datasource.mg")public class MongoMasterConfig extends AbstractMongoConfigure{ @Override @Bean("mongoTemplate") public MongoTemplate getMongoTemplate() throws Exception { return new MongoTemplate(mongoDbFactory()); }}编写Dao MongoTemplate模式
@Repositorypublic class CmCableDetailRepo{ @Autowired private MongoTemplate mongoTemplate; public Page<Cm_Cable> findByLevelAndName(String areacode, int level,String name,int pageNum, int pageSize){ PageRequest page = new PageRequest(pageNum, pageSize); Query query = new Query(); Criteria criteria = new Criteria(); criteria.and("areacode").regex("^"+areacode); if(level > -1){ criteria.and("cableSegment_level").is(level); } if(null != name && name.trim().length() > 0){ criteria.and("zh_label").regex(".*?"+name+".*"); } query.addCriteria(criteria); Long count = mongoTemplate.count(query, Cm_Cable.class); List<Cm_Cable> list = mongoTemplate.find(query.with(page), Cm_Cable.class); return new PageImpl<Cm_Cable>(list, page, count); }MongoRepository模式
@Repositorypublic interface CmCableDetailMapper extends MongoRepository<Cm_Cable, String>{}以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
SpringBoot如何快速配置数据源;有如下两种方式:通过spring-boot-starter-jdbc快速配置数据源自定义数据源DataSource首先我
spring-boot是基于spring框架的,它并不是对spring框架的功能增强,而是对spring的一种快速构建的方式。spring-boot应用程序提供
上篇使用docker构建spring-boot应用,是把编译好的jar包构建到镜像中。这篇是把spring-boot连同数据库,做为一组docker服务运行起来
你在使用MyBatis的过程中,是否有想过多个数据源应该如何配置,如何去实现?出于这个好奇心,我在DruidWiki的数据库多数据源中知晓Spring提供了对多
简介redis多数据源主要的运用场景是在需要使用多个redis服务器或者使用多个redis库,本文采用的是fastdep依赖集成框架,快速集成Redis多数据源