SpringBoot中動態(tài)數(shù)據(jù)源是實現(xiàn)與用途

更新時間：2023年08月13日 08:35:44 作者：vker

這篇文章主要是來和大家討論一下SpringBoot中動態(tài)數(shù)據(jù)源是實現(xiàn)與用途，文中的示例代碼簡潔易懂，具有一定的學習價值，感興趣的可以了解一下

1、技術(shù)棧
2、Maven 依賴
3、數(shù)據(jù)庫結(jié)構(gòu)
4、application.yml 配置文件
5、定義一個 DataSources 注解
6、配置一下動態(tài)數(shù)據(jù)源
7、寫一個基于 DataSources 注解的動態(tài)代理
8、再來寫一個讀數(shù)據(jù)庫配置信息的配置類

業(yè)務層代碼

1、實體類
2、Dao 數(shù)據(jù)層
3、Service 服務層
4、Controller 控制層
5、最后來看一下啟動類
6、測試結(jié)果

一、應用場景

主從復制
讀寫分離
分庫分表

主從復制與讀寫分離通常是一起使用的。

二、實現(xiàn)方式

1、技術(shù)棧

SpringBoot 2.6.13
Druid 1.2.16
Spring JDBC
MySQL 8.0
AOP動態(tài)代理

2、Maven 依賴

下邊依賴放入同一個pom.xml文件就可以

<properties>
    <java.version>11</java.version>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    <spring-boot.version>2.6.13</spring-boot.version>
</properties>
<dependencies>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-jdbc</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-aop</artifactId>
    </dependency>
    <dependency>
        <groupId>com.mysql</groupId>
        <artifactId>mysql-connector-j</artifactId>
        <scope>runtime</scope>
    </dependency>
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid-spring-boot-starter</artifactId>
        <version>1.2.16</version>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>
<dependencyManagement>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-dependencies</artifactId>
            <version>${spring-boot.version}</version>
            <type>pom</type>
            <scope>import</scope>
        </dependency>
    </dependencies>
</dependencyManagement>

3、數(shù)據(jù)庫結(jié)構(gòu)

數(shù)據(jù)庫結(jié)構(gòu)非常簡單，主要實現(xiàn)思想，復雜的都是同一個操作方式。

（1）數(shù)據(jù)庫：db_dynamic1

