mybatisplus的横向分表应该怎么操作

MyBatis-Plus 的分表插件是通过拦截器实现的，通过对 SQL 进行解析，自动判断是否需要进行分表，然后动态生成对应的 SQL。横向分表指的是将一个大表按照某个字段进行水平拆分成多个小表，将数据均分到这些小表中，从而提高数据访问效率。

MyBatis-Plus 的分表插件支持多种分表策略，包括固定分表策略、哈希分表策略和日期范围分表策略等。其中，哈希分表策略是最常用的分表策略之一。

具体操作步骤如下：

1. 在数据库中创建多个相同结构的表，表名可以按照一定规则命名，例如 user_0、user_1、user_2 等。

2. 在 MyBatis-Plus 的配置文件中添加分表插件：

<plugins>
    <plugin interceptor="com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor">
        <property name="sqlParser" ref="mybatis-plus-pagination-sql-parser"/>
    </plugin>
    <plugin interceptor="com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor">
        <property name="interceptors">
            <array>
                <bean class="com.baomidou.mybatisplus.extension.plugins.inner.DynamicTableNameInnerInterceptor">
                    <property name="tableNameHandler" ref="myTableNameHandler"/>
                </bean>
            </array>
        </property>
    </plugin>
</plugins>

3. 实现自定义的分表策略：

@Component("myTableNameHandler")
public class MyTableNameHandler implements TableNameHandler {

    @Override
    public String dynamicTableName(TableInfo tableInfo, String sql, Object param) {
        // 获取分表字段的值
        Long userId = getShardingValue(param);
        // 计算分表后缀
        int tableIndex = (int) (userId % 3);
        // 返回分表名
        return tableInfo.getTableName() + "_" + tableIndex;
    }

    private Long getShardingValue(Object param) {
        // 从参数中获取分表字段的值
        if (param instanceof Long) {
            return (Long) param;
        } else if (param instanceof Map) {
            Map<String, Object> paramMap = (Map<String, Object>) param;
            return (Long) paramMap.get("userId");
        } else {
            throw new RuntimeException("Unsupported sharding type: " + param.getClass());
        }
    }

}

4. 在 Mapper 接口中定义动态 SQL，使用 `@SqlParser(filter = true)` 注解标记不需要分表的 SQL：

public interface UserMapper extends BaseMapper<User> {

    @SqlParser(filter = true)
    @Select("SELECT COUNT(*) FROM user")
    int countAll();

    @Select("SELECT * FROM user WHERE id = #{id}")
    User selectById(Long id);

    @Select("SELECT * FROM user WHERE user_id = #{userId}")
    List<User> selectByUserId(Long userId);

}