Java--事务，操作数据库，实现转账

╰+攻爆jí腚メ 2022-05-19 02:42 276阅读 0赞

更新：2019/3/29

**目录**

简介

事务的四个特性

一个小Demo

目录结构

jdbc.properties

JDBCUtil.java

TestTransaction.java【核心代码】

数据库

demo2

--------------------

# 简介 #

事务（Transaction） 其实指的一组操作，里面包含许多个单一的逻辑。只要有一个逻辑没有执行成功，那么都算失败。 所有的数据都回归到最初的状态(回滚)

简单的说：银行要把张三的钱转到李四的账户上。张三扣钱，李四加钱。这两个操作要都成功才算转账成功，不能张三扣完钱，李四没收到。事务就是解决这样的问题。

# 事务的四个特性 #

事务应该具有4个属性：原子性、一致性、隔离性、持久性。这四个属性通常称为**ACID特性**。

**原子性（atomicity）**。一个事务是一个不可分割的工作单位，事务中包括的诸操作要么都做，要么都不做。

**一致性（consistency）**。事务必须是使数据库从一个一致性状态变到另一个一致性状态。一致性与原子性是密切相关的。

**隔离性（isolation）**。一个事务的执行不能被其他事务干扰。即一个事务内部的操作及使用的数据对并发的其他事务是隔离的，并发执行的各个事务之间不能互相干扰。

**持久性（durability）**。持久性也称永久性（permanence），指一个事务一旦提交，它对数据库中数据的改变就应该是永久性的。接下来的其他操作或故障不应该对其有任何影响。

# 一个小Demo #

## 目录结构 ##

记得导入my-connector jar包和JUnt 5

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyOTY1MTg3_size_16_color_FFFFFF_t_70][]

## jdbc.properties ##

连接数据库的配置文件

driverClass=com.mysql.cj.jdbc.Driver
    url=jdbc:mysql://localhost/bank?useSSL=false&serverTimezone=UTC
    name=root
    password=123456

要操作的是bank数据库 ，url是mysql8的写法，不然会报错

## JDBCUtil.java  ##

工具类，直接用

