[大数据] 利用Ant 执行SQL 脚本

开发: C++知识库 Java知识库 JavaScript Python PHP知识库人工智能区块链大数据移动开发嵌入式开发工具数据结构与算法开发测试游戏开发网络协议系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑笔记本显卡显示器固态硬盘硬盘耳机手机 iphone vivo oppo 小米华为单反装机图拉丁

-> 大数据 -> 利用Ant 执行SQL 脚本 -> 正文阅读

[大数据]利用Ant 执行SQL 脚本

pom.xml 添加ant

<dependency>
  <groupId>org.apache.ant</groupId>
  <artifactId>ant</artifactId>
  <version>1.10.9</version>
  <exclusions>
    <exclusion>
      <artifactId>tools</artifactId>
      <groupId>com.sun</groupId>
    </exclusion>
  </exclusions>
</dependency>

import lombok.extern.slf4j.Slf4j;
import org.apache.tools.ant.Project;
import org.apache.tools.ant.taskdefs.SQLExec;
import org.springframework.util.ResourceUtils;

import java.io.File;
import java.util.Properties;

/**
 * <p>导入sql文件到数据库</p>
 *
 * @Date 2021/4/13 17:48
 */
@Slf4j
public class ScriptSql {
	// test.sql文件放在resources目录下
    private static final String SCRIPT_SQL = "classpath:test.sql";

    public static void exeSQLSript(Properties prop) throws Exception {
        //读取sql脚本文件保存到数组中
        String[] sqlName = {SCRIPT_SQL};
        //循环执行sql脚本
        for (int i = 0; i < sqlName.length; i++) {
            //利用 Ant 的SQL Task来实现执行SQL 脚本的功能。ant 包中的 SQLExec类的扩展
            SQLExec sqlExec = new SQLExec();
            String mysqlDriver = prop.getProperty("driver","com.mysql.cj.jdbc.Driver");
            String url = prop.getProperty("url");
            // 获取用户密码，默认为root/root
            String username = prop.getProperty("username","root");
            String password = prop.getProperty("password","root");

            // 设置数据库参数
            sqlExec.setDriver(mysqlDriver);
            sqlExec.setUrl(url);
            sqlExec.setUserid(username);
            sqlExec.setPassword(password);
            //防止乱码，sql文件也需要设置为utf-8
            sqlExec.setEncoding("UTF8");
            //设置sql脚本
            File file = ResourceUtils.getFile(SCRIPT_SQL);
            sqlExec.setSrc(file);
            // 设置是否输出 true-打印,false-不打印
            sqlExec.setPrint(true);
            // 要指定这个属性，不然会出错
            sqlExec.setProject(new Project());
            sqlExec.setOutputEncoding("UTF8");
            sqlExec.setAutocommit(true);
            sqlExec.execute();
            log.info("sqlExec execute success!");
        }
    }

    public static void main(String[] args) {
        Properties prop = new Properties();
        prop.setProperty("url",  "jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&zeroDateTimeBehavior=convertToNull&allowMultiQueries=true&serverTimezone=Asia/Shanghai");
        prop.setProperty("username", "root");
        prop.setProperty("password", "root");
        try {
            ScriptSql.exeSQLSript(prop);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}