我有以下代码:
import java.sql.*;
class App {
public static void main(String[] args) {
HelloJdbc hj = new HelloJdbc();
hj.insertPerson();
hj.printPersons();
hj.close();
}
}
class HelloJdbc {
String url = "jdbc:h2:~/persons";
String username = "username";
String password = "password";
// Active connection
Connection con;
public HelloJdbc() {
try {
Connection con = DriverManager.getConnection(url, username, password); Statement st = con.createStatement();
// Making sure I have the same data every time
st.executeUpdate("DELETE FROM person");
st.executeUpdate("INSERT INTO person VALUES (1, 'Alice');");
this.con = con;
} catch (SQLException e) {}
}
void insertPerson() {
try {
con.setAutoCommit(false);
con.createStatement().executeUpdate("INSERT INTO person VALUES(2, 'Bob');");
} catch (SQLException e) {}
}
void printPersons() {
try (Connection con = DriverManager.getConnection(url, username, password);) {
ResultSet rs = con.createStatement().executeQuery("SELECT * FROM person;");
while (rs.next()) {
System.out.println(rs.getObject(1) + " " + rs.getObject(2));
}
} catch (SQLException e) {}
}
void close() {
try {
con.close();
} catch (Exception e) {}
}
}
当我运行此代码时,输出将为:
1 Alice
我理解,因为在insertPerson
中我有con.setAutoCommit(false);
但是,当我更改printPerson
方法如下,因此它使用活动连接而不是新连接:
void printPersons() {
try {
ResultSet rs = con.createStatement().executeQuery("SELECT * FROM person;");
while (rs.next()) {
System.out.println(rs.getObject(1) + " " + rs.getObject(2));
}
} catch (SQLException e) {}
}
输出更改为:
1 Alice
2 Bob
我很困惑,从连接创建新的语句是否会从先前的语句中提交所有内容?行为改变的原因是什么?
编译&使用javac App.java; java -cp ".:h2.jar" App;
在同一文件夹中使用App.java
的CC_4运行。
如果连接执行交易中的插入,更新或删除,则该连接的其他语句也将能够看到更改尚未提交,以便其他连接可以看到它们。
(实际上,在正常情况下,其他连接直到犯下更改,但是与read_uncomment的隔离级别的交易将允许其他连接在原始连接执行提交或回滚之前查看更改。)