mybatis水平分表实现动态表名的项目实例
作者：先养只猫 发布时间：2023-04-02 22:11:42
标签：mybatis,动态表名
一、水平分表
当业务需求的数据量过大时，一个表格存储数据会非常之多，故时长采用水平分表的方式来减少每张表的数据量即是提升查询数据库时的效率。
水平分表时，各表的结构完全一样，表名不同。
例如：这里我们建了10张user表，每张表的结构完全一致，表名由0~9。
表中包含有id和name属性且都采用varchar的存储类型。
为什么id没有采用int自增的形式？
大型项目极有可能采用分布式数据库，若采用自增的方式，会导致id重复。且id也不一定只是由纯数字组成，id不由数据库自主生成后，可在后台代码中是使用工具类进行id生成。
二、项目实现
目录结构
不需要的文件我已经手动马赛克，避免干扰。
简单以一个用户信息的新增和查询为例子。
pom.xml
本次使用mybatis+mybatis-plus为例。
<!--spring mybatis-->
<dependency>
<groupId>org.mybatis.spring.boot</groupId>
<artifactId>mybatis-spring-boot-starter</artifactId>
<version>2.2.0</version>
</dependency>
<!--mybatis-plus-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.4.3.1</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<scope>runtime</scope>
</dependency>
application.yaml
server:
port: 9090
spring:
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3306/test?serverTimezone=UTC&useUnicode=true&characterEncoding=utf8
username: root
password: root
mybatis-plus:
mapper-locations: classpath:mybatis/*.xml #mapper位置
type-aliases-package: com/example/demo/po #设置别名，类名的小写
工具类
R返回类
package com.example.demo.utils;
import com.example.demo.utils.inter.ResultCode;
import lombok.Data;
import java.util.HashMap;
import java.util.Map;
@Data
public class R<T> {
private Boolean success;
private Integer code;
private String message;
private T data;
public R() {
}
public static <T> R<T> ok(){
R<T> r = new R<>();
r.setSuccess(true);
r.setCode(ResultCode.SUCCESS);
r.setMessage("成功");
return r;
}
public static <T> R<T> error() {
R<T> r = new R<>();
r.setSuccess(false);
r.setCode(ResultCode.ERROR);
r.setMessage("失败");
return r;
}
public R<T> success(Boolean success) {
this.setSuccess(success);
return this;
}
public R<T> message(String message) {
this.setMessage(message);
return this;
}
public R<T> code(Integer code) {
this.setCode(code);
return this;
}
public void setData(T data) {
this.data = data;
}
public R<T> data(T data) {
this.setData(data);
return this;
}
public R<T> setReLoginData() {
Map<String, Integer> resultMap = new HashMap<>();
resultMap.put("code", -100);
this.data((T) resultMap);
return this;
}
public R<T> setErrorCode(Integer errorCode) {
Map<String, Integer> resultMap = new HashMap<>();
resultMap.put("errorCode", errorCode);
this.data((T) resultMap);
return this;
}
}
通过封装的返回类来实现数据的返回，同时可以自定义返回code（各种错误码），便于项目规范即管理。
ResultCode：返回码
package com.example.demo.utils.inter;
public interface ResultCode {
Integer SUCCESS = 2000;
Integer ERROR = 3000;
}
TableNameUtil：根据自己定义的规则获取表名
这里可以通过字符串拼接，实现user_0~user_9的返回。
数据存储规则： id最后一个数字为0即对应user_0，同理9对应user_9。
package com.example.demo.utils;
import org.springframework.stereotype.Component;
@Component
public class TableNameUtil {
public String getUserTableName(String id){
return "user_"+id.substring(id.length()-1);
}
}
IdUtil：根据自己定义的规则生成唯一ID
这里的生成规则是通过UUID+随机0~ 9的数字来实现唯一ID的生成。大型项目一般会有一个专门由于生成唯一序列号的服务器~。
package com.example.demo.utils;
import org.springframework.stereotype.Component;
import java.util.UUID;
@Component
public class IdUtil {
public synchronized String generatorUserId(){
return UUID.randomUUID()+String.valueOf(Math.random()*10);
}
}
实体类
po类（Persistent Object ）
package com.example.demo.po;
import com.baomidou.mybatisplus.annotation.TableId;
import com.baomidou.mybatisplus.annotation.TableName;
import lombok.Data;
import java.io.Serializable;
@Data
@TableName("user_0")//mybatis-plus匹配一张表即可，因为所有表的结构完全一致。
public class User implements Serializable {
@TableId
private String id;
private String name;
}
dto类（Data Transfer Object）
注： 用例比较简单，没有几个参数，实际时新增和查询可能都会封装许多参数。
UserIn： 新增User时用于传递数据，id由后台生成，前端传输数据时就不必存在id字段。
package com.example.demo.po.dto;
import lombok.Data;
@Data
public class UserIn {
private String name;
}
QueryUserId：查询时使用
package com.example.demo.po.dto;
import lombok.Data;
@Data
public class QueryUserId {
private String id;
}
Mapper层
UserMapper
package com.example.demo.mapper;
import com.baomidou.mybatisplus.core.mapper.BaseMapper;
import com.example.demo.po.User;
import org.apache.ibatis.annotations.Mapper;
import org.apache.ibatis.annotations.Param;
@Mapper
public interface UserMapper extends BaseMapper<User> {
//这里只是简单定义了两个接口，本打算写个批量插入的，
//但是这必须要求批量插入时的所有表的id最后一位数字是相同的（即是同一张表），
//这里不符合，因为这里是在插入时随机生成的，就和循环单独插入一样了~
void insertUser(@Param("tableName") String tableName, @Param("user") User user);
User selectUserById(@Param("tableName") String tableName, @Param("id") String id);
}
UserMapper.xml
与UserMapper相绑定，通过@Param指定传参后xml中进行调用时的名称。
动态表名的实现也是通过传参实现的，这里直接传递参数"tableName"让xml进行获取。
注： 这里使用${tableName}而不使用#{tableNaem}是因为在使用#进行预加载时，由于此时未能获取tableName，即无法确定具体的表格，预加载会报错。
不错的博客，详细介绍
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.example.demo.mapper.UserMapper">
<insert id="insertUser" parameterType="com.example.demo.po.User">
insert into ${tableName}(id, name) values (#{user.id}, #{user.name});
</insert>
<select id="selectUserById" parameterType="java.lang.String" resultType="com.example.demo.po.User">
select * from ${tableName} where id = '${id}'
</select>
</mapper>
Service层
package com.example.demo.service;
import com.baomidou.mybatisplus.extension.service.IService;
import com.example.demo.po.User;
public interface UserService extends IService<User> {
void insertUser(User user);
User selectUserById(String id);
}
impl实现类
package com.example.demo.service.impl;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
import com.example.demo.mapper.UserMapper;
import com.example.demo.po.User;
import com.example.demo.service.UserService;
import com.example.demo.utils.IdUtil;
import com.example.demo.utils.TableNameUtil;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
@Service
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements UserService {
@Resource
private IdUtil idUtil;
@Resource
private TableNameUtil tableNameUtil;
@Override
public void insertUser(User user) {
String id = idUtil.generatorUserId();//生成Id
user.setId(id);
String tableName = tableNameUtil.getUserTableName(id);//根据id获取表名
baseMapper.insertUser(tableName,user);
}
@Override
public User selectUserById(String id) {
String tableName = tableNameUtil.getUserTableName(id);
return baseMapper.selectUserById(tableName, id);
}
}
Controller层
package com.example.demo.controller;
import com.example.demo.po.User;
import com.example.demo.po.dto.UserIn;
import com.example.demo.service.UserService;
import com.example.demo.utils.R;
import lombok.extern.slf4j.Slf4j;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;
@Slf4j
@RestController
@RequestMapping("/user")
public class UserController {
@Resource
private UserService userService;
@PostMapping("/insertUser")
public R insertUser(@RequestBody UserIn userIn){
User user = new User();
user.setName(userIn.getName());
userService.insertUser(user);
return R.ok();
}
@GetMapping("/selectUserById")
public R selectUserById(@RequestBody String id){
User user = userService.selectUserById(id);
return R.ok().data(user);
}
}
过程及结果截图展示
通过Apifox调用接口
创建用户User
使用自动生成数据，结果返回成功
…多输入些数据…查看数据库中数据
… id查询用户
测试成功
三、扩展
还可以在xml中通过调用Java方法来实现生成表名的操作，这里就不需要mapper传递tableName参数了，但是需要用于获取tableName的参数。在学习中遇到这种方式，做个记录。
这种方式比较特殊，一般很少使用。
UserMapper新增
void insertUserI(@Param("user") User user);
User selectUserByIdI(@Param("id") String id);
UserMapper.xml新增
<insert id="insertUserI" parameterType="com.example.demo.po.User">
insert into "${@com.example.demo.utils.TableNameUtil@getUserTableName(id)}"(id, name) values (#{user.id}, #{user.name});
</insert>
<select id="selectUserByIdI" parameterType="java.lang.String" resultType="com.example.demo.po.User">
select * from "${@com.example.demo.utils.TableNameUtil@getUserTableName(id)}" where id = '${id}'
</select>
或通过bind标签进行绑定
<insert id="insertUserI" parameterType="com.example.demo.po.User">
<bind name="tableName" value="@com.example.demo.utils.TableNameUtil@getUserTableName(id)"/>
insert into ${tableName}(id, name) values (#{user.id}, #{user.name});
</insert>
<select id="selectUserByIdI" parameterType="java.lang.String" resultType="com.example.demo.po.User">
<bind name="tableName" value="@com.example.demo.utils.TableNameUtil@getUserTableName(id)"/>
select * from ${tableName} where id = '${id}'
</select>
Service层新增
void insertUserI(@Param("user") User user);
User selectUserByIdI(@Param("id") String id);
Controller层新增
@PostMapping("/insertUserI")
public R insertUserI(@RequestBody UserIn userIn){
User user = new User();
user.setName(userIn.getName());
userService.insertUser(user);
log.info("insertUserI OK");
return R.ok();
}
@GetMapping("/selectUserByIdI")
public R selectUserByIdI(@RequestBody QueryUserId queryUserId){
User user = userService.selectUserById(queryUserId.getId());
log.info("selectUserByIdI :"+user.toString());
return R.ok().data(user);
}
过程及结果截图展示
调用insertUserI创建新用户
日志打印
数据库中数据
调用selectUserByIdI进行查询
日志查看
关于xml调用Java方法时是否能获取对应参数
这里在getUserTableName方法下输出了一下id
来源：https://blog.csdn.net/qq_52050769/article/details/125841208
0
投稿猜你喜欢
1、LongAdder由来LongAdder类是JDK1.8新增的一个原子性操作类。AtomicLong通过CAS算法提供了非阻塞的原子性操- 大致分为以下几个方面：一些查询指令整理使用SQL语句进行特殊查询检测表字段是否存在数据库升级数据库表字段赋初始值一、查询指令整理1.链式执行
- springboot集成swagger3swagger3的springboot启动器jar包<!-- https://mvnrepos
- Java xml出现错误 javax.xml.transform.TransformerException: java.lang.NullP
- 最近在开发项目的时候遇到一个问题，在myecilpes上使用googlede gson读取项目中的json文件成功，然后把项目发布到tomc
- maven没有打包xml文件的问题最近使用maven带管理项目，采用SSM的技术栈，在配置好一些配置文件，打包部署到tomcat上，出现没有
- 我们知道HashMap集合是允许存放null值的hashMap是根据key的hashCode来寻找存放位置的，那当key为null时， 怎么
- flutter material widget组件之信息展示组件，供大家参考，具体内容如下widget分为两类：widgets librar
- 复合语句Java的复合语句是以整个区块为单位的语句，由{}以及{}内包含的内容组成对于复合语句来说，复合语句创建了一个局部变量的作用域，该作
- 详解Java注解的实现与使用方法Java注解是java5版本发布的，其作用就是节省配置文件，增强代码可读性。在如今各种框架及开发中非常常见，
- Java读文件修改默认换行符Java默认换行符是'\n'。但有时数据并不以'\n'进行换行方法如下publi
- 最近碰到个需求，是希望在Unity有一个按钮，打开后直接跳转淘宝app，打开商品页面。百度了下没有相关的文章，于是我在此分享下。之前开发游戏
- 1、前言当提及如何终止一个线程时，部分读者通常立马想到的方法肯定是stop()，但是stop()方法并不被推荐使用（很多规范中是禁止使用的）
- Rmb.javapublic class Rmb { /** *人民币的基本信息和操作 *@auth
- 双保险线程，每次启动2个相同的线程，互相检测，避免线程死锁造成影响。两个线程都运行，但只有一个线程执行业务，但都会检测对方的时间戳 如果时间
- 引言ShardingSphere的SQL解析，本篇文章源码基于4.0.1版本ShardingSphere的分片引擎从解析引擎到路由引擎到改写
- 通过本篇文章主要给大家讲解了在JAVA开发中Servlet3.0异步处理遇到的问题以及处理办法，以下是具体内容：Servlet 3.0 开始
- 目录Sonar概述一、 搭建sona服务二、idea配置三、 配置maven的setting.xml文件四、idea中 mvn sonar:
- spring cloud gateway获取请求的真实地址在使用spring cloud gateway的时候，路由一般配置为服务名例如 l
- 本文实例讲述了java实现单词搜索迷宫游戏。分享给大家供大家参考。具体分析如下：我们在杂志上，经常能够看到找单词的小游戏，在一个二维表格中，
