Spring-boot集成pgmongo多数据源

Posted wangziqiang123

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Spring-boot集成pgmongo多数据源相关的知识,希望对你有一定的参考价值。

spring boot集成pg、mongo多数据源

修改POM文件,增加相应Jar包

1
2
3
4
5
6
7
8
9
10
11
12
13
<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>

修改启动类,去除原有的数据源自动加载机制

1
2
3
4
5
6
7
@SpringBootApplication(
exclude = {DataSourceAutoConfiguration.class,
PageHelperAutoConfiguration.class ,
MongoAutoConfiguration.class, MongoDataAutoConfiguration.class//禁用数据源自动配置
})
@EnableEurekaClient
public class MainApplication {、、、

编写application.yml文件,增加配置信息

1
2
3
4
5
6
7
8
9
10
11
12
13
14
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
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
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);

mongo

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
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>{

}

原文:大专栏  Spring-boot集成pg、mongo多数据源


以上是关于Spring-boot集成pgmongo多数据源的主要内容,如果未能解决你的问题,请参考以下文章

在 spring-boot 集成测试中使用 H2 数据库的 JDBC 连接错误

12代i7和i5集成显卡区别

spring-boot 2.0 多模块化项目和EurekaServer的搭建

有没有办法正确集成两个(或更多)Spring-Boot 项目?

spring-boot集成mybatis

spring-boot项目的docker集成化部署