神操作：Spring Cloud多数据源配置指南——轻松玩转数据库

2023-09-03 11:09:03

Spring Cloud 多数据源配置和使用指南

简介

在现代软件开发中，面对复杂的业务场景，连接多个数据库以满足不同需求已成为常态。Spring Cloud 作为一款功能强大的分布式系统框架，提供了便捷的多数据源配置和使用方式，让开发者轻松驾驭多个数据库连接。

一、配置数据源

1. 数据源信息定义

首先，在配置文件中定义各个数据源的信息，包括 URL、用户名和密码。例如，对于一个主数据库和从数据库：

spring.datasource.primary.url=jdbc:mysql://localhost:3306/primary
spring.datasource.primary.username=root
spring.datasource.primary.password=password

spring.datasource.replica.url=jdbc:mysql://localhost:3307/replica
spring.datasource.replica.username=root
spring.datasource.replica.password=password

二、创建数据源配置类

1. 注入数据源信息

创建一个数据源配置类，将配置文件中的数据源信息注入到 DataSource 对象中：

@Configuration
public class DataSourceConfig {

    @Bean
    public DataSource primaryDataSource() {
        return DataSourceBuilder.create()
                .url("jdbc:mysql://localhost:3306/primary")
                .username("root")
                .password("password")
                .build();
    }

    @Bean
    public DataSource replicaDataSource() {
        return DataSourceBuilder.create()
                .url("jdbc:mysql://localhost:3307/replica")
                .username("root")
                .password("password")
                .build();
    }
}

三、使用JdbcTemplate

1. 注入JdbcTemplate

使用 JdbcTemplate 来注入不同的数据源，并在业务逻辑中进行数据库操作：

@Service
public class UserService {

    @Autowired
    private JdbcTemplate primaryJdbcTemplate;

    @Autowired
    private JdbcTemplate replicaJdbcTemplate;

    // ... 业务逻辑
}

2. 执行数据库操作

public List<User> getAllUsers() {
    return primaryJdbcTemplate.query("SELECT * FROM users", new RowMapper<User>() {
        @Override
        public User mapRow(ResultSet rs, int rowNum) throws SQLException {
            // ... 映射结果
        }
    });
}

public User getUserById(Long id) {
    return replicaJdbcTemplate.queryForObject("SELECT * FROM users WHERE id = ?", new Object[] { id }, new RowMapper<User>() {
        @Override
        public User mapRow(ResultSet rs, int rowNum) throws SQLException {
            // ... 映射结果
        }
    });
}