package util;

import java.io.FileNotFoundException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;


/**
 * @autor hh
 * @date 2022/07/06 20:12
 * 在界面初始化时创建数据表
 */
public class DBInit {
    /**
     * 从resources目录下读取sql文件,加载到程序中
     * 文件IO
     * @return
     */
    public static List<String> readSQL() {
        List<String> ret = new ArrayList<>();
        try {
            InputStream in = DBUtil.class.getClassLoader()
                    .getResourceAsStream("init.sql");

            Scanner scanner = new Scanner(in);
            //自定义换行符
            scanner.useDelimiter(";");
            // nextLine是默认遇到换行分割
            // Next是按照自定义换行符分割
            while (scanner.hasNext()) {
                String str = scanner.next();
                if ("".equals(str) || "\r\n".equals(str)) {
                    continue;
                }
                if (str.contains("--")) {
                    str = str.replaceAll("--", "");
                }
                ret.add(str);
            }
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
//        System.out.println("读取到的SQL内容为:");
//        System.out.println(ret);
        return ret;
    }

    /**
     * 在界面初始化时先初始化数据库，创建数据表
     */
    public static void init() {
        Connection connection = null;
        Statement statement = null;
        try {
           connection = DBUtil.getConnection();
            // 获取要执行的sql语句
            List<String> sqls = readSQL();
            // 这里咱采用了普通的Statement接口，没有用PrepareStatement
            statement = connection.createStatement();
            for (String sql : sqls) {
//                System.out.println("执行SQL操作 : " + sql);
                statement.executeUpdate(sql);
            }
        } catch (SQLException e) {
            System.err.println("数据库初始化失败");
            e.printStackTrace();
        } finally {
            DBUtil.close(statement);
        }
    }

    public static void main(String[] args) throws FileNotFoundException {
        init();
    }
}