dao类
package cn.day1802;
import java.sql.Connection;
import java.sql.PreparedStatement;public class AccountDao {
public void updateBalance(Connection con,String name,double balance) {
try {
String sql = "update account set balance=balance+? where name=?";
PreparedStatement pt = con.prepareStatement(sql);
pt.setDouble(1, balance);
pt.setString(2, name);
pt.executeUpdate();
}catch(Exception e) {
}
}
}
Dome1 类 测试类
package cn.day1802;
import java.sql.Connection;
import java.sql.SQLException;public class Demo1 {
public static void main(String[] args) {
transferMoney("李明", "李芳", 100); //向转帐方法传值,李明给李芳转100元钱
}
public static void transferMoney(String from, String to,double money) {
Connection con = null;
System.out.println(1);
try {
con = JdbcUtils.getConnection();
//开启事务
con.setAutoCommit(false);
System.out.println(2);
AccountDao dao = new AccountDao();
dao.updateBalance(con,from, -money);//给from减去相应金额 李明减100元
dao.updateBalance(con,to, money);//给from加上相应金额 李芳加100元
//执行事务
System.out.println(3);
con.commit();
con.close();
}catch(Exception e) {
//回滚事务
try {
con.rollback();
con.close();
} catch (SQLException e1) {
}
}
}
}
查看隔离级别
select @@tx_isolation 查看隔离级别
set transaction siolationlevel 设置隔离级别
在jdbc 设置隔离级别
con.setTransactionIsoIation(int level)