springboot mybatis druid多数据源
时间: 2023-05-08 08:58:43 浏览: 190
Spring Boot是一种快速开发应用程序的框架。它结合了多种技术,包括Spring Framework、Hibernate、MyBatis和其他流行工具,使其极其方便快速地创建和部署Web应用程序。
MyBatis是一种流行的Java持久性框架,它用于将Java对象映射到关系型数据库中。在Spring Boot中使用MyBatis,可以轻松访问数据库,并在应用程序中使用对象关系映射器(ORM)实现数据的持久化。
Druid是一个高性能的、支持分布式数据存储的数据库连接池。它能够管理数据库连接池,并监控连接,以保证数据访问安全和效率。
在Spring Boot中使用多数据源,可以提高应用程序的性能和可扩展性。通过配置多个数据源,并使用Druid作为连接池,可以将访问不同数据源的操作分别交给不同的线程处理,从而提高程序的并发性。
同时,使用MyBatis对不同数据源进行数据访问和持久化,可以方便地实现数据的读写分离和数据分区等高级功能,提高应用程序的数据处理能力。
总之,结合Spring Boot、MyBatis和Druid,可以轻松构建高性能、可扩展的多数据源应用程序,适用于各种大规模企业应用、互联网应用等场景。
相关问题
springboot mybatis plus 多数据源
以下是使用Spring Boot和MyBatis Plus实现多数据源的最简解决方案:
1.在pom.xml文件中添加MyBatis Plus和Druid的依赖:
```xml
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.3.1</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid-spring-boot-starter</artifactId>
<version>1.2.6</version>
</dependency>
```
2.在application.yml文件中配置数据源:
```yaml
spring:
datasource:
master:
url: jdbc:mysql://localhost:3306/db1?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
username: root
password: root
driver-class-name: com.mysql.cj.jdbc.Driver
slave:
url: jdbc:mysql://localhost:3306/db2?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT%2B8
username: root
password: root
driver-class-name: com.mysql.cj.jdbc.Driver
```
3.创建数据源配置类:
```java
@Configuration
@MapperScan(basePackages = "com.example.demo.mapper")
public class DataSourceConfig {
@Bean
@ConfigurationProperties(prefix = "spring.datasource.master")
public DataSource masterDataSource() {
return DruidDataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties(prefix = "spring.datasource.slave")
public DataSource slaveDataSource() {
return DruidDataSourceBuilder.create().build();
}
@Bean
public DynamicDataSource dynamicDataSource(@Qualifier("masterDataSource") DataSource masterDataSource,
@Qualifier("slaveDataSource") DataSource slaveDataSource) {
Map<Object, Object> targetDataSources = new HashMap<>();
targetDataSources.put(DataSourceType.MASTER, masterDataSource);
targetDataSources.put(DataSourceType.SLAVE, slaveDataSource);
return new DynamicDataSource(masterDataSource, targetDataSources);
}
@Bean
public SqlSessionFactory sqlSessionFactory(DynamicDataSource dynamicDataSource) throws Exception {
MybatisSqlSessionFactoryBean sqlSessionFactory = new MybatisSqlSessionFactoryBean();
sqlSessionFactory.setDataSource(dynamicDataSource);
sqlSessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath*:mapper/*.xml"));
return sqlSessionFactory.getObject();
}
@Bean
public SqlSessionTemplate sqlSessionTemplate(SqlSessionFactory sqlSessionFactory) {
return new SqlSessionTemplate(sqlSessionFactory);
}
}
```
4.创建数据源类型枚举类:
```java
public enum DataSourceType {
MASTER,
SLAVE
}
```
5.创建动态数据源类:
```java
public class DynamicDataSource extends AbstractRoutingDataSource {
private static final ThreadLocal<DataSourceType> contextHolder = new ThreadLocal<>();
public DynamicDataSource(DataSource defaultTargetDataSource, Map<Object, Object> targetDataSources) {
super.setDefaultTargetDataSource(defaultTargetDataSource);
super.setTargetDataSources(targetDataSources);
super.afterPropertiesSet();
}
@Override
protected Object determineCurrentLookupKey() {
return contextHolder.get();
}
public static void setDataSourceType(DataSourceType dataSourceType) {
contextHolder.set(dataSourceType);
}
public static void clearDataSourceType() {
contextHolder.remove();
}
}
```
6.创建数据源切换注解:
```java
@Retention(RetentionPolicy.RUNTIME)
@Target({ElementType.METHOD})
public @interface DataSource {
DataSourceType value() default DataSourceType.MASTER;
}
```
7.创建数据源切换切面:
```java
@Aspect
@Component
public class DataSourceAspect {
@Pointcut("@annotation(com.example.demo.annotation.DataSource)")
public void dataSourcePointCut() {
}
@Before("dataSourcePointCut()")
public void before(JoinPoint joinPoint) {
MethodSignature signature = (MethodSignature) joinPoint.getSignature();
DataSource dataSource = signature.getMethod().getAnnotation(DataSource.class);
if (dataSource != null) {
DynamicDataSource.setDataSourceType(dataSource.value());
}
}
@After("dataSourcePointCut()")
public void after(JoinPoint joinPoint) {
DynamicDataSource.clearDataSourceType();
}
}
```
8.在Mapper接口中使用@DataSource注解指定数据源:
```java
@DataSource(DataSourceType.MASTER)
List<User> selectAllUsers();
@DataSource(DataSourceType.SLAVE)
List<User> selectAllUsersFromSlave();
```
9.最后,启动Spring Boot应用程序并测试多数据源是否正常工作。
--相关问题--:
1. Spring Boot如何集成MyBatis Plus?
2. 如何在Spring Boot中配置
springboot mybatis实现多数据源
SpringBoot Mybatis实现多数据源可以通过以下步骤来实现:
1. 在配置文件中,分别配置各个数据源的相关信息,包括驱动类、用户名、密码、JDBC URL等。
2. 创建多个数据源对应的数据库连接池,如使用HikariCP或Druid。
3. 创建一个继承自AbstractRoutingDataSource的类,重写determineCurrentLookupKey方法,根据具体的业务逻辑来动态切换数据源。
4. 配置SqlSessionFactoryBean,将数据源设置为AbstractRoutingDataSource,这样在执行数据库操作时,会根据具体的业务需求来选择不同的数据源。
5. 在需要使用不同数据源的地方,使用@Qualifier注解来指定具体的数据源。
阅读全文