SpringBoot结合Mybatis实现创建数据库表代码方法

本篇文章小编给大家分享一下SpringBoot结合Mybatis实现创建数据库表代码方法，文章代码介绍的很详细，小编觉得挺不错的，现在分享给大家供大家参考，有需要的小伙伴们可以来看看。

准备创建表的 SQL 语句

创建表 SQL 语句，内容如下：

CREATE TABLE IF NOT EXISTS `user`
(
    `id`       int(0)      NOT NULL AUTO_INCREMENT COMMENT '主键',
    `group_id` int(0)      NULL DEFAULT NULL COMMENT '组号',
    `username` varchar(20) NULL DEFAULT NULL COMMENT '用户名',
    `password` varchar(20) NULL DEFAULT NULL COMMENT '密码',
    PRIMARY KEY (`id`)
) ENGINE = InnoDB
  AUTO_INCREMENT = 9
  CHARACTER SET = utf8mb4 COMMENT ='用于测试的用户表';

实现通过 MyBatis 创建数据库表示例

目的就是解决通过 MyBatis 执行创建表的语句，从而实现创建数据库中的表的功能，实现代码如下：

在 Maven 中引入相关依赖

在 Maven的 pom.xml文件中，引入 SpringBoot、MySql、MyBytis 等依赖，内容如下：

    4.0.0

    
        org.springframework.boot
        spring-boot-starter-parent
        2.6.2
    

    club.mydlq
    springboot-mybatis-create-table-example
    1.0.0
    springboot-mybatis-example
    springboot mybatis create table example project

    
        1.8
    

    
        
        
            org.springframework.boot
            spring-boot-starter-web
        
        
        
            org.projectlombok
            lombok
            true
        
        
        
            mysql
            mysql-connector-java
        
        
        
            org.mybatis.spring.boot
            mybatis-spring-boot-starter
            2.2.1
        
    

    
        
            
                org.springframework.boot
                spring-boot-maven-plugin
            
        
    

在 SpringBoot 配置文件中添加数据库配置

在 SpringBoot 的 application.yml 文件中，添加数据库连接的参数，配置内容如下：

spring:
  application:
    name: springboot-mybatis-create-table-example
  # 数据库配置
  datasource:
    type: com.zaxxer.hikari.HikariDataSource
    driverClassName: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://127.0.0.1:3306/test?serverTimezone=Asia/Shanghai&useUnicode=true&useSSL=false&allowPublicKeyRetrieval=true
    hikari:
      pool-name: DatebookHikariCP
      minimum-idle: 5
      maximum-pool-size: 15
      max-lifetime: 1800000
      connection-timeout: 30000
      username: root
      password: 123456

# 指定 mapper 的 xml 文件位置
mybatis:
  mapper-locations: classpath:mappers/*.xml

创建测试的 Mapper 接口类

创建一个用户建表的 MyBatis 的 Mapper 接口，代码如下：

import org.apache.ibatis.annotations.Mapper;

@Mapper
public interface TableMapper {

    /**
     * 创建数据库表
     *
     * @param tableName 表名称
     */
    void createTable(String tableName);

}

创建与 Mapper 关联的 XML 文件

创建一个用于和 Mapper 接口关联的 xml 文件 TableMapper.xml，在里面添加用于创建表的 SQL 语句，内容如下：

    
    
        CREATE TABLE IF NOT EXISTS `${tableName}`
        (
            `id`       int(0)      NOT NULL AUTO_INCREMENT COMMENT '主键',
            `group_id` int(0)      NULL DEFAULT NULL COMMENT '组号',
            `username` varchar(20) NULL DEFAULT NULL COMMENT '用户名',
            `password` varchar(20) NULL DEFAULT NULL COMMENT '密码',
            PRIMARY KEY (`id`)
        ) ENGINE = InnoDB
          AUTO_INCREMENT = 9
          CHARACTER SET = utf8mb4 COMMENT ='用于测试的用户表';
    

创建用于测试的 Controller 类

创建一个用于测试的 Controller 类，里面提供一个创建表的接口，代码如下：

import club.mydlq.mappers.TableMapper;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;

@RestController
public class TestController {

    @Resource
    private TableMapper tableMapper;

    /**
     * 创建数据库表
     *
     * @param tableName 表名称
     * @return 是否创建成功
     */
    @PostMapping("/createTable")
    public ResponseEntity createTableTest(@RequestParam String tableName) {
        try {
            // 创建数据库表
            tableMapper.createTable(tableName);
        } catch (Exception e) {
            return ResponseEntity.status(500).body("创建数据库表失败");
        }
        return ResponseEntity.ok("创建数据库表成功");
    }

}

创建 SpringBoot 启动类

创建一个用于启动 SpringBoot 的启动类，代码如下：

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);
    }

}

调用创建表的接口进行测试

执行 curl 命令，使用 POST 方法调用之前示例项目 Controller 类中提供的创建表接口 /createTable，在数据库 test 中创建一个 user 表：

$ curl -X POST http://l*oca**lhost:8080/createTable?tableName=user

执行完接口后，再进入数据库，输入下面命令观察库中是否创建包成功：

mysql> use test;
Database changed

mysql> show tables;
+----------------------------------------+
| Tables_in_test                         |
+----------------------------------------+
| user                                   |
+----------------------------------------+
1 rows in set (0.00 sec)

可以看到 test 库中已经成功创建了 user 表。