数据库事务性

TPL：事务控制语句

start transaction:开启一次事务
rollback:回滚
commit：提交事务

JDBC中与事务有关的方法：
Connection.setAutoCommit(boolean b)
Connection.rollback()
Connection.rollback(Savepoint sp)
Connection.commit();

*****四、事务的特性（隔离级别）
A:原子性。说明事务是一个不可分割的单位。
C：一致性.事务必须使数据库从一个一致性状态变换到另外一个一致性状态.(比如转账)
*I：隔离性。一个事务不能被其他事务打扰。
D：持久性。事务一旦提交，就应该被永久保存起来。

如果不考虑事务的隔离级别，会出现以下“不正确”的情况：
脏读：指一个事务读到了另一个事务中未提交的数据。
不可重复读：针对一条记录的，同一条记录前后不一样
虚读（幻读）：针对一张表，前后读到的记录条数不一样。

MySQL中控制事务隔离级别的语句：
select @@tx_isolation; //查看当前的事务隔离级别
set transaction isolation level 你的级别（四种之一）;//设置隔离级别

隔离级别的分类：
READ UNCOMMITTED(未授权读):脏读、不可重复读、虚读都有可能发生。
READ COMMITTED(授权读):能避免脏读，不可重复读、虚读都有可能发生。
REPEATABLE READ(可重复读):能避免脏读、不可重复度，虚读都有可能发生。
SERIALIZABLE(序列化):能避免脏读、不可重复度、虚读。

oracle隔离级别 只有READ COMMITTED和 SERIALIZABLE

因为当有人对数据库的数据进行任何写操作（DML操作）时，Oracle数据库系统首先将原始的数据复制到回滚段中，之后才做相应的操作，在事务处理结束之前其他的用户可以读这些数据，但是读到的都是回滚段上的数据。

create table bank
{
　　id int primary key,
　　name varchar(10),
　　money int
}

搭建数据库连接

c3p0-config.xml下

<?xml version="1.0" encoding="UTF-8"?>
<c3p0-config>
    <default-config>
        <property name="driverClass">com.mysql.jdbc.Driver</property>
        <property name="jdbcUrl">jdbc:mysql://127.0.0.1:3306/bank</property>
        <property name="user">root</property>
        <property name="password">mima</property>
    </default-config>
</c3p0-config>

JdbcUtil.java   导入相关的类

public class JdbcUtil {
    private static ComboPooledDataSource dataSource =new ComboPooledDataSource();
    public static ComboPooledDataSource getDataSource()
    {
        return dataSource;
    }
}

测试代码 。 注意 事务是针对一次连接Connection的，如果

 QueryRunner runner =new  QueryRunner(ds);    的话可能对于连接 会有不同的Connecton就达不到效果了

    public static void main(String[] args) throws Exception  {
        DataSource ds=JdbcUtil.getDataSource();
        Connection con=ds.getConnection();
        QueryRunner runner =new  QueryRunner();        
        try {
            con.setAutoCommit(false);
        } catch (SQLException e1) {
            e1.printStackTrace();
        }
        try {
            String sql1="update money_table set money=money+1000 where name = ?";
            runner.update(con,sql1, new Object[]{"aa"});
            int i=1/0;
            String sql2="update money_table set money=money-1000 where name = ?";
            runner.update(con,sql2, new Object[]{"bb"});
            con.commit();
        
        } catch (Exception e) {
            try {
                con.rollback();
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        }
        finally
        {
            
        }

    }

数据正常。

    public static void main(String[] args) throws Exception  {
        DataSource ds=JdbcUtil.getDataSource();
        Connection con=ds.getConnection();
        QueryRunner runner =new  QueryRunner();        
        try {
            con.setAutoCommit(false);
        } catch (SQLException e1) {
            e1.printStackTrace();
        }
        Savepoint sp=null;
        try {
            String sql1="update money_table set money=money+1000 where name = ?";
            runner.update(con,sql1, new Object[]{"aa"});    
            String sql2="update money_table set money=money-1000 where name = ?";
            runner.update(con,sql2, new Object[]{"bb"});
            sp=con.setSavepoint();
            int i=1/0;
            String sql3="update money_table set money=money+1000 where name = ?";
            runner.update(con,sql3, new Object[]{"cc"});
            String sql4="update money_table set money=money-1000 where name = ?";
            runner.update(con,sql4, new Object[]{"dd"});
        
        
        } catch (Exception e) {
            try {
                con.rollback(sp);
            } catch (SQLException e1) {
                e1.printStackTrace();
            }
            e.printStackTrace();
        }
        finally
        {
            con.commit();
        }

    }