package com.zhujunwei.utils;
    
    import java.io.InputStream;
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    import java.util.Properties;
    
    public class JDBCUtil {
    	
    	static String driverClass = null;
    	static String url = null;
    	static String name = null;
    	static String password= null;
    	
    	static{
    		try {
    			//1. 创建一个属性配置对象
    			Properties properties = new Properties();
    //			InputStream is = new FileInputStream("jdbc.properties");
    			
    			
    			//使用类加载器，去读取src底下的资源文件。 后面在servlet
    			InputStream is = JDBCUtil.class.getClassLoader().getResourceAsStream("jdbc.properties");
    			//导入输入流。
    			properties.load(is);
    			
    			//读取属性
    			driverClass = properties.getProperty("driverClass");
    			url = properties.getProperty("url");
    			name = properties.getProperty("name");
    			password = properties.getProperty("password");
    			
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	
    	/**
    	 * 获取连接对象
    	 * @return
    	 */
    	public static Connection getConn(){
    		Connection conn = null;
    		try {
    			Class.forName(driverClass);
    			//静态代码块 ---> 类加载了，就执行。 java.sql.DriverManager.registerDriver(new Driver());
    			//DriverManager.registerDriver(new com.mysql.jdbc.Driver());
    			//DriverManager.getConnection("jdbc:mysql://localhost/test?user=monty&password=greatsqldb");
    			//2. 建立连接 参数一： 协议 + 访问的数据库 ， 参数二： 用户名 ， 参数三： 密码。
    			conn = DriverManager.getConnection(url, name, password);
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    		return conn;
    	}
    	
    	/**
    	 * 释放资源
    	 * @param conn
    	 * @param st
    	 * @param rs
    	 */
    	public static void release(Connection conn , Statement st , ResultSet rs){
    		closeRs(rs);
    		closeSt(st);
    		closeConn(conn);
    	}
    	public static void release(Connection conn , Statement st){
    		closeSt(st);
    		closeConn(conn);
    	}
    
    	
    	private static void closeRs(ResultSet rs){
    		try {
    			if(rs != null){
    				rs.close();
    			}
    		} catch (SQLException e) {
    			e.printStackTrace();
    		}finally{
    			rs = null;
    		}
    	}
    	
    	private static void closeSt(Statement st){
    		try {
    			if(st != null){
    				st.close();
    			}
    		} catch (SQLException e) {
    			e.printStackTrace();
    		}finally{
    			st = null;
    		}
    	}
    	
    	private static void closeConn(Connection conn){
    		try {
    			if(conn != null){
    				conn.close();
    			}
    		} catch (SQLException e) {
    			e.printStackTrace();
    		}finally{
    			conn = null;
    		}
    	}
    }

## TestTransaction.java【核心代码】 ##

package com.zhujunwei;
    
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    import org.junit.Test;
    
    import com.zhujunwei.utils.JDBCUtil;
    
    public class TestTransaction {
    	@Test
    	public void test() {
    		
    		Connection conn = null ;
    		PreparedStatement ps = null ;
    		System.out.println("-----");
    		try {
    			conn = JDBCUtil.getConn();
    			//1.关闭自动提交
    			conn.setAutoCommit(false);
    			String sql = "update account set money = money- ? where id = ?";
    			ps = conn.prepareStatement(sql);
    			
    			//减钱
    			ps.setInt(1, 100);
    			ps.setInt(2,1);
    			int len = ps.executeUpdate();
    			System.out.println("成功修改"+len+"行。");
    			
                            //手工加的异常,程序要想正常运行请注释
                            int a = 10/0;
                                
    			//加钱
    			ps.setInt(1, -100);
    			ps.setInt(2,2);
    			len = ps.executeUpdate();
    			System.out.println("成功修改"+len+"行。");
    			
    			//2.提交数据
    			conn.commit();
    		} catch (SQLException e) {
    			//3.异常就回滚
    			try {
    				conn.rollback();
    			} catch (SQLException e1) {
    				e1.printStackTrace();
    			}
    			e.printStackTrace();
    		} finally {
    			JDBCUtil.release(conn, ps);
    		}
    	}
    }

##  数据库 ##

![20190108203832529.png][]

1.  运行一波，在test()方法上鼠标右键，Run as >Junit Test

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyOTY1MTg3_size_16_color_FFFFFF_t_70 1][]

2. 你会发现程序出现错了，但是扣款是成功的，你回到数据库看一下，发现并没有变，这是因为**回滚**了。

把int a = 10/0;注释掉再运行一下。

![20190108204512366.png][]

3.运行是成功的，回到数据库看一下，发现数据库改变了。

![20190108204604836.png][]

#  demo2 #

以前的老例子了，不看也罢。

package com.zjw.jdbc;
    
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.PreparedStatement;
    import java.sql.SQLException;
    
    /**
     * 
     * @描述：事务：转账
     * @作者: zjw
     * @时间: 2018年7月19日 上午11:06:43
     */
    public class TranferMain
    {
    	public static void main(String[] args)
    	{
    		String fromName = "张三1" ;
    		String toName = "李四2" ;
    		double money = 1 ;
    		
    		tranfer(fromName,toName,money);
    	}
    
    	private static void tranfer(String fromName, String toName, double money)
    	{
    		Connection connection = null ;
    		PreparedStatement ps = null ;
    		try
    		{
    			Class.forName("com.mysql.cj.jdbc.Driver");
    			String url = "jdbc:mysql://localhost:3306/myfirst?useSSL=false&serverTimezone=UTC";
    			String user = "root";
    			String password = "123456";
    			connection = DriverManager.getConnection(url, user, password);
    			/* 一个链接里面的所有sql语句要么都成功,要么都失败 
    			 * 
    			 * 自动提交
    			 * */
    			boolean flag = connection.getAutoCommit();
    			/* 不让自动提交
    			 * mysql等数据库是自动提交的,
    			 * 但是oracle:需要手动提交
    			 *  */
    			connection.setAutoCommit(false);
    			
    			String sql = "update student set balance = balance-? where name = ?";
    			ps = connection.prepareStatement(sql);
    			ps.setObject(1, money);
    			ps.setObject(2, fromName);
    			int res = ps.executeUpdate();
    			if(res>0)
    			{
    				System.out.println(fromName+"扣钱成功"+"扣钱："+money);
    				ps.close();
    				sql = "update student set balance = balance+? where name = ?"; 
    				ps = connection.prepareStatement(sql);
    				ps.setObject(1, money);
    				ps.setObject(2, toName);
    				res = ps.executeUpdate();
    				if(res>0)
    				{
    					System.out.println(toName+"收钱成功"+"收钱："+money);
    					//提交事务
    					connection.commit();
    					//还原现场
    					connection.setAutoCommit(flag);
    				}
    				
    			}
    			
    		} catch (Exception e)
    		{
    			e.printStackTrace();
    			//回滚
    			if (connection != null)
    			{
    				try
    				{
    					connection.rollback();
    				} catch (SQLException e1)
    				{
    					e1.printStackTrace();
    				}
    			}
    		} finally
    		{
    			try
    			{
    				ps.close();
    				ps = null ;
    			} catch (SQLException e)
    			{
    				e.printStackTrace();
    			}
    			try
    			{
    				connection.close();
    				connection = null ;
    			} catch (SQLException e)
    			{
    				e.printStackTrace();
    			}
    		}
    	}
    	
    }

![70][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyOTY1MTg3_size_16_color_FFFFFF_t_70]: /images/20220519/f2ce9c873d3e414a8779432915be5ada.png
[20190108203832529.png]: /images/20220519/f1edd341ddf949e185bea40793aba2f1.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzMyOTY1MTg3_size_16_color_FFFFFF_t_70 1]: /images/20220519/8828d8332ac44503af57de3a5519ad4b.png
[20190108204512366.png]: /images/20220519/f7f1957f4fbc4f3f9fd4a64fc6cc4e36.png
[20190108204604836.png]: /images/20220519/22442ba2e57041adbb75e052fb07e972.png
[70]: /images/20220519/6575805a5e2342f891cfb632594d3563.png