mybatis水平分表實現(xiàn)動態(tài)表名的項目實例
一、水平分表
- 當業(yè)務需求的數(shù)據(jù)量過大時,一個表格存儲數(shù)據(jù)會非常之多,故時長采用水平分表的方式來減少每張表的數(shù)據(jù)量即是提升查詢數(shù)據(jù)庫時的效率。
- 水平分表時,各表的結構完全一樣,表名不同。
- 例如:這里我們建了10張user表,每張表的結構完全一致,表名由0~9。
- 表中包含有id和name屬性且都采用varchar的存儲類型。
- 為什么id沒有采用int自增的形式?
- 大型項目極有可能采用分布式數(shù)據(jù)庫,若采用自增的方式,會導致id重復。且id也不一定只是由純數(shù)字組成,id不由數(shù)據(jù)庫自主生成后,可在后臺代碼中是使用工具類進行id生成。
二、項目實現(xiàn)
目錄結構
不需要的文件我已經(jīng)手動馬賽克,避免干擾。
簡單以一個用戶信息的新增和查詢為例子。
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; } }
通過封裝的返回類來實現(xiàn)數(shù)據(jù)的返回,同時可以自定義返回code(各種錯誤碼),便于項目規(guī)范即管理。
ResultCode:返回碼
package com.example.demo.utils.inter; public interface ResultCode { Integer SUCCESS = 2000; Integer ERROR = 3000; }
TableNameUtil:根據(jù)自己定義的規(guī)則獲取表名
這里可以通過字符串拼接,實現(xiàn)user_0~user_9的返回。
數(shù)據(jù)存儲規(guī)則: id最后一個數(shù)字為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:根據(jù)自己定義的規(guī)則生成唯一ID
這里的生成規(guī)則是通過UUID+隨機0~ 9的數(shù)字來實現(xiàn)唯一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)
注: 用例比較簡單,沒有幾個參數(shù),實際時新增和查詢可能都會封裝許多參數(shù)。
UserIn: 新增User時用于傳遞數(shù)據(jù),id由后臺生成,前端傳輸數(shù)據(jù)時就不必存在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最后一位數(shù)字是相同的(即是同一張表), //這里不符合,因為這里是在插入時隨機生成的,就和循環(huán)單獨插入一樣了~ 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中進行調用時的名稱。
動態(tài)表名的實現(xiàn)也是通過傳參實現(xiàn)的,這里直接傳遞參數(shù)"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實現(xiàn)類
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);//根據(jù)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調用接口
創(chuàng)建用戶User
使用自動生成數(shù)據(jù),結果返回成功
…多輸入些數(shù)據(jù)…查看數(shù)據(jù)庫中數(shù)據(jù)
… id查詢用戶
測試成功
三、擴展
還可以在xml中通過調用Java方法來實現(xiàn)生成表名的操作,這里就不需要mapper傳遞tableName參數(shù)了,但是需要用于獲取tableName的參數(shù)。在學習中遇到這種方式,做個記錄。
這種方式比較特殊,一般很少使用。
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創(chuàng)建新用戶
日志打印
數(shù)據(jù)庫中數(shù)據(jù)
調用selectUserByIdI進行查詢
日志查看
關于xml調用Java方法時是否能獲取對應參數(shù)
這里在getUserTableName方法下輸出了一下id
到此這篇關于mybatis水平分表實現(xiàn)動態(tài)表名的項目實例的文章就介紹到這了,更多相關mybatis 動態(tài)表名內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!
相關文章
Spring RestTemplate簡化HTTP通信實現(xiàn)功能探究
這篇文章主要為大家介紹了Spring框架中的RestTemplate,如果你是個Java程序員,那么你肯定知道Spring框架的重要性,在Spring的眾多工具中,RestTemplate是用來簡化HTTP通信的一個強大工具2024-01-01MyBatis Plus之實現(xiàn)動態(tài)排序方式
這篇文章主要介紹了MyBatis Plus之實現(xiàn)動態(tài)排序方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教2024-02-02springboot整合mybatis-plus逆向工程的實現(xiàn)
這篇文章主要介紹了springboot整合mybatis-plus逆向工程的實現(xiàn),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧2020-08-08java使用google身份驗證器實現(xiàn)動態(tài)口令驗證的示例
本篇文章主要介紹了java使用google身份驗證器實現(xiàn)動態(tài)口令驗證的示例,具有一定的參考價值,有興趣的可以了解一下2017-08-08