文章正文

Mysql java导入sql文件

【文档】2020-04-23

简介Mysql java导入sql文件

//Mysql java导入sql文件
public void testJavaImport() {
        String dbUrl = "";
        String className = "";
        String dbUsername = "";
        String dbPassword = "";

        LinkedList<String> outFiles = new LinkedList<>();
        outFiles.add("d://test.sql");
        try {
            Class.forName(className);
            Connection conn = DriverManager.getConnection(dbUrl, dbUsername, dbPassword);
            ScriptRunner runner = new ScriptRunner(conn);
            runner.setAutoCommit(true);
            //
            for (String sqlFile : outFiles) {
                long startTime = System.currentTimeMillis();
                File file = new File(sqlFile);
                try {
                    if (!file.getName().endsWith(".sql")) {
                        throw new Exception("非sql文件");
                    }
                    runner.setFullLineDelimiter(false);
                    runner.setDelimiter(";");//语句结束符号设置
                    runner.setLogWriter(null);//日志数据输出，这样就不会输出过程
                    runner.setSendFullScript(false);
                    runner.setAutoCommit(true);
                    runner.setStopOnError(true);
                    runner.runScript(new InputStreamReader(new FileInputStream(sqlFile), "utf8"));
                    //
                    file.delete();
                    System.out.println((String.format("【%s】执行成功", sqlFile)));
                } catch (Exception e) {
                    e.printStackTrace();
                }
                System.out.println("takeTime: " + (System.currentTimeMillis() - startTime) / 1000 + "s");
            }
            conn.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }


打赏支持

感谢您的支持，加油!

打开微信扫码打赏，你说多少就多少

找书费时，联系客服快速查找!

扫码支持

在线客服8:30-22:30，若离线请留言！

获取教程，请联系在线客服!

扫码支持

在线客服8:30-22:30，若离线请留言！

热门阅读

找PDF电子书，太费时间?

  • 微信扫描二维码，让客服快速查找。

    • 在线客服8:30-22:00，若离线请留言！