如何用Java执行SQL脚本文件？

Question

我想在 Java 中执行 SQL 脚本文件，而不将整个文件内容读取到一个大查询中并执行它。

还有其他标准方法吗？

Answer 1

只要您不介意依赖 Ant，就有一种很好的方法可以从 Java 执行 SQL 脚本，而无需亲自阅读它们。在我看来，这种依赖在你的情况下是非常合理的。下面是示例代码，其中 SQLExec 类位于 ant.jar 中：

private void executeSql(String sqlFilePath) {
    final class SqlExecuter extends SQLExec {
        public SqlExecuter() {
            Project project = new Project();
            project.init();
            setProject(project);
            setTaskType("sql");
            setTaskName("sql");
        }
    }

    SqlExecuter executer = new SqlExecuter();
    executer.setSrc(new File(sqlFilePath));
    executer.setDriver(args.getDriver());
    executer.setPassword(args.getPwd());
    executer.setUserid(args.getUser());
    executer.setUrl(args.getUrl());
    executer.execute();
}

Answer 2

没有可移植的方法可以做到这一点。您可以将本机客户端作为外部程序执行来执行此操作：

import java.io.*;
public class CmdExec {

  public static void main(String argv[]) {
    try {
      String line;
      Process p = Runtime.getRuntime().exec
        ("psql -U username -d dbname -h serverhost -f scripfile.sql");
      BufferedReader input =
        new BufferedReader
          (new InputStreamReader(p.getInputStream()));
      while ((line = input.readLine()) != null) {
        System.out.println(line);
      }
      input.close();
    }
    catch (Exception err) {
      err.printStackTrace();
    }
  }
}

• 代码示例是从 此处提取的 并修改为假设用户想要执行 PostgreSQL 脚本文件来回答问题。

Answer 3

Flyway 库对此非常有用：

    Flyway flyway = new Flyway();
    flyway.setDataSource(dbConfig.getUrl(), dbConfig.getUsername(), dbConfig.getPassword());
    flyway.setLocations("classpath:db/scripts");
    flyway.clean();
    flyway.migrate();

它会扫描脚本的位置并按顺序运行它们。脚本可以使用 V01__name.sql 进行版本控制，因此如果仅调用 migrate，则只会运行那些尚未运行的脚本。使用名为“schema_version”的表来跟踪事物。但也可以做其他事情，请参阅文档：flyway。

clean 调用不是必需的，但对于从干净的数据库开始很有用。
另外，请注意位置（默认为“classpath:db/migration”），“:”后面没有空格，这让我很困惑。

Answer 4

不，您必须读取该文件，将其拆分为单独的查询，然后单独执行它们（或使用 JDBC 的批处理 API）。

原因之一是每个数据库都定义了自己的分隔 SQL 语句的方式（有些使用 ;，其他使用 /，有些允许两者，甚至定义您自己的分隔符）。

Answer 5

您不能使用 JDBC，因为它不支持 .解决方法是包含 iBatis iBATIS 是一个持久性框架，并调用 Scriptrunner 构造函数，如 iBatis 文档 。

包含像 ibatis 这样的重量级持久性框架来运行简单的 sql 脚本并不好，而您可以使用命令行来执行此操作

$ mysql -u root -p db_name < test.sql

Answer 6

由于 JDBC 不支持此选项，解决此问题的最佳方法是通过 Java 程序执行命令行。下面是 postgresql 的一个例子：

private void executeSqlFile() {
     try {
         Runtime rt = Runtime.getRuntime();
         String executeSqlCommand = "psql -U (user) -h (domain) -f (script_name) (dbName)";
         Process pr = rt.exec();
         int exitVal = pr.waitFor();
         System.out.println("Exited with error code " + exitVal);
      } catch (Exception e) {
        System.out.println(e.toString());
      }
}

Answer 7

Apache iBatis 解决方案非常有效。

我使用的脚本示例正是我从 MySql 工作台运行的脚本。

这里有一篇带有示例的文章：
https://www.tutorialspoint.com/how-to-run -sql-script-using-jdbc#:~:text=你%20can%20execute%20.,to%20pass%20a%20connection%20object.&text=注册%20%20MySQL%20JDBC%20Driver,method%20of %20%20DriverManager%20类。

这就是我所做的：

pom.xml 依赖

