根据提示,在右侧编辑器补充代码,编写一条新增SQL语句和任意一条错误的SQL语句,提交事务;要求第一条新增语句在数据库中被修改,其后错误SQL语句不执行。 正确的新增插入语句如下: 在mydb数据库student表中新增一条id为4,name为赵六,sex为女,age为21的数据。 错误的SQL语句如下: ps = conn.prepareStatement("insert in student(id,name,sex,age) values(5,'钱七','男',18)"); 提示: 事务回滚都会放在catch中来捕获。 每一条SQL语句之后都可提交事务。 预期输出: 1 张三 男 19 2 李四 女 18 3 王五 男 20 4 赵六 女 21
时间: 2024-03-07 13:49:06 浏览: 89
以下是代码实现:
```java
import java.sql.*;
public class TransactionTest {
public static void main(String[] args) {
Connection conn = null;
PreparedStatement ps = null;
try {
// 加载数据库驱动
Class.forName("com.mysql.jdbc.Driver");
// 获取数据库连接
conn = DriverManager.getConnection("jdbc:mysql:///mydb", "root", "password");
// 关闭自动提交事务
conn.setAutoCommit(false);
// 插入一条新记录
ps = conn.prepareStatement("insert into student(id, name, sex, age) values(4, '赵六', '女', 21)");
ps.executeUpdate();
System.out.println("新增数据成功!");
// 错误的SQL语句,引发SQLException异常,导致事务回滚
ps = conn.prepareStatement("insert in student(id,name,sex,age) values(5,'钱七','男',18)");
ps.executeUpdate();
System.out.println("执行SQL语句成功!");
// 提交事务
conn.commit();
System.out.println("事务提交成功!");
} catch (ClassNotFoundException e) {
e.printStackTrace();
} catch (SQLException e) {
e.printStackTrace();
try {
// 事务回滚
if (conn != null) {
conn.rollback();
System.out.println("事务回滚成功!");
}
} catch (SQLException ex) {
ex.printStackTrace();
}
} finally {
// 关闭数据库连接和PreparedStatement对象
try {
if (ps != null) {
ps.close();
}
if (conn != null) {
conn.close();
}
} catch (SQLException e) {
e.printStackTrace();
}
}
}
}
```
在该代码中,我们先将数据库连接的autoCommit属性设置为false,以开启事务。然后执行第一条SQL语句插入一条新记录,接着执行第二条SQL语句,由于该SQL语句存在语法错误,将引发SQLException异常,导致事务回滚。最后在catch块中手动回滚事务,关闭数据库连接和PreparedStatement对象。
阅读全文