1. 程式人生 > >Java執行SQL腳本文件到數據庫

Java執行SQL腳本文件到數據庫

方法 pep sql腳本 sql文件 -s mps pub sql語句 data

方式一:直接讀取SQL腳本文件的內容,然後傳遞到SQL中。

代碼:RunSqlService:

    @Autowired
    private RunSqlDao runSqlDao;
    
    /**
     * 讀取文件內容到SQL中執行
     * @param sqlPath SQL文件的路徑:如:D:/TestProject/web/sql/腳本.Sql
     */
    public void runSqlByReadFileContent(String sqlPath) throws Exception {
        try {
             
            String sqlStr 
= readFileByLines(sqlPath); // System.out.println("獲得的文本:" + sqlStr); if (sqlStr.length() > 0) { runSqlDao.runSqlBySqlStr(sqlStr); } } catch (Exception e) { e.printStackTrace(); throw e; } } /** * 以行為單位讀取文件,常用於讀面向行的格式化文件
*/ private String readFileByLines(String filePath) throws Exception { StringBuffer str = new StringBuffer(); BufferedReader reader = null; try { reader = new BufferedReader(new InputStreamReader( new FileInputStream(filePath), "UTF-8")); String tempString
= null; int line = 1; // 一次讀入一行,直到讀入null為文件結束 while ((tempString = reader.readLine()) != null) { // 顯示行號 // System.out.println("line " + line + ": " + tempString); str = str.append(" " + tempString); line++; } reader.close(); } catch (IOException e) { e.printStackTrace(); throw e; } finally { if (reader != null) { try { reader.close(); } catch (IOException e1) { } } } return str.toString(); }

RunSqlDao :

    /**
     * @param sqlStr
     */
    public void runSqlBySqlStr(String sqlStr) {
        Map<String,Object> map=new HashMap<String,Object>();
        map.put("sqlStr", sqlStr);
        sqlSessionTemplate.selectList("runSql.runSqlBySqlStr", map);
    }

SQLMap:

<mapper namespace="runSql">

<select id="runSqlBySqlStr" parameterType="map">
<![CDATA[ ${sqlStr}]]>
</select>

</mapper>

這種寫法:只支持數據的變化(新增、修改、刪除),且SQL文件內容以begin開始,以end結束。無法更新表字段修改等操作。

方式二;使用ScriptRunner

代碼:RunSqlService:

    /**
     * 執行sql腳本文件 使用ScriptRunner
     * @param sqlPath SQL文件的路徑:如:D:/TestProject/web/sql/腳本.Sql
     */
    public void runSqlByScriptRunner(String sqlPath) throws Exception {
        try {
            SqlSession sqlSession = sqlSessionFactory.openSession();
            Connection conn = sqlSession.getConnection();
            ScriptRunner runner = new ScriptRunner(conn);
            runner.setEscapeProcessing(false);
            runner.setSendFullScript(true);            
            runner.runScript(new InputStreamReader(new FileInputStream(sqlPath), "UTF-8"));
        } catch (Exception e) {
            e.printStackTrace();
            throw e;
        }
    }

這種寫法:只能有一行SQL,即一次執行一個SQL語句,否則就會報錯。

方式三:使用ScriptUtils
代碼:RunSqlService:(以下兩種方式:腳本.Sql 和RunSqlService 在同一目錄下)

方法(1)

    /**
     * 執行sql腳本文件 使用Spring工具類
     */
    public void runSqlBySpringUtils() throws Exception {
        try {
            SqlSession sqlSession = sqlSessionFactory.openSession();
            Connection conn = sqlSession.getConnection();
            ClassPathResource rc = new ClassPathResource("腳本.Sql", RunSqlDao.class);
            ScriptUtils.executeSqlScript(conn, rc);
        } catch (Exception e) {
            e.printStackTrace();
            throw e;
        }
    }

方法(2)

    /**
     * 執行sql腳本文件 使用Spring工具類
     */
    public void runSqlBySpringUtils() throws Exception {
        try {
            SqlSession sqlSession = sqlSessionFactory.openSession();
            Connection conn = sqlSession.getConnection();
            ClassPathResource rc = new ClassPathResource("腳本.Sql", RunSqlDao.class);
            EncodedResource er = new EncodedResource(rc, "utf-8");
            ScriptUtils.executeSqlScript(conn, er);
        } catch (Exception e) {
            e.printStackTrace();
            throw e;
        }
    }

方法(1),腳本.Sql文件必須是ANSI的,否則執行到數據中漢字是亂碼。

方法(2)解決了方法(1)的問題,完美了,喜歡的小夥伴們快拿去享用吧。

文章為本人原創,轉載請標明出處。

Java執行SQL腳本文件到數據庫