<!-- IBATIS SQL Script runner from Apache (https://mvnrepository.com/artifact/org.apache.ibatis/ibatis-core) -->
<dependency>
    <groupId>org.apache.ibatis</groupId>
    <artifactId>ibatis-core</artifactId>
    <version>3.0</version>
</dependency>

项 执行脚本的代码：

import java.io.BufferedReader;
import java.io.File;
import java.io.FileReader;
import java.io.Reader;
import java.sql.Connection;   
import org.apache.ibatis.jdbc.ScriptRunner;   
import lombok.extern.slf4j.Slf4j;

@Slf4j
public class SqlScriptExecutor {

    public static void executeSqlScript(File file, Connection conn) throws Exception {
        Reader reader = new BufferedReader(new FileReader(file));
        log.info("Running script from file: " + file.getCanonicalPath());
        ScriptRunner sr = new ScriptRunner(conn);
        sr.setAutoCommit(true);
        sr.setStopOnError(true);
        sr.runScript(reader);
        log.info("Done.");
    }
    
}

Answer 8

对于我的简单项目，用户应该能够选择要执行的 SQL 文件。
由于我对其他答案不满意，并且无论如何我都在使用 Flyway，所以我仔细查看了 Flyway 代码。 DefaultSqlScriptExecutor 正在执行实际执行，因此我尝试弄清楚如何创建 DefaultSqlScriptExecutor 的实例。

基本上，以下代码片段加载一个String，将其拆分为单个语句并逐个执行。
Flyway 还提供除 StringResource 之外的其他 LoadableResource，例如 FileSystemResource。但我没有仔细观察过它们。

由于 DefaultSqlScriptExecutor 和其他类未由 Flyway 正式记录，请谨慎使用代码片段。

public static void execSqlQueries(String sqlQueries, Configuration flyWayConf) throws SQLException {
  // create dependencies FlyWay needs to execute the SQL queries
  JdbcConnectionFactory jdbcConnectionFactory = new JdbcConnectionFactory(flyWayConf.getDataSource(),
      flyWayConf.getConnectRetries(),
      null);
  DatabaseType databaseType = jdbcConnectionFactory.getDatabaseType();
  ParsingContext parsingContext = new ParsingContext();
  SqlScriptFactory sqlScriptFactory = databaseType.createSqlScriptFactory(flyWayConf, parsingContext);
  Connection conn = flyWayConf.getDataSource().getConnection();
  JdbcTemplate jdbcTemp = new JdbcTemplate(conn);
  ResourceProvider resProv = flyWayConf.getResourceProvider();
  DefaultSqlScriptExecutor scriptExec = new DefaultSqlScriptExecutor(jdbcTemp, null, false, false, false, null);
  
  // Prepare and execute the actual queries
  StringResource sqlRes = new StringResource(sqlQueries);
  SqlScript sqlScript = sqlScriptFactory.createSqlScript(sqlRes, true, resProv);
  scriptExec.execute(sqlScript);
}

Answer 9

我发现可移植的最简单的外部工具是 jisql - https://www.xigole .com/software/jisql/jisql.jsp 。
您可以将其运行为：

java -classpath lib/jisql.jar:\
          lib/jopt-simple-3.2.jar:\
          lib/javacsv.jar:\
           /home/scott/postgresql/postgresql-8.4-701.jdbc4.jar 
    com.xigole.util.sql.Jisql -user scott -password blah     \
    -driver postgresql                                       \
    -cstring jdbc:postgresql://localhost:5432/scott -c \;    \
    -query "select * from test;"

Answer 10

JDBC 不支持此选项（尽管特定的数据库驱动程序可能提供此选项）。
不管怎样，将所有文件内容加载到内存中应该不会有问题。

Answer 11

试试这个代码：

String strProc =
         "DECLARE \n" +
         "   sys_date DATE;"+
         "" +
         "BEGIN\n" +
         "" +
         "   SELECT SYSDATE INTO sys_date FROM dual;\n" +
         "" +
         "END;\n";

try{
    DriverManager.registerDriver ( new oracle.jdbc.driver.OracleDriver () );
    Connection connection = DriverManager.getConnection ("jdbc:oracle:thin:@your_db_IP:1521:your_db_SID","user","password");  
    PreparedStatement psProcToexecute = connection.prepareStatement(strProc);
    psProcToexecute.execute();
}catch (Exception e) {
    System.out.println(e.toString());  
}

Answer 12

如果您使用Spring，则可以使用DataSourceInitializer：

@Bean
public DataSourceInitializer dataSourceInitializer(@Qualifier("dataSource") final DataSource dataSource) {
    ResourceDatabasePopulator resourceDatabasePopulator = new ResourceDatabasePopulator();
    resourceDatabasePopulator.addScript(new ClassPathResource("/data.sql"));
    DataSourceInitializer dataSourceInitializer = new DataSourceInitializer();
    dataSourceInitializer.setDataSource(dataSource);
    dataSourceInitializer.setDatabasePopulator(resourceDatabasePopulator);
    return dataSourceInitializer;
}

用于在初始化期间设置数据库并清理数据库
销毁期间的数据库。

https： //docs.spring.io/spring-framework/docs/current/javadoc-api/org/springframework/jdbc/datasource/init/DataSourceInitializer.html