java 執行sql腳本的3種方式 (ant,ibatis,ScriptRunner)

package com.unmi; import java.io.*; import org.apache.tools.ant.*; import org.apache.tools.ant.taskdefs.*; import org.apache.tools.ant.types.*; /** * 調用 ant.jar 的 SQLExec 執行 SQL 腳本文件 * @author Unmi */ public class AntExecSql { /** * @param args */ public static void main(String[] args) { SQLExec sqlExec = new SQLExec(); //設置數據庫參數 sqlExec.setDriver("oracle.jdbc.driver.OracleDriver"); sqlExec.setUrl("jdbc:oracle:thin:@10.128.x.x:1521:xxsid"); sqlExec.setUserid("xxuser"); sqlExec.setPassword("xxpass"); //要執行的腳本 sqlExec.setSrc(new File("src/data.sql")); //有出錯的語句該如何處理 sqlExec.setOnerror((SQLExec.OnError)(EnumeratedAttribute.getInstance( SQLExec.OnError.class, "abort"))); sqlExec.setPrint(true); //設置是否輸出 //輸出到文件 sql.out 中；不設置該屬性，默認輸出到控制檯 sqlExec.setOutput(new File("src/sql.out")); sqlExec.setProject(new Project()); // 要指定這個屬性，否則會出錯 sqlExec.execute(); } } package com.unmi; import java.io.*; import org.apache.tools.ant.*; import org.apache.tools.ant.taskdefs.*; import org.apache.tools.ant.types.*; /** * 調用 ant.jar 的 SQLExec 執行 SQL 腳本文件 * @author Unmi */ public class AntExecSql { /** * @param args */ public static void main(String[] args) { SQLExec sqlExec = new SQLExec(); //設置數據庫參數 sqlExec.setDriver("oracle.jdbc.driver.OracleDriver"); sqlExec.setUrl("jdbc:oracle:thin:@10.128.x.x:1521:xxsid"); sqlExec.setUserid("xxuser"); sqlExec.setPassword("xxpass"); //要執行的腳本 sqlExec.setSrc(new File("src/data.sql")); //有出錯的語句該如何處理 sqlExec.setOnerror((SQLExec.OnError)(EnumeratedAttribute.getInstance( SQLExec.OnError.class, "abort"))); sqlExec.setPrint(true); //設置是否輸出 //輸出到文件 sql.out 中；不設置該屬性，默認輸出到控制檯 sqlExec.setOutput(new File("src/sql.out")); sqlExec.setProject(new Project()); // 要指定這個屬性，否則會出錯 sqlExec.execute(); } } ibatis： package com.ibatis.jpetstore.test; import java.sql.DriverManager; import java.util.Properties; import com.ibatis.common.jdbc.ScriptRunner; import com.ibatis.common.resources.Resources; import com.mysql.jdbc.Connection; public class DBTestSQL { public static void main(String[] args) { try { Properties props = Resources.getResourceAsProperties("properties/database.properties"); String url = props.getProperty("url"); String driver = props.getProperty("driver"); String username = props.getProperty("username"); String password = props.getProperty("password"); System.out.println(url); if(url.equals("jdbc:mysql://localhost:3306/jpetstore1")) { Class.forName(driver).newInstance(); Connection conn = (Connection) DriverManager.getConnection(url, username, password); ScriptRunner runner = new ScriptRunner(conn, false, false); runner.setErrorLogWriter(null); runner.setLogWriter(null); runner.runScript(Resources.getResourceAsReader("ddl/mysql/jpetstore-mysql-schema.sql")); runner.runScript(Resources.getResourceAsReader("ddl/mysql/jpetstore-mysql-dataload.sql")); } } catch (Exception e) { e.printStackTrace(); } } } ScriptRunner(com.ibatis.common.jdbc.*)用法 ScriptRunner類用於執行SQL語句,例如建立數據庫schema，或傳入缺省或測試數據庫等等。 從下面的例子能夠認識到它的易用性: 例子1：使用現成的數據庫鏈接 Connection conn=getConnection();//some method to get a Connection ScriptRunner runner=new ScriptRunner(); runner.runScript(conn,Resources.getResourceAsReader("com/some/resource/path/initialize.sql")); conn.close(); 例子2：使用新的數據庫鏈接 ScriptRunner runner=new ScriptRunner("com.some.Driver","jdbc:url://db","login","password"); runner.runScript(conn,new FileReader("/user/local/db/scripts/initialize-db.sql"));例子3：使用新建立的數據鏈接 Properties props= getProperties();//some properties form somewhereScriptRunner runner =new ScriptRunner(props);runner.runScript(conn,new FileReader("/user/local/db/scripts/initialize-db.sql"));