【JDBC】转账案例

import java.io.InputStream; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.SQLException; import java.util.Properties; import javax.sql.DataSource; import com.alibaba.druid.pool.DruidDataSourceFactory; public class DruidUtil { //1.创建一个连接池对象 private static DataSource dataSource; //静态代码创建，这样第一次使用这个类的时候就可以直接创建DataSource对象了 static{ try { //读取Druid.properties文件中的数据 创建连接池对象 InputStream is = DruidUtil.class.getClassLoader().getResourceAsStream("Druid.properties"); //创建properties集合载入流中数据 Properties pro = new Properties(); pro.load(is); //Druid工具载入pro集合中的数据 创建数据源对象 dataSource = DruidDataSourceFactory.createDataSource(pro); } catch (Exception e) { e.printStackTrace(); } } //2.创建方法 返回一个连接 public static Connection getConn() throws SQLException{ return dataSource.getConnection(); } //3.关闭所有资源 public static void closeAll(ResultSet rs, PreparedStatement pst, Connection conn) { if (rs != null) { try { rs.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (pst != null) { try { pst.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if (conn != null) { try { conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }

public class Student { private int sid; private String name; private int age; private String sex;    构造    set/get    toString }

/*  * 查询student类中的所有的信息 展示到控制台上  *  * */ @Test public  void selectAll() throws Exception{ //1.获取链接 Connection conn = DruidUtil.getConn(); System.out.println("Demo04 ======>selectAll() ======> 获取链接完毕 conn= "+conn); //2.通过链接获取SQL的发射器 String sql = "select * from student"; PreparedStatement pst = conn.prepareStatement(sql); //3.发射SQL语句 得到结果集 ResultSet rs = pst.executeQuery(); System.out.println("Demo04 ======>selectAll() ======> 发射完毕 rs= "+rs); //创建一个集合 List<Student> list = new ArrayList<Student>(); //4.处理结果集 while(rs.next()){ Student s = new Student(rs.getInt("sid"), rs.getString("name"), rs.getInt("age"), rs.getString("sex")); list.add(s); } //5.关闭资源 DruidUtil.closeAll(rs, pst, conn); //遍历 for(Student stu: list){ System.out.println(stu); } }

import java.sql.Connection; import java.sql.PreparedStatement; import com.czxy.util.DruidUtil; public class AccountDao { /*  * 从指定的账户中取钱（减钱）  * */ public void outMoney(String name,int money) throws Exception{ //1.获取链接 Connection conn = DruidUtil.getConn(); //2.发射器 String sql = "UPDATE account SET money=money-? WHERE NAME=?"; PreparedStatement pst = conn.prepareStatement(sql); pst.setInt(1, money); pst.setString(2, name); //3.发射 int num = pst.executeUpdate(); //4.处理结果 System.out.println("本次执行的影响的行数是： num="+num); //5.关闭资源 DruidUtil.closeAll(null, pst, conn); } /*  * 从指定的账户中存钱（加钱）  * */ public void inMoney(String name,int money) throws Exception{ //1.获取链接 Connection conn = DruidUtil.getConn(); //2.发射器 String sql = "UPDATE account SET money=money+? WHERE NAME=?"; PreparedStatement pst = conn.prepareStatement(sql); pst.setInt(1, money); pst.setString(2, name); //3.发射 int num = pst.executeUpdate(); //4.处理结果 System.out.println("本次执行的影响的行数是： num="+num); //5.关闭资源 DruidUtil.closeAll(null, pst, conn); } }

import com.czxy.dao.AccountDao; public class AccountService { /**  * 实现转账  * @param srcName : 钱的来源  * @param descName : 钱的去向  * @param money : 钱数  * */ public void transfer(String srcName,String descName,int money){ AccountDao ad = new AccountDao(); try { // -钱 ad.outMoney(srcName, money); // +钱 ad.inMoney(descName, money); System.out.println("转账完毕 "); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } } }

public class Demo02 { public static void main(String[] args) { //创建Service对象 AccountService as = new AccountService(); //张三 给 李四 转2块钱 as.transfer("张三", "李四", 2); } }

sql语句

描述

Connection对象的方法名

描述

/*  * 从指定的账户中取钱（减钱）  * */ public void outMoney(String name,int money,Connection conn) throws Exception{ //2.发射器 String sql = "UPDATE account SET money=money-? WHERE NAME=?"; PreparedStatement pst = conn.prepareStatement(sql); pst.setInt(1, money); pst.setString(2, name); //3.发射 int num = pst.executeUpdate(); //4.处理结果 System.out.println("本次执行的影响的行数是： num="+num); //5.关闭资源 只关闭结果集不关闭链接 DruidUtil.closeAll(null, pst, null); } /*  * 从指定的账户中存钱（加钱）  * */ public void inMoney(String name,int money,Connection conn) throws Exception{ //2.发射器 String sql = "UPDATE account SET money=money+? WHERE NAME=?"; PreparedStatement pst = conn.prepareStatement(sql); pst.setInt(1, money); pst.setString(2, name); //3.发射 int num = pst.executeUpdate(); //4.处理结果 System.out.println("本次执行的影响的行数是： num="+num); //5.关闭资源 只关闭结果集不关闭链接 DruidUtil.closeAll(null, pst, null); }

public void transfer(String srcName,String descName,int money){ AccountDao ad = new AccountDao(); Connection conn =null; try { //获取链接 conn = DruidUtil.getConn(); //把自动提交关闭，变成手动提交 conn.setAutoCommit(false); // -钱  传递连接对象 ad.outMoney(srcName, money,conn); //制造一个bug , 模拟转账出现问题 int a=1/0; // +钱  传递连接对象 ad.inMoney(descName, money,conn); //转账成功则手动提交事物 conn.commit(); System.out.println("转账完毕 "); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); if(conn!=null){ try { //操作失败 回滚 conn.rollback(); System.out.println("执行了回滚 ，把数据恢复原状 "); } catch (SQLException e1) { // TODO Auto-generated catch block e1.printStackTrace(); } } }finally { if(conn!=null){ try { //关闭链接 conn.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } }