Spring Boot:实现MyBatis动态创建表

这篇具有很好参考价值的文章主要介绍了Spring Boot:实现MyBatis动态创建表。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

在有些应用场景中,我们会有需要动态创建和操作表的需求。

比如因为单表数据存储量太大而采取分表存储的情况,又或者是按日期生成日志表存储系统日志等等。这个时候就需要我们动态的生成和操作数据库表了。

而我们都知道,以往我们使用MyBatis是需要提前生成包括Model,Mapper和XML映射文件的,显然因为动态生成和操作表的需求一开始表都是不存在的,所以也就不能直接通过MyBatis连接数据库来生成我们的数据访问层代码并用来访问数据库了。

MyBatis提供了动态SQL,我们可以通过动态SQL,传入表名等信息然组装成建表和操作语句。

本小节中实现的案例中每个用户都会有一个自己日志表,我们的设计 思路就是在新创建用户的时候,根据用户的信息 创建一个日志存储表,表名是根据用户的 id 来创建,首先是控制中新增用户:

@Controller
@RequestMapping("/user")
public class UserController {
    @Autowired
    private IUserService userService;
    @PostMapping(value="/add")
    public Object addUser(@RequestBody User user) {
        return userService.addUser(user);
    }
}

然后用户的操作IUserService实现定义如下:

@Service("userService")
public class UserServiceImpl extends ServiceImpl<UserMapper, User> implements IUserService {@Resource
    private UserMapper userMapper;
    @Resource
    private UserLogMapper userLogMapper;@Override
    @Transactional
    public User addUser(User user) {
        // 插入
        userMapper.saveUser(user);
        // 添加用户时,创建日志存储表
        Integer id = user.getId();
        //定义用户日志表表名
        String tableName = "t_user_log_" + id;
        //查询表是否存在
        if (userLogMapper.existTable(tableName) > 0) {
            //删除用户对应的日志表
            userLogMapper.dropTable(tableName);
        }
        //新创建表
        userLogMapper.createTable(tableName);
        return user;
    }
}

UserMapper 就是操作用户数据相关的,这里使用的是新增用户的数据:

@Mapper
public interface UserMapper extends BaseMapper<User> {
    int saveUser(@Param("user") User user);
}

对应的xml

