问题描述
我正在尝试为数据库连接构建某种单元测试。 首先,我创建一个新连接和新表,填充它,然后检查数据是否存在,此时一切都很好。 比客户端创建新连接并尝试获取相同数据但查询结果为空,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;
}
}
解决方法
我错过了 connection.commit();