java使用ScriptRunner执行sql文件

主要是使用ScriptRunner来执行sql文件，传入.sql文件的位置即可。

支持出错回滚

/**
 * 使用ScriptRunner执行sql文件
 */
public class ExecuteSql {

    private static final Logger LOGGER = LoggerFactory.getLogger(ExecuteSql.class);

    @Autowired
    private DataSource dataSource; // 获取数据库连接对象

    public static void main(String[] args) {
        try {
            executeSqlFile("/sql/myTest.sql");
            LOGGER.info("【执行sql文件】执行成功");
        } catch (Exception e) {
            e.printStackTrace();
            LOGGER.info("【执行sql文件】执行出错" + e);
        }
    }

    private void executeSqlFile(String sqlFileName) throws Exception {
        if (StringUtils.isEmpty(sqlFileName)) {
            return;
        }
        Exception error = null;
        // 获取连接对象
        Connection conn = dataSource.getConnection();
        try {
            // 设置不自动提交
            conn.setAutoCommit(false);
            // 初始化ScriptRunner
            ScriptRunner runner = new ScriptRunner(conn);
            // 设置不自动提交
            runner.setAutoCommit(false);
            // true，遇见错误会停止执行，打印并抛出异常，捕捉异常，并进行回滚，保证在一个事务内执行；
            // false，遇见错误不会停止，会继续执行，会打印异常信息，并不会抛出异常，当前方法无法捕捉异常无法进行回滚操作，无法保证在一个事务内执行；
            runner.setStopOnError(true);
            // true则获取整个脚本并执行；
            // false则按照自定义的分隔符每行执行；
            runner.setSendFullScript(false);
            // 定义命令间的分隔符
            runner.setDelimiter(";");
            runner.setFullLineDelimiter(false);
            // 设置是否输出日志，null不输出日志，不设置自动将日志输出到控制台
            runner.setLogWriter(null);

            LOGGER.info("【执行sql文件】读取sql文件");
            // 读取文件
            Resource resource = new ClassPathResource(sqlFileName);
            File file = resource.getFile();

            LOGGER.info("【执行sql文件】开始执行sql文件");
            // 如果有多个sql文件，可以写多个runner.runScript(xxx),
            runner.runScript(new InputStreamReader(new FileInputStream(file), StandardCharsets.UTF_8));
            // 执行
            conn.commit();
        } catch (Exception e) {
            LOGGER.info("【执行sql文件】执行出错，开始回滚");
            conn.rollback();
            error = e;
        } finally {
            close(conn);
        }
        if (error != null) {
            throw error;
        }
    }

    /*
     * @描述：关闭连接
     * @创建人：吴翔龙
     * @创建时间：2019/2/20
     * @param：[conn]
     * @return：void
     */
    private static void close(Connection conn) {
        LOGGER.info("【执行sql文件】关闭数据库连接");
        try {
            if (conn != null) {
                conn.close();
            }
        } catch (Exception e) {
            if (conn != null) {
                conn = null;
            }
        }
    }
}