Springboot 使用MyCat实现MySQL分库分表

首先，让我们回顾一下什么是MySQL分库分表。MySQL分库分表是将大型数据库按照一定的规则进行分割成多个小型的数据库或者表，以达到减轻单个数据库或表的压力的目的，提高系统的性能和可扩展性。

在本篇博客中，我们将使用Spring Boot和Mycat来实现MySQL分库分表。Mycat是一个开源的MySQL数据库分布式集群中间件，它可以将一台MySQL数据库分成多个MySQL数据库，并且支持水平和垂直分表。

好的，下面是一个简单的 Spring Boot 项目，演示如何使用 Mycat 实现 MySQL 分库分表：

1. 首先，在 pom.xml 中添加 Mycat 和 MySQL 驱动依赖：

<dependencies>
    <dependency>
        <groupId>org.mycat</groupId>
        <artifactId>mycat-client</artifactId>
        <version>1.6.7.3</version>
    </dependency>
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>8.0.27</version>
    </dependency>
</dependencies>

2. 创建 Mycat 数据库连接配置文件 mycat.yaml，并放置在 resources 目录下：

mycat:
  servers:
    - address: localhost:8066
      username: mycat
      password: mycat
  schema: test
  dataSources:
    - name: ds0
      url: jdbc:mysql://localhost:3306/db0
      username: root
      password: root
    - name: ds1
      url: jdbc:mysql://localhost:3306/db1
      username: root
      password: root
  rule:
    - tables:
        - user
      dataNodes: ds0, ds1
      ruleAlgorithm: crc32
      ruleColumns: id
      ruleType: partition

其中，mycat.servers 配置 Mycat 服务器的地址、用户名和密码；mycat.schema 配置默认的数据库名；mycat.dataSources 配置数据源的信息；mycat.rule 配置分片规则，这里将 user 表按照 id 字段进行分库分表，使用 CRC32 算法。

3. 在 Spring Boot 应用程序中使用 Mycat 数据源：

@Configuration
public class DataSourceConfig {

    @Bean
    public DataSource dataSource() {
        MycatDataSource dataSource = new MycatDataSource();
        dataSource.setJdbcUrl("jdbc:mysql://localhost:8066/test");
        dataSource.setUser("mycat");
        dataSource.setPassword("mycat");
        return dataSource;
    }
}

4. 创建一个 User 实体类，用于映射 user 表：

@Entity
@Table(name = "user")
public class User {

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

    private String name;

    private Integer age;

    // 省略 getter 和 setter
}

5. 创建一个 UserRepository 接口，继承自 JpaRepository，用于操作 User 实体：

public interface UserRepository extends JpaRepository<User, Long> {
}

6. 在 application.yml 中配置 Hibernate 的 JPA 属性，启用自动建表和更新模式：

spring:
    jpa:
	    hibernate:
	    	ddl-auto: create-update

7. 在 Spring Boot 应用程序中，使用 UserRepository 接口进行 CRUD 操作：

@RestController
@RequestMapping("/users")
public class UserController {

    @Autowired
    private UserRepository userRepository;

    @PostMapping
    public User createUser(@RequestBody User user) {
        return userRepository.save(user);
    }

    @GetMapping("/{id}")
    public User getUserById(@PathVariable Long id) {
        return userRepository.findById(id).orElse(null);
    }

    @GetMapping
    public List<User> getAllUsers() {
    return userRepository.findAll();
	}

	@PutMapping("/{id}")
	public User updateUser(@PathVariable Long id, @RequestBody User user) {
	    user.setId(id);
	    return userRepository.save(user);
	}
	
	@DeleteMapping("/{id}")
	public void deleteUser(@PathVariable Long id) {
	    userRepository.deleteById(id);
	}

现在，你可以启动这个 Spring Boot 应用程序，创建、读取、更新和删除 User 实体了。

需要注意的是，使用 Mycat 分库分表后，所有操作都将由 Mycat 中转，并发性能会受到影响。因此，需要根据实际情况进行性能测试和优化。另外，Mycat 官方在 2021 年停止维护，建议使用其他分库分表解决方案。