<?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="flutter.dio.model.mapper.UserMapper">
    <insert id="saveUser"  useGeneratedKeys="true" keyProperty="id">
        insert into t_user(name,password,age)
        values(#{user.name},#{user.password},#{user.age})
    </insert>
</mapper>

用户新建成功后,再根据用户的id定义表名,然后创建新的日志表:

UserLogMapper 是用户日志操作使用Mapper ,定义如下:

public interface UserLogMapper {
    //保存用户的日志 
    int insert(@Param("tableName")String tableName, @Param("userLog") UserLog userLog);
    /**
     * 查找用户全部的日志
     * @param tableName 用户对应的表名
     * @return
     */
    List<UserLog> selectAll(@Param("tableName")String tableName);/**
     * 是否存在表
     * @param tableName
     * @return
     */
    int existTable(@Param("tableName")String tableName);
    /**
     * 删除表
     * @param tableName
     * @return
     */
    int dropTable(@Param("tableName")String tableName);
    /**
     * 创建表
     * @param tableName
     * @return
     */
    int createTable(@Param("tableName")String tableName);
}

UserLogMapper对应的xml核心内容如下:

<?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="flutter.dio.model.mapper.UserLogMapper">
    <resultMap id="BaseResultMap" type="flutter.dio.model.entity.UserLog">
        <id column="id" jdbcType="BIGINT" property="id"/>
        <result column="user_name" jdbcType="VARCHAR" property="userName"/>
        <result column="operation" jdbcType="VARCHAR" property="operation"/>
        <result column="method" jdbcType="VARCHAR" property="method"/>
        <result column="params" jdbcType="VARCHAR" property="params"/>
        <result column="time" jdbcType="BIGINT" property="time"/>
        <result column="ip" jdbcType="VARCHAR" property="ip"/>
    </resultMap>
    <sql id="Base_Column_List">
        id, user_name, operation, method, params, time, ip
    </sql><insert id="insert" parameterType="flutter.dio.model.entity.UserLog">
        insert into ${tableName} (id, user_name, operation,
                                  method, params, time,
                                  ip)
        values (#{userLog.id,jdbcType=BIGINT}, #{userLog.userName,jdbcType=VARCHAR},
                #{userLog.operation,jdbcType=VARCHAR},
                #{userLog.method,jdbcType=VARCHAR}, #{userLog.params,jdbcType=VARCHAR}, #{userLog.time,jdbcType=BIGINT},
                #{userLog.ip,jdbcType=VARCHAR})
    </insert><select id="selectAll" resultMap="BaseResultMap">
        select
        <include refid="Base_Column_List"/>
        from ${tableName}
    </select><!--    查看指定的表是否存在-->
    <select id="existTable" parameterType="String" resultType="Integer">
        select count(*)
        from information_schema.TABLES
        where table_name = #{tableName}
    </select>
    <!-- 删除指定的表-->
    <update id="dropTable">
        DROP TABLE IF EXISTS ${tableName}
    </update>
    <!-- 创建新的日志表-->
    <update id="createTable" parameterType="String">
        CREATE TABLE ${tableName}
        (
            `id`        bigint(20) NOT NULL AUTO_INCREMENT COMMENT '编号',
            `user_name` varchar(50)   DEFAULT NULL COMMENT '用户名',
            `operation` varchar(50)   DEFAULT NULL COMMENT '用户操作',
            `method`    varchar(200)  DEFAULT NULL COMMENT '请求方法',
            `params`    varchar(5000) DEFAULT NULL COMMENT '请求参数',
            `time`      bigint(20) NOT NULL COMMENT '执行时长(毫秒)',
            `ip`        varchar(64)   DEFAULT NULL COMMENT 'IP地址',
            PRIMARY KEY (`id`)
        ) ENGINE=InnoDB AUTO_INCREMENT=2897 DEFAULT CHARSET=utf8 COMMENT='用户操作日志';
    </update>
</mapper>

上述代码中包括两部分内容,一部分是对表的操作 创建 与 删除,另一部分是对表中的数据的操作,保存用户的日志数据与查询用户的日志数据,都需要将用户对应的日志表名做为参数查询。文章来源地址https://www.toymoban.com/news/detail-444937.html

到了这里,关于Spring Boot:实现MyBatis动态创建表的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 如何在Spring Boot应用中使用Nacos实现动态更新数据源

    🌷🍁 博主猫头虎 带您 Go to New World.✨🍁 🦄 博客首页——猫头虎的博客🎐 🐳《面试题大全专栏》 文章图文并茂🦕生动形象🦖简单易学!欢迎大家来踩踩~🌺 🌊 《IDEA开发秘籍专栏》学会IDEA常用操作,工作效率翻倍~💐 🌊 《100天精通Golang(基础入门篇)》学会Golang语言

    2024年02月10日
    浏览(38)
  • MyBatis Plus 插件 动态数据源实现原理与源码讲解 (dynamic-datasource-spring-boot-starter-master)

    目录 1. 介绍 2. 基本原理 3. 源码介绍 3.1 使用 AOP 拦截,方法执行前获取到当前方法要用的数据源 3.2 实现自定义 DataSource 接口,实现 DataSource 接口的 getConnect 方法做动态处理 多数据源即一个项目中同时存在多个不同的数据库连接池。 比如 127.0.0.1:3306/test   127.0.0.1:3307/test 

    2024年02月07日
    浏览(41)
  • 【Spring Boot】数据库持久层框架MyBatis — Spring Boot构建MyBatis应用程序

    Spring Boot是用于快速构建Spring应用程序的框架。MyBatis是一种Java持久化框架,可以帮助开发人员轻松地管理数据库。将Spring Boot与MyBatis结合使用可以使开发人员更容易地创建和管理数据库应用程序。 以下是使用Spring Boot构建MyBatis应用程序的步骤: 添加MyBatis依赖项:在项目的

    2024年02月10日
    浏览(53)
  • Spring Boot 中动态创建 Flowable 工作流

    在 Spring Boot 中动态创建 Flowable 工作流可以通过以下步骤实现: 1. 创建 Flowable 配置:首先,您需要在 Spring Boot 应用程序中配置 Flowable。您可以使用 Spring Boot 的配置文件或注解来配置 Flowable。 2. 创建工作流定义:接下来,您需要创建工作流定义。您可以使用 Flowable 的 API 来

    2024年02月10日
    浏览(37)
  • 实现Spring Boot集成MyBatis

    在Java开发中,Spring Boot和MyBatis是非常常用的框架。Spring Boot是一个快速开发应用程序的框架,而MyBatis是一个持久化框架,可以方便地操作数据库。本文将介绍如何使用Idea集成Spring Boot和MyBatis,并创建一个简单的示例项目。 步骤1:创建Spring Boot项目 1、打开Idea,点击\\\"Create N

    2024年02月09日
    浏览(42)
  • 【Spring Boot】Spring Boot结合MyBatis简单实现学生信息管理模块

    环境准备 JDK Spring Boot MyBatis 创建Spring Boot项目 使用Spring Initializr创建一个新的Spring Boot项目,并添加以下依赖: Spring Web MyBatis Framework MySQL Driver 数据库设计 在MySQL数据库中创建一个名为 studentdb 的数据库,并创建一个名为 students 的表,表结构如下:

    2024年02月11日
    浏览(51)
  • 使用mybatis和dynamic-datasource-spring-boot-starter动态切换数据源操作数据库

    记录 :415 场景 :使用mybatis和dynamic-datasource-spring-boot-starter动态切换数据源操作数据库。 版本 :JDK 1.8,Spring Boot 2.6.3,dynamic-datasource-spring-boot-starter-3.3.2,mybatis-3.5.9。 源码 :https://github.com/baomidou/dynamic-datasource-spring-boot-starter dynamic-datasource-spring-boot-starter :一个基于springboot的快

    2023年04月19日
    浏览(44)
  • 使用Nacos配置中心动态管理Spring Boot应用配置

    🌷🍁 博主猫头虎 带您 Go to New World.✨🍁 🦄 博客首页——猫头虎的博客🎐 🐳《面试题大全专栏》 文章图文并茂🦕生动形象🦖简单易学!欢迎大家来踩踩~🌺 🌊 《IDEA开发秘籍专栏》学会IDEA常用操作,工作效率翻倍~💐 🌊 《100天精通Golang(基础入门篇)》学会Golang语言

    2024年02月12日
    浏览(58)
  • 使用dynamic-datasource-spring-boot-starter动态切换数据源操作数据库(MyBatis-3.5.9)

    记录 :383 场景 :使用dynamic-datasource-spring-boot-starter动态切换数据源,使用MyBatis操作数据库。提供三种示例:一,使用@DS注解作用到类上。二,使用@DS注解作用到方法上。三,不使用注解,使用DynamicDataSourceContextHolder类在方法内灵活切换不同数据源。 源码: https://github.com/

    2024年01月20日
    浏览(52)
  • Spring Cloud+Spring Boot+Mybatis+uniapp+前后端分离实现知识付费平台

    提供职业教育、企业培训、知识付费系统搭建服务。系统功能包含:录播课、直播课、题库、营销、公司组织架构、员工入职培训等。 提供私有化部署,免费售后,专业技术指导,支持PC、APP、H5、小程序多终端同步,支持二次开发定制,源码交付。   Java版知识付费-轻松拥

    2024年02月15日
    浏览(52)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包