Springboot 調用mysql的.sql檔案，執行mysql語句

前言

該篇内容介紹是 調用指定的 .sql 檔案， 執行裡面的mysql語句。

正文 

實戰示例準備：

1. 一張 user 表 ：

2.2個簡單 SQL檔案（裡面就簡單寫點插入sql語句）：

sql檔案在項目中的位置：

3.pom.xml 依賴：

<!--web-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- mybatis依賴 -->
        <dependency>
            <groupId>org.mybatis.spring.boot</groupId>
            <artifactId>mybatis-spring-boot-starter</artifactId>
            <version>1.3.0</version>
        </dependency>
        <!--mysql驅動-->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
        </dependency>
        <!-- druid資料源驅動 1.1.10解決springboot從1.0——2.0版本問題-->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid-spring-boot-starter</artifactId>
            <version>1.1.10</version>
        </dependency>      

4.application.yml 配置：

server:
  port: 8082
spring:
  datasource:
    druid:
      url: jdbc:mysql://127.0.0.1:3306/test?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=UTF-8&useSSL=true&rewriteBatchedStatements=true
      username: root
      password: 123456
      initialSize: 5
      minIdle: 5
      maxActive: 20
      maxWait: 60000
      timeBetweenEvictionRunsMillis: 60000
      minEvictableIdleTimeMillis: 300000
      validationQuery: SELECT 1 FROM DUAL
      testWhileIdle: true
      testOnBorrow: false
      testOnReturn: false
      poolPreparedStatements: true
      maxPoolPreparedStatementPerConnectionSize: 20
      useGlobalDataSourceStat: true
      connectionProperties: druid.stat.mergeSql=true;druid.stat.slowSqlMillis=5000      

5. 建立一個工具類ExecuteSQLUtil.java ：

可以看到我的有關mysql連接配接資訊在示例裡面是從yml檔案讀取的或者是在代碼寫死，這個大家根據具體業務場景和項目去調整，甚至放在資料庫裡面查詢也行。

import org.springframework.beans.factory.annotation.Value;
import org.springframework.core.io.ClassPathResource;
import org.springframework.core.io.support.EncodedResource;
import org.springframework.jdbc.datasource.init.ScriptUtils;
import org.springframework.stereotype.Component;
import java.sql.*;

/**
 * @Author: JCccc
 * @Description:
 * @Date: 2020/11/16
 */
@Component
public class ExecuteSQLUtil {

    @Value("${spring.datasource.druid.url}")
    private String DB_URL;
    @Value("${spring.datasource.druid.username}")
    private String DB_USERNAME;
    @Value("${spring.datasource.druid.password}")
    private String DB_PWD;

    public  Connection executeSql(String sqlFileName){
        Connection connection = null;
        try {
            String driverClassName = "com.mysql.cj.jdbc.Driver";
//            String DB_URL = "jdbc:mysql://127.0.0.1:3306/test?serverTimezone=Asia/Shanghai&useUnicode=true&characterEncoding=UTF-8&useSSL=true&rewriteBatchedStatements=true";
//            String DB_USERNAME = "root";
//            String DB_PWD = "123456";

            Class.forName(driverClassName);
             connection = DriverManager.getConnection(DB_URL, DB_USERNAME, DB_PWD);
        } catch (Exception e) {
            e.printStackTrace();
        }
        ClassPathResource rc = new ClassPathResource(sqlFileName);
        EncodedResource er = new EncodedResource(rc, "utf-8");
        ScriptUtils.executeSqlScript(connection, er);
        return connection;
    }


}      

6. 寫個測試接口，使用postman調用一下：

/**
 * @Author: JCccc
 * @Description:
 * @Date: 2020/11/16
 */
@RestController
public class TestController {

    @Autowired
    ExecuteSQLUtil executeSQLUtil;

    @GetMapping("/executeMysql")
    public String executeMysql(@RequestParam("scriptName") String scriptName) {

        executeSQLUtil.executeSql("static/"+scriptName+".sql");

        return "ok";
    }


}      

測試：

運作結果：