使用Java如何將SQL腳本文件執(zhí)行到數(shù)據(jù)庫中？針對(duì)這個(gè)問題，這篇文章詳細(xì)介紹了相對(duì)應(yīng)的分析和解答，希望可以幫助更多想解決這個(gè)問題的小伙伴找到更簡(jiǎn)單易行的方法。
創(chuàng)新互聯(lián)服務(wù)項(xiàng)目包括鶴峰網(wǎng)站建設(shè)、鶴峰網(wǎng)站制作、鶴峰網(wǎng)頁制作以及鶴峰網(wǎng)絡(luò)營(yíng)銷策劃等。多年來，我們專注于互聯(lián)網(wǎng)行業(yè)，利用自身積累的技術(shù)優(yōu)勢(shì)、行業(yè)經(jīng)驗(yàn)、深度合作伙伴關(guān)系等，向廣大中小型企業(yè)、政府機(jī)構(gòu)等提供互聯(lián)網(wǎng)行業(yè)的解決方案，鶴峰網(wǎng)站推廣取得了明顯的社會(huì)效益與經(jīng)濟(jì)效益。目前，我們服務(wù)的客戶以成都為中心已經(jīng)輻射到鶴峰省份的部分城市，未來相信會(huì)繼續(xù)擴(kuò)大服務(wù)區(qū)域并繼續(xù)獲得客戶的支持與信任！
方式一：直接讀取SQL腳本文件的內(nèi)容，然后傳遞到SQL中。
代碼：RunSqlService：
重慶分公司
重慶分公司
@Autowired
private RunSqlDao runSqlDao;
/**
* 讀取文件內(nèi)容到SQL中執(zhí)行
* @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為文件結(jié)束
while ((tempString = reader.readLine()) != null) {
// 顯示行號(hào)
// 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 map=new HashMap();
map.put("sqlStr", sqlStr);
sqlSessionTemplate.selectList("runSql.runSqlBySqlStr", map);
} SQLMap：
這種寫法：只支持?jǐn)?shù)據(jù)的變化（新增、修改、刪除）,且SQL文件內(nèi)容以begin開始，以end結(jié)束。無法更新表字段修改等操作。
方式二；使用ScriptRunner
代碼：RunSqlService：
/**
* 執(zhí)行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，即一次執(zhí)行一個(gè)SQL語句，否則就會(huì)報(bào)錯(cuò)。
方式三：使用ScriptUtils
代碼：RunSqlService：(以下兩種方式：腳本.Sql 和RunSqlService 在同一目錄下)
方法（1）
/**
* 執(zhí)行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）
/**
* 執(zhí)行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的，否則執(zhí)行到數(shù)據(jù)中漢字是亂碼。
方法（2）解決了方法（1）的問題，完美了，喜歡的小伙伴們快拿去享用吧。
關(guān)于使用Java如何將SQL腳本文件執(zhí)行到數(shù)據(jù)庫中問題的解答就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關(guān)知識(shí)。
