import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
public boolean isHandled(SQLException e, String sql, SqlFile file, Connection newConnection) {
  String lowerCaseSql = sql.toLowerCase();
  switch (e.getErrorCode()) {
  case 3701:
    if (lowerCaseSql.contains("drop")) {
      // droping not existing object
      LOG.warn("Cannot %S_MSG the %S_MSG '%.*ls', because it does not exist or you do not have permission. Ignoring error.");
      return true;
    }
    return false;
  case 2627:
    if (lowerCaseSql.contains("values")) {
	    // insert existing row 
      LOG.warn("Cannot insert duplicate key in object. Ignoring error.");
      return true;
    }
    return false;
  case 2714:
 // create existing object
    LOG.warn("There is already an object named. Ignoring error.");
    return true;
  default:
    return false;
  }
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
@Override
public boolean isHandled(SQLException e, String sql, SqlFile sqlFile, Connection newConnection) {
  String lowerCaseSql = sql.toLowerCase();

  LOG.info("ErrorCode = [" + e.getErrorCode() + "]; SQLState = [" + e.getSQLState() + "]");

  try {
    //IGNORED_SQL_STATE state = IGNORED_SQL_STATE.valueOf("_" + e.getSQLState());
    // O1 class is ignored because it is of warning class.
    
    boolean ignored = e.getSQLState().startsWith("01"); //|| state.isIgnored(lowerCaseSql);
    if (sqlFile != null && ignored) {
      // In case an error was handled e.g. script execution should continue we must reset connection
      sqlFile.getConnection().rollback();
      // XXX: do we need to close old connection here?
      sqlFile.setConnection(newConnection);
    }
    return ignored;
  } catch (IllegalArgumentException iae) {
    return e.getSQLState().startsWith("01");
  } catch (SQLException sqlException) {
    LOG.error(sqlException);
    return false;
  }
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
private void createSchema(Connection conn) throws IOException, SqlToolError, SQLException {
    // Note that the character set should match the encoding in pom.xml
    Charset charset = Charset.forName("Cp1252");
    SqlFile sqlFile = new SqlFile(
                    new InputStreamReader(LogAnalyzer.class.getResourceAsStream("/create_schema.sql"), charset),
                    "create schema", null, null, false, null);
    sqlFile.setConnection(conn);
    sqlFile.setAutoClose(true);
    sqlFile.execute();
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
@BeforeClass
public static void setUpClass() throws IOException, SqlToolError, SQLException {
    // On crée la connection vers la base de test "in memory"
    myDataSource = getDataSource();
    myConnection = myDataSource.getConnection();
    // On initialise la base avec le contenu d'un fichier de test
    String sqlFilePath = GeneralDAO_Test.class.getResource("sample.sql").getFile();
    SqlFile sqlFile = new SqlFile(new File(sqlFilePath));

    sqlFile.setConnection(myConnection);
    sqlFile.execute();
    sqlFile.closeReader();
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
public static void deployDatabaseSchemaAndData(String jdbcUrl, String username, String password)
    throws IOException, SqlToolError, SQLException {

    Connection connection = null;
    try {
        connection = DriverManager.getConnection(jdbcUrl, username, password);
        InputStreamReader isr = new InputStreamReader(Thread.currentThread().getContextClassLoader()
            .getResourceAsStream(HSQLDB_SCHEMA_AND_DATA_SQL), System.getProperty("file.encoding"));
        SqlFile sqlFile = new SqlFile(isr, "--sql", System.out, null, false, null);
        sqlFile.setConnection(connection);
        sqlFile.execute();
    } finally {
        quietClose(connection);
    }
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
@Given("^Dataset (.*) loaded.$")
public void runSQLScript(String fileName) {
    try {
        SqlFile sqlFile = new SqlFile(new File(fileName));
        Connection c = getConnectionOnIntegration();
        c.setAutoCommit(false);
        sqlFile.setConnection(c);
        sqlFile.execute();
        c.commit();
        c.close();
    } catch (Exception e) {
        _log.error("Error when loading the Dataset: " + fileName, e);
        Assert.fail();
    }
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
@Before
public void initDatabase() throws IOException, SQLException, SqlToolError {
    Properties props = new Properties();
    props.load(this.getClass().getResourceAsStream("/unittest-db.properties"));
    conn = DriverManager.getConnection(props.getProperty("jdbc.url"), props.getProperty("username"), props.getProperty("password"));
    repo = new StatsRepository(conn);
    String sqlFilePath = getClass().getResource("/test.sql").getFile();
    SqlFile sqlFile = new SqlFile(new File(sqlFilePath));

    sqlFile.setConnection(conn);
    sqlFile.execute();
    sqlFile.closeReader();
    conn.commit();
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
public boolean isHandled(SQLException e, String sql, SqlFile file, Connection newConnection) {
  Scanner words = new Scanner(sql.toLowerCase());
  try {
    return isHandled(e, sql, words);
  } finally {
    words.close();
  }
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
public boolean isHandled(SQLException e, String sql, SqlFile sqlFile, Connection newConnection) {
  switch (e.getErrorCode()) {
  case -141:
    LOG.warn("Table not found. Ignoring error.");
    return true;
  case -110:
    LOG.warn("Item already exists. Ignoring error.");
    return true;
  default:
    return false;
  }
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
public boolean isHandled(SQLException e, String sql, SqlFile sqlFile, Connection newConnection) {
  boolean ignored = handler.isHandled(e, sql, sqlFile, newConnection);

  String logMessage = (ignored ? "IGNORED:" : "FATAL:") + e.getMessage();
  log(sql, 0, e.getErrorCode(), logMessage, -0.01);
  return ignored;
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
public static void handleDataAccessException(SQLException e, String sql, SQLExceptionHandler handler, SqlFile sqlFile, Connection newConnection)
    throws SQLException {
  if (!handler.isHandled(e, sql, sqlFile, newConnection)) {
    LOG.info("\n\nERROR is not handled\n\n");
    throw e;
  }
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
private void openCommandPrompt(Connection conn) throws IOException, SqlToolError, SQLException {
    SqlFile sqlFile = new SqlFile(null, true);
    sqlFile.setConnection(conn);
    sqlFile.execute();
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
public void setSqlFile(SqlFile sqlFile) {
  this.sqlFile = sqlFile;
}
 

import org.hsqldb.cmdline.SqlFile; //导入依赖的package包/类
boolean isHandled(SQLException e, String sql, SqlFile sqlFile, Connection newConnection);