如何使用JDBC执行.sql脚本文件
可能重复：
使用JDBC和MySQL运行.sql脚本
我有一个包含40-50个SQL语句的SQL脚本文件。 是否有可能使用JDBC来运行这个脚本文件？
此链接可能会帮助您： http : //pastebin.com/f10584951 。
粘贴在后面：
/* * Slightly modified version of the com.ibatis.common.jdbc.ScriptRunner class * from the iBATIS Apache project. Only removed dependency on Resource class * and a constructor */ /* * Copyright 2004 Clinton Begin * * Licensed under the Apache License, Version 2.0 (the "License"); * you may not use this file except in compliance with the License. * You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ import java.io.IOException; import java.io.LineNumberReader; import java.io.PrintWriter; import java.io.Reader; import java.sql.*; /** * Tool to run database scripts */ public class ScriptRunner { private static final String DEFAULT_DELIMITER = ";"; private Connection connection; private boolean stopOnError; private boolean autoCommit; private PrintWriter logWriter = new PrintWriter(System.out); private PrintWriter errorLogWriter = new PrintWriter(System.err); private String delimiter = DEFAULT_DELIMITER; private boolean fullLineDelimiter = false; /** * Default constructor */ public ScriptRunner(Connection connection, boolean autoCommit, boolean stopOnError) { this.connection = connection; this.autoCommit = autoCommit; this.stopOnError = stopOnError; } public void setDelimiter(String delimiter, boolean fullLineDelimiter) { this.delimiter = delimiter; this.fullLineDelimiter = fullLineDelimiter; } /** * Setter for logWriter property * * @param logWriter * - the new value of the logWriter property */ public void setLogWriter(PrintWriter logWriter) { this.logWriter = logWriter; } /** * Setter for errorLogWriter property * * @param errorLogWriter * - the new value of the errorLogWriter property */ public void setErrorLogWriter(PrintWriter errorLogWriter) { this.errorLogWriter = errorLogWriter; } /** * Runs an SQL script (read in using the Reader parameter) * * @param reader * - the source of the script */ public void runScript(Reader reader) throws IOException, SQLException { try { boolean originalAutoCommit = connection.getAutoCommit(); try { if (originalAutoCommit != this.autoCommit) { connection.setAutoCommit(this.autoCommit); } runScript(connection, reader); } finally { connection.setAutoCommit(originalAutoCommit); } } catch (IOException e) { throw e; } catch (SQLException e) { throw e; } catch (Exception e) { throw new RuntimeException("Error running script. Cause: " + e, e); } } /** * Runs an SQL script (read in using the Reader parameter) using the * connection passed in * * @param conn * - the connection to use for the script * @param reader * - the source of the script * @throws SQLException * if any SQL errors occur * @throws IOException * if there is an error reading from the Reader */ private void runScript(Connection conn, Reader reader) throws IOException, SQLException { StringBuffer command = null; try { LineNumberReader lineReader = new LineNumberReader(reader); String line = null; while ((line = lineReader.readLine()) != null) { if (command == null) { command = new StringBuffer(); } String trimmedLine = line.trim(); if (trimmedLine.startsWith("--")) { println(trimmedLine); } else if (trimmedLine.length() < 1 || trimmedLine.startsWith("//")) { // Do nothing } else if (trimmedLine.length() < 1 || trimmedLine.startsWith("--")) { // Do nothing } else if (!fullLineDelimiter && trimmedLine.endsWith(getDelimiter()) || fullLineDelimiter && trimmedLine.equals(getDelimiter())) { command.append(line.substring(0, line .lastIndexOf(getDelimiter()))); command.append(" "); Statement statement = conn.createStatement(); println(command); boolean hasResults = false; if (stopOnError) { hasResults = statement.execute(command.toString()); } else { try { statement.execute(command.toString()); } catch (SQLException e) { e.fillInStackTrace(); printlnError("Error executing: " + command); printlnError(e); } } if (autoCommit && !conn.getAutoCommit()) { conn.commit(); } ResultSet rs = statement.getResultSet(); if (hasResults && rs != null) { ResultSetMetaData md = rs.getMetaData(); int cols = md.getColumnCount(); for (int i = 0; i < cols; i++) { String name = md.getColumnLabel(i); print(name + "\t"); } println(""); while (rs.next()) { for (int i = 0; i < cols; i++) { String value = rs.getString(i); print(value + "\t"); } println(""); } } command = null; try { statement.close(); } catch (Exception e) { // Ignore to workaround a bug in Jakarta DBCP } Thread.yield(); } else { command.append(line); command.append(" "); } } if (!autoCommit) { conn.commit(); } } catch (SQLException e) { e.fillInStackTrace(); printlnError("Error executing: " + command); printlnError(e); throw e; } catch (IOException e) { e.fillInStackTrace(); printlnError("Error executing: " + command); printlnError(e); throw e; } finally { conn.rollback(); flush(); } } private String getDelimiter() { return delimiter; } private void print(Object o) { if (logWriter != null) { System.out.print(o); } } private void println(Object o) { if (logWriter != null) { logWriter.println(o); } } private void printlnError(Object o) { if (errorLogWriter != null) { errorLogWriter.println(o); } } private void flush() { if (logWriter != null) { logWriter.flush(); } if (errorLogWriter != null) { errorLogWriter.flush(); } } } 我使用这一小段代码来导入由mysqldump创build的sql语句：
public static void importSQL(Connection conn, InputStream in) throws SQLException { Scanner s = new Scanner(in); s.useDelimiter("(;(\r)?\n)|(--\n)"); Statement st = null; try { st = conn.createStatement(); while (s.hasNext()) { String line = s.next(); if (line.startsWith("/*!") && line.endsWith("*/")) { int i = line.indexOf(' '); line = line.substring(i + 1, line.length() - " */".length()); } if (line.trim().length() > 0) { st.execute(line); } } } finally { if (st != null) st.close(); } }
另一种select是，这不支持注释，对于Apache Derby的AmaterasERD DDL导出非常有用：
public void executeSqlScript(Connection conn, File inputFile) { // Delimiter String delimiter = ";"; // Create scanner Scanner scanner; try { scanner = new Scanner(inputFile).useDelimiter(delimiter); } catch (FileNotFoundException e1) { e1.printStackTrace(); return; } // Loop through the SQL file statements Statement currentStatement = null; while(scanner.hasNext()) { // Get statement String rawStatement = scanner.next() + delimiter; try { // Execute statement currentStatement = conn.createStatement(); currentStatement.execute(rawStatement); } catch (SQLException e) { e.printStackTrace(); } finally { // Release resources if (currentStatement != null) { try { currentStatement.close(); } catch (SQLException e) { e.printStackTrace(); } } currentStatement = null; } } scanner.close(); }
只要阅读它，然后使用其中的完整的SQL文件准备的expression。
（如果我记得不错）
ADD：你也可以阅读和分割";" 而不是循环执行它们。 不要忘记评论，并再次添加";"
您应该能够将SQL文件parsing为语句。 并且一次运行一个语句。 如果你知道你的文件由简单的插入/更新/删除语句组成，你可以使用分号作为语句分隔符。 在一般情况下，你有一个任务来创build你的特定的SQL方言parsing器。
我尝试执行创buildSQL数据库的SQL脚本时遇到同样的问题。 我在这里和那里搜到了一个最初由Clinton Begin写的支持评论的Java类（见http://pastebin.com/P14HsYAG ）。 我略微修改了该文件以迎合触发器，因为必须将默认的DELIMITER更改为不同的东西。 我已经使用该版本的ScriptRunner（请参阅http://pastebin.com/sb4bMbVv ）。 由于（开放源码和免费的）SQLScriptRunner类是一个绝对必要的实用工具，因此开发人员提供更多的意见将是一件好事，希望我们很快会有一个更稳定的版本。
您可以使用BufferedReader读取每行脚本行，并将每行添加到StringBuilder以便脚本变成一个大string。
然后你可以使用JDBC创build一个Statement对象，并调用statement.execute(stringBuilder.toString()) 。
