Spring-boot集成pgmongo多数据源

<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//禁用数据源自动配置
        })
@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

1、手动加载数据源
@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);

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()); 
	}

}
2.1、编写Dao  MongoTemplate模式

@Repository
public 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);
	}

2.2、MongoRepository模式
@Repository
public interface CmCableDetailMapper extends MongoRepository<Cm_Cable, String>{

}