import com.ibatis.common.jdbc.ScriptRunner; //导入依赖的package包/类
public INode executeScript(MappingTask mappingTask, AccessConfiguration accessConfiguration, AccessConfiguration tempAccessConfiguration,
        String sqlScript, Reader sourceSQLScriptReader, Reader sourceInstanceSQLScriptReader, Reader targetSQLScriptReader, Reader intermediateSQLScriptReader) throws DAOException {
    IConnectionFactory connectionFactory = null;
    Connection connection = null;
    try {
        String databaseName = extractDatabaseName(accessConfiguration);
        connectionFactory = new SimpleDbConnectionFactory();
        connection = connectionFactory.getConnection(tempAccessConfiguration);
        ScriptRunner scriptRunner = new ScriptRunner(connection, true, false);
        StringBuilder dropQuery = new StringBuilder();
        dropQuery.append("drop database ").append(databaseName).append(";");
        scriptRunner.runScript(new StringReader(dropQuery.toString()));
        StringBuilder createQuery = new StringBuilder();
        createQuery.append("create database ").append(databaseName).append(";");
        scriptRunner.runScript(new StringReader(createQuery.toString()));
    } catch (Exception ex) {
        logger.error(ex);
        throw new DAOException(ex);
    } finally {
        connectionFactory.close(connection);
    }
    return executeScript(mappingTask, accessConfiguration, sqlScript, sourceSQLScriptReader, sourceInstanceSQLScriptReader, targetSQLScriptReader, intermediateSQLScriptReader);
}
 

import com.ibatis.common.jdbc.ScriptRunner; //导入依赖的package包/类
protected static void initScript(String script) throws Exception {
  DataSource ds = sqlMap.getDataSource();

  Connection conn = ds.getConnection();

  Reader reader = Resources.getResourceAsReader(script);

  ScriptRunner runner = new ScriptRunner(conn, false, false);
  runner.setLogWriter(null);
  runner.setErrorLogWriter(null);

  runner.runScript(reader);
  conn.commit();
  conn.close();
  reader.close();
}
 

import com.ibatis.common.jdbc.ScriptRunner; //导入依赖的package包/类
private static void setupDB() throws SQLException, IOException {
    Connection connection = DriverManager.getConnection(DATABASE_URL + ";create=true");

    ScriptRunner scriptRunner = new ScriptRunner(connection, true, true);
    scriptRunner.runScript(new BufferedReader(new FileReader(path)));
    connection.close();
}
 

import com.ibatis.common.jdbc.ScriptRunner; //导入依赖的package包/类
public void runScriptFile() {
	
	final InformationFrame dialog = new InformationFrame();
	final String sqlFilePath = "src/com/coder/hms/connection/hotel_management_system.sql";
	final String DB_DRIVER = "com.mysql.cj.jdbc.Driver";
	final String DB_CONNECTION = "jdbc:mysql://localhost:3306/";
	String DB_USER = JOptionPane.showInputDialog(this, "Enter your database user name :", "Coder HMS [Input]", JOptionPane.QUESTION_MESSAGE);
	String DB_PASSWORD = JOptionPane.showInputDialog(this, "Enter your database password :", "Coder HMS [Input]", JOptionPane.QUESTION_MESSAGE);
	
		try {
			
			Class.forName(DB_DRIVER);
			Connection connection = DriverManager.getConnection(DB_CONNECTION, DB_USER, DB_PASSWORD);
			
			ScriptRunner runner = new ScriptRunner(connection, false, false);
			Reader br = new BufferedReader(new FileReader(sqlFilePath));

			file = new File(System.getProperty("user.dir")+ File.separator + "Logging Store/SQL_Logs.txt");
			PrintWriter writer = new PrintWriter(file);
			runner.setLogWriter(writer);
			runner.runScript(br);
			dialog.setMessage("Your database and tables created successfully.");
			
			status = true;
			
		} catch (SQLException | ClassNotFoundException | IOException ex) {
			dialog.setMessage(ex.getMessage());
			status = false;
		}
	
	dialog.setVisible(true);
}
 

import com.ibatis.common.jdbc.ScriptRunner; //导入依赖的package包/类
public static void setupDB() throws SQLException, IOException {

        Connection connection = DriverManager.getConnection(DATABASE_URL + ";create=true");

        ScriptRunner scriptRunner = new ScriptRunner(connection, true, true);
        scriptRunner.runScript(new BufferedReader(new FileReader(path)));

        connection.close();
    }