h2db - H2DB混合模式，客户端获取空查询

Question

我正在尝试为数据库连接构建某种单元测试。首先，我正在创建一个新连接和新表，填充它，然后检查数据是否存在，此时一切都很好。比客户端创建一个新连接并尝试获取相同的数据，但查询结果为空，0 行，2 列。

public class H2dbTest {

private static final String CREATE_TABLE = "CREATE TABLE TEST(ID varchar(12) primary key, NAME char(7))";
private static final String INSERT_QUERY = "INSERT INTO TEST(ID, NAME) VALUES (1234567,'TEST')";
private static final String SELECT_QUERY = "SELECT ID, NAME FROM TEST";

public static void main(String[] args) {
        DeleteDbFiles.execute("~", "test", true);
        Connection connection = getDBConnection();
        insertWithStatement(connection);
        readFromClient();
}

private static void insertWithStatement(Connection connection) {
    try {
        connection.setAutoCommit(false);
        Statement stmt = connection.createStatement();
        stmt.execute(CREATE_TABLE);
        stmt.execute(INSERT_QUERY);
        ResultSet rs = stmt.executeQuery(SELECT_QUERY);
        System.out.println("Check DB after insert");
        while (rs.next()) {
            System.out.println("Id " + rs.getInt("ID") + " Name " + rs.getString("NAME"));
        }
        stmt.closeOnCompletion();
    } catch (SQLException e) {
        System.out.println("Exception Message " + e.getLocalizedMessage());
    } catch (Exception e) {
        e.printStackTrace();
    }
}

private static void readFromClient(){
    Connection connection = null;
    try {
        connection = getDBConnection();
        connection.setAutoCommit(false);
        Statement stmt = connection.createStatement();
        ResultSet rs = stmt.executeQuery(SELECT_QUERY);
        System.out.println("Client DB query result");
        while (rs.next()) {
            System.out.println("Id " + rs.getInt("ID") + " Name " + rs.getString("ID"));
        }
    } catch (SQLException e) {
        System.out.println("Exception Message " + e.getLocalizedMessage());
    } catch (Exception e) {
        e.printStackTrace();
    } finally {
        connection.close();
    }
}
private static Connection getDBConnection() {
    Connection dbConnection = null;
    try {
        Class.forName(DB_DRIVER);
    } catch (ClassNotFoundException e) {
        System.out.println(e.getMessage());
    }
    try {
        dbConnection = DriverManager.getConnection(DB_CONNECTION, DB_USER, DB_PASSWORD);
        return dbConnection;
    } catch (SQLException e) {
        System.out.println(e.getMessage());
    }
    return dbConnection;
}

}

Answer 1

我错过了 connection.commit();