一文搞懂SpringBoot 配置多个数据源玩转多数据库连接

2022-11-27 00:25:36

在SpringBoot中轻松配置多个数据库，释放项目潜能

对于现代软件开发来说，管理和连接多个数据库已成为一种常见需求。SpringBoot，作为Java开发中的强大框架，提供了灵活且高效的方式来实现此目的。本文将详细探讨如何配置SpringBoot以连接多个数据库，助你突破多数据库难题，释放项目的无限潜能。

准备工作

踏上SpringBoot的多数据库之旅之前，你需要准备好以下材料：

一个现有的SpringBoot项目
Java开发环境（如Eclipse或IntelliJ IDEA）
MySQL数据库（或其他支持的数据库）

第一步：引入必要的依赖

在项目中引入必要的依赖，为SpringBoot提供连接和管理多个数据库所需的功能。在pom.xml文件中添加以下依赖项：

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
    <groupId>com.alibaba</groupId>
    <artifactId>druid</artifactId>
    <version>1.2.9</version>
</dependency>

第二步：配置数据源信息

在application.yml配置文件中，你需要为每个数据源配置连接信息。例如，要连接两个MySQL数据库，你的配置可能如下所示：

spring:
  datasource:
    first:
      url: jdbc:mysql://localhost:3306/first_db
      username: root
      password: 123456
    second:
      url: jdbc:mysql://localhost:3306/second_db
      username: root
      password: 123456

第三步：创建实体类

接下来，你需要创建两个实体类，分别代表两个数据库中的表。

@Entity
@Table(name = "first_table")
public class FirstEntity {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    private String name;

    //省略getter和setter方法
}

@Entity
@Table(name = "second_table")
public class SecondEntity {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Long id;

    private String name;

    //省略getter和setter方法
}

第四步：编写Controller

Controller负责处理HTTP请求，并在应用程序中控制数据流。

@RestController
@RequestMapping("/data")
public class DataController {

    @Autowired
    private FirstService firstService;

    @Autowired
    private SecondService secondService;

    @PostMapping("/first")
    public ResponseEntity<String> saveFirst(@RequestBody FirstEntity entity) {
        firstService.save(entity);
        return ResponseEntity.ok("Saved successfully in first database!");
    }

    @PostMapping("/second")
    public ResponseEntity<String> saveSecond(@RequestBody SecondEntity entity) {
        secondService.save(entity);
        return ResponseEntity.ok("Saved successfully in second database!");
    }
}

第五步：实现Service和Mapper

Service层负责业务逻辑，而Mapper层负责与数据库的交互。

public interface FirstService {

    void save(FirstEntity entity);
}

public class FirstServiceImpl implements FirstService {

    @Autowired
    private FirstMapper firstMapper;

    @Override
    public void save(FirstEntity entity) {
        firstMapper.insert(entity);
    }
}

public interface SecondService {

    void save(SecondEntity entity);
}

public class SecondServiceImpl implements SecondService {

    @Autowired
    private SecondMapper secondMapper;

    @Override
    public void save(SecondEntity entity) {
        secondMapper.insert(entity);
    }
}

public interface FirstMapper {

    @Insert("INSERT INTO first_table (name) VALUES (#{name})")
    int insert(FirstEntity entity);
}

public interface SecondMapper {

    @Insert("INSERT INTO second_table (name) VALUES (#{name})")
    int insert(SecondEntity entity);
}