这篇文章主要介绍了Spring-boot集成pg、mongo多数据源过程详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
这篇文章主要介绍了Spring-boot集成pg、mongo多数据源过程详解,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
org.springframework.bootspring-boot-starter-data-mongodborg.postgresqlpostgresqlruntimeorg.springframework.bootspring-boot-starter-jdbc
@SpringBootApplication( exclude = {DataSourceAutoConfiguration.class, pageHelperAutoConfiguration.class , MongoAutoConfiguration.class, MongoDataAutoConfiguration.class//禁用数据源自动配置 }) @EnableEurekaClient public class MainApplication {、、、
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的数据源以及使用样例
pg1、手动加载数据源@Configuration public 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 @Mapper public interface StCableFiberMapper { @Select("SELECT * FROM st_cable_fiber WHERE id = #{id}") St_cable_fiber findById(@Param("id") String id);mongo1、加载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 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模式@Repository public class CmCableDetailRepo{ @Autowired private MongoTemplate mongoTemplate; public Page 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 list = mongoTemplate.find(query.with(page), Cm_Cable.class); return new PageImpl(list, page, count); }MongoRepository模式@Repository public interface CmCableDetailMapper extends MongoRepository{ }以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持编程之家。