DROP TABLE IF EXISTS `tb_user`;
CREATE TABLE `tb_user` (
  `id` bigint NOT NULL AUTO_INCREMENT,
  `username` varchar(50) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
BEGIN;
INSERT INTO `tb_user` (`id`, `username`) VALUES (1, '張三');
INSERT INTO `tb_user` (`id`, `username`) VALUES (2, '李四');
INSERT INTO `tb_user` (`id`, `username`) VALUES (3, '王五');
COMMIT;
SET FOREIGN_KEY_CHECKS = 1;

（2）數(shù)據(jù)庫：db_dynamic2

DROP TABLE IF EXISTS `tb_user`;
CREATE TABLE `tb_user` (
  `id` int NOT NULL AUTO_INCREMENT,
  `username` varchar(50) CHARACTER SET utf8mb4 COLLATE utf8mb4_0900_ai_ci DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=4 DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
BEGIN;
INSERT INTO `tb_user` (`id`, `username`) VALUES (1, 'Vker');
INSERT INTO `tb_user` (`id`, `username`) VALUES (2, 'Jack');
INSERT INTO `tb_user` (`id`, `username`) VALUES (3, 'Lucy');
COMMIT;
SET FOREIGN_KEY_CHECKS = 1;

4、application.yml 配置文件

將下面配置文件的url, username, password換成你自己的

spring:
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    druid:
      master:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://127.0.0.1:3306/db_dynamic1?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&useSSL=false
        username: root
        password: root_root
      slave:
        driver-class-name: com.mysql.cj.jdbc.Driver
        url: jdbc:mysql://127.0.0.1:3306/db_dynamic2?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF8&useSSL=false
        username: root
        password: root_root
      initial-size: 1
      min-idle: 1
      max-active: 20
      test-on-borrow: true

5、定義一個 DataSources 注解

這個注解主要用于多數(shù)據(jù)源的選擇，默認是 master

@Target({ElementType.METHOD, ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
public @interface DataSources {
    String value() default "master";
}

6、配置一下動態(tài)數(shù)據(jù)源

這個類主要用于配置多數(shù)據(jù)源，不要忘記@Primary注解，否則會報錯。

@Component
@Primary
public class DynamicDataSources extends AbstractRoutingDataSource {
    public static ThreadLocal<String> name = new ThreadLocal<>();
    @Resource
    DataSource master;
    @Resource
    DataSource slave;
    @Override
    protected Object determineCurrentLookupKey() {
        return name.get();
    }
    @Override
    public void afterPropertiesSet() {
        Map<Object, Object> ds = new HashMap<>();
        ds.put("master", master);
        ds.put("slave", slave);
        super.setTargetDataSources(ds);
        super.setDefaultTargetDataSource(master);
        super.afterPropertiesSet();
    }
}

7、寫一個基于 DataSources 注解的動態(tài)代理

這個動態(tài)代理用于檢查類或者方法上的@DataSources注解，取到注解中的value值，將值傳入動態(tài)數(shù)據(jù)源配置類DynamicDataSources的ThreadLocal中，用于選擇數(shù)據(jù)源。

@Component
@Aspect
public class DynamicDataSourcesAspect {
    Logger logger = LoggerFactory.getLogger(DynamicDataSourcesAspect.class);
    @Before("@annotation(dataSources)")
    public void before(DataSources dataSources) {
        String value = dataSources.value();
        DynamicDataSources.name.set(value);
        logger.info("進入AOP代理: {}", value);
    }
}

8、再來寫一個讀數(shù)據(jù)庫配置信息的配置類

這個配置類主要將application.yml中的數(shù)據(jù)庫配置信息的配置信息進行加載，然后使用數(shù)據(jù)源事務管理器DataSourceTransactionManager進行注冊。

@Configuration
public class DynamicDataSourcesConfig {
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.druid.master")
    public DataSource master() {
        return DruidDataSourceBuilder.create().build();
    }
    @Bean
    @ConfigurationProperties(prefix = "spring.datasource.druid.slave")
    public DataSource slave() {
        return DruidDataSourceBuilder.create().build();
    }
    @Bean
    public DataSourceTransactionManager dataSourceTransactionManager1(@Qualifier("master") DataSource master) {
        DataSourceTransactionManager dataSourceTransactionManager =
                new DataSourceTransactionManager();
        dataSourceTransactionManager.setDataSource(master);
        return dataSourceTransactionManager;
    }
    @Bean
    public DataSourceTransactionManager dataSourceTransactionManager2(@Qualifier("slave") DataSource slave) {
        DataSourceTransactionManager dataSourceTransactionManager =
                new DataSourceTransactionManager();
        dataSourceTransactionManager.setDataSource(slave);
        return dataSourceTransactionManager;
    }
}

重點的都做完了，接下來就寫一下基本的業(yè)務層代碼吧，注釋就不寫了，我相信小伙伴們都能看懂。

業(yè)務層代碼

1、實體類

public class User {
    private Long id;
    private String username;
   // 省略了 getter setter
}

2、Dao 數(shù)據(jù)層

public interface UserMapper {
    List<User> selectAllUser();
}

@Repository
public class UserMapperImpl implements UserMapper {
    @Resource
    private JdbcTemplate jdbcTemplate;
    @Override
    public List<User> selectAllUser() {
        String sql = "select * from tb_user";
        return jdbcTemplate.query(sql,
                new BeanPropertyRowMapper<>(User.class));
    }
}

3、Service 服務層

public interface UserService {
    List<User> list();
}

@Service
public class UserServiceImpl implements UserService {
    @Resource
    private UserMapper userMapper;
    @Override
    public List<User> list() {
        return userMapper.selectAllUser();
    }
}

4、Controller 控制層

這里說一下，你可以將注解 @DataSources 注解放到你想使用不同數(shù)據(jù)源的方法上，如下，默認 master 可以不寫。

@RestController
public class UserController {
    @Resource
    private UserService userService;
    @GetMapping("list1")
    public List<User> list1() {
        return userService.list();
    }
    @GetMapping("list2")
    @DataSources("slave")
    public List<User> lis2t() {
        return userService.list();
    }
}

5、最后來看一下啟動類

需要把 DataSourceAutoConfiguration 排除掉哦

@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class})
public class DynamicDatasourceDemoApplication {
    public static void main(String[] args) {
        SpringApplication.run(DynamicDatasourceDemoApplication.class, args);
    }
}

6、測試結(jié)果

list1接口

list2接口

好了，以上就是動態(tài)數(shù)據(jù)源的實現(xiàn)方式了，歡迎小伙伴們留言，下期我們看看，如何實現(xiàn)主從復制和讀寫分離。

以上就是SpringBoot中動態(tài)數(shù)據(jù)源是實現(xiàn)與用途的詳細內(nèi)容，更多關(guān)于SpringBoot動態(tài)數(shù)據(jù)源的資料請關(guān)注腳本之家其它相關(guān)文章！

您可能感興趣的文章:

亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

SpringBoot中動態(tài)數(shù)據(jù)源是實現(xiàn)與用途

目錄

一、應用場景

二、實現(xiàn)方式

1、技術(shù)棧

2、Maven 依賴

3、數(shù)據(jù)庫結(jié)構(gòu)

4、application.yml 配置文件

5、定義一個 DataSources 注解

6、配置一下動態(tài)數(shù)據(jù)源

7、寫一個基于 DataSources 注解的動態(tài)代理

8、再來寫一個讀數(shù)據(jù)庫配置信息的配置類

業(yè)務層代碼

1、實體類

2、Dao 數(shù)據(jù)層

3、Service 服務層

4、Controller 控制層

5、最后來看一下啟動類

6、測試結(jié)果

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

SpringBoot中動態(tài)數(shù)據(jù)源是實現(xiàn)與用途

目錄

一、應用場景

二、實現(xiàn)方式

1、技術(shù)棧

2、Maven 依賴

3、數(shù)據(jù)庫結(jié)構(gòu)

4、application.yml 配置文件

5、定義一個 DataSources 注解

6、配置一下動態(tài)數(shù)據(jù)源

7、寫一個基于 DataSources 注解的動態(tài)代理

8、再來寫一個讀數(shù)據(jù)庫配置信息的配置類

業(yè)務層代碼

1、實體類

2、Dao 數(shù)據(jù)層

3、Service 服務層

4、Controller 控制層

5、最后來看一下啟動類

6、測試結(jié)果

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

一、應用場景

二、實現(xiàn)方式

1、技術(shù)棧

2、Maven 依賴

3、數(shù)據(jù)庫結(jié)構(gòu)

4、application.yml 配置文件

6、配置一下動態(tài)數(shù)據(jù)源

7、寫一個基于 DataSources 注解的動態(tài)代理

1、實體類

3、Service 服務層

4、Controller 控制層

6、測試結(jié)果