Linkis在springBoot 实现分数据源分库分表并且在datasourcerouter里面配置规则实现自动切换
时间: 2024-01-21 08:18:45 浏览: 105
Linkis是一个基于Spring Boot的开源分布式大数据应用平台,它提供了分数据源、分库、分表的支持。在Linkis中,通过在datasourcerouter中配置规则,可以实现自动切换数据源,从而实现对多个数据库的访问。
在Linkis中,需要先在application.yml中配置多个数据源,并在datasourcerouter中配置切换规则。具体步骤如下:
1. 在application.yml中配置多个数据源,如下所示:
```
spring:
datasource:
master:
url: jdbc:mysql://localhost:3306/master?useUnicode=true&characterEncoding=utf-8&useSSL=false
username: root
password: root
slave:
url: jdbc:mysql://localhost:3306/slave?useUnicode=true&characterEncoding=utf-8&useSSL=false
username: root
password: root
```
2. 在datasourcerouter中配置切换规则,如下所示:
```
@Configuration
public class DataSourceConfig {
@Bean(name = "master")
@Primary
@ConfigurationProperties(prefix = "spring.datasource.master")
public DataSource masterDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "slave")
@ConfigurationProperties(prefix = "spring.datasource.slave")
public DataSource slaveDataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "routingDataSource")
public DataSource routingDataSource(@Qualifier("master") DataSource masterDataSource,
@Qualifier("slave") DataSource slaveDataSource) {
Map<Object, Object> targetDataSources = new HashMap<>();
targetDataSources.put("master", masterDataSource);
targetDataSources.put("slave", slaveDataSource);
RoutingDataSource routingDataSource = new RoutingDataSource();
routingDataSource.setDefaultTargetDataSource(masterDataSource);
routingDataSource.setTargetDataSources(targetDataSources);
return routingDataSource;
}
}
```
在routingDataSource方法中,我们将master和slave数据源添加到一个Map中,然后通过RoutingDataSource类实现数据源的自动切换。
3. 在需要访问数据库的地方,使用注解来指定数据源,如下所示:
```
@Service
public class UserServiceImpl implements UserService {
@Autowired
@Qualifier("routingDataSource")
private DataSource dataSource;
@Override
@DataSource("master")
public List<User> getAllUsers() {
// 查询master数据源中的数据
}
@Override
@DataSource("slave")
public List<User> getSlaveAllUsers() {
// 查询slave数据源中的数据
}
}
```
在getAllUsers方法中,我们使用@DataSource("master")注解来指定使用master数据源,而在getSlaveAllUsers方法中,我们使用@DataSource("slave")注解来指定使用slave数据源。
通过以上步骤,我们就可以在Linkis中实现分数据源、分库、分表,并且在datasourcerouter里面配置规则实现自动切换了。
阅读全文