Spring事务传播隔离启动优化和回滚-----Spring框架

冷不防 2024-03-24 18:47 5阅读 0赞

>     package com.powernode.bank.service.impl;
>     
>     import com.powernode.bank.dao.AccountDao;
>     import com.powernode.bank.pojo.Account;
>     import org.springframework.stereotype.Service;
>     import org.springframework.transaction.annotation.Transactional;
>     
>     import javax.annotation.Resource;
>     import java.io.IOException;
>     
>     @Service("is2")
>     public class IsolationService2
>     {
>     //    READ_UNCOMMITTED读取未提交commit的事务信息(会导致脏读,不可复读(因为数据未保存到数据库,随时有可能修改),幻读)
>     //    READ_COMMITTED读取已经提交的数据(不会导致脏读,不可复读,因为数据一旦修改,还是会导致前后读到的数据不一样,幻读)
>     //    REPEATABLE_READ可复读的(读取数据后保持在缓存内,不会导致脏读,可复读,因为信息缓存了,会导致幻读,因为数据库信息别的事务也会修改)
>     //    SERIALIZABLE序列化(一旦数据被读取,其他事务就需要排队执行,不会导致脏读,不可复读和幻读,效率比较差)
>         @Resource(name = "accountDao")
>         private AccountDao accountDao;
>         //2号负责插入信息
>     //    @Transactional(readOnly = true,timeout = 5)
>         //设置为readOnly后,不能执行增删改语句,目的是提高select的查询效率,如果没有增删改,要启用readOnly
>         //readOnly完全不能增删改
>         //表示事务超时时间为10秒,超过10秒事务内所有的DML语句还没有执行完毕,该事务会回滚
>         //当前事务最后一条DML语句加上之前消耗的时间
>         //没有DML语句了就不再算了
>     //    @Transactional(rollbackFor = RuntimeException.class)
>         //发生RuntimeException或者其子类都回滚
>         @Transactional(rollbackFor = NullPointerException.class)
>         //当异常是空指针异常不回滚
>         public void save(Account act) throws IOException {
>             //如果DML语句先执行,则不会超时
>             accountDao.insert(act);
>             //模拟异常,IOException,编译时异常
>     //        if(1 == 1)
>     //        {
>     //            throw new IOException();
>     //        }
>             if(1 == 1)
>             {
>                 throw new RuntimeException();
>             }
>             //睡眠一会
>             try
>             {
>                 Thread.sleep(1000);
>             }
>             catch (InterruptedException e)
>             {
>                 throw new RuntimeException(e);
>             }
>     //        //睡眠一会
>     //        try
>     //        {
>     //            Thread.sleep(1000 * 6);
>     //        }
>     //        catch (InterruptedException e)
>     //        {
>     //            throw new RuntimeException(e);
>     //        }
>     //        //如果DML语句先执行,则不会超时
>     //        accountDao.insert(act);
>             //可以在这里写一句无关紧要的DML语句来方向利用这个特点计时
>         }
>     }
> 
>     package com.powernode.bank.service.impl;
>     
>     import com.powernode.bank.dao.AccountDao;
>     import com.powernode.bank.pojo.Account;
>     import org.springframework.stereotype.Service;
>     import org.springframework.transaction.annotation.Transactional;
>     
>     import javax.annotation.Resource;
>     import java.io.IOException;
>     
>     @Service("is2")
>     public class IsolationService2
>     {
>     //    READ_UNCOMMITTED读取未提交commit的事务信息(会导致脏读,不可复读(因为数据未保存到数据库,随时有可能修改),幻读)
>     //    READ_COMMITTED读取已经提交的数据(不会导致脏读,不可复读,因为数据一旦修改,还是会导致前后读到的数据不一样,幻读)
>     //    REPEATABLE_READ可复读的(读取数据后保持在缓存内,不会导致脏读,可复读,因为信息缓存了,会导致幻读,因为数据库信息别的事务也会修改)
>     //    SERIALIZABLE序列化(一旦数据被读取,其他事务就需要排队执行,不会导致脏读,不可复读和幻读,效率比较差)
>         @Resource(name = "accountDao")
>         private AccountDao accountDao;
>         //2号负责插入信息
>     //    @Transactional(readOnly = true,timeout = 5)
>         //设置为readOnly后,不能执行增删改语句,目的是提高select的查询效率,如果没有增删改,要启用readOnly
>         //readOnly完全不能增删改
>         //表示事务超时时间为10秒,超过10秒事务内所有的DML语句还没有执行完毕,该事务会回滚
>         //当前事务最后一条DML语句加上之前消耗的时间
>         //没有DML语句了就不再算了
>     //    @Transactional(rollbackFor = RuntimeException.class)
>         //发生RuntimeException或者其子类都回滚
>         @Transactional(rollbackFor = NullPointerException.class)
>         //当异常是空指针异常不回滚
>         public void save(Account act) throws IOException {
>             //如果DML语句先执行,则不会超时
>             accountDao.insert(act);
>             //模拟异常,IOException,编译时异常
>     //        if(1 == 1)
>     //        {
>     //            throw new IOException();
>     //        }
>             if(1 == 1)
>             {
>                 throw new RuntimeException();
>             }
>             //睡眠一会
>             try
>             {
>                 Thread.sleep(1000);
>             }
>             catch (InterruptedException e)
>             {
>                 throw new RuntimeException(e);
>             }
>     //        //睡眠一会
>     //        try
>     //        {
>     //            Thread.sleep(1000 * 6);
>     //        }
>     //        catch (InterruptedException e)
>     //        {
>     //            throw new RuntimeException(e);
>     //        }
>     //        //如果DML语句先执行,则不会超时
>     //        accountDao.insert(act);
>             //可以在这里写一句无关紧要的DML语句来方向利用这个特点计时
>         }
>     }

>     package com.powernode.bank.service.impl;
>     
>     import com.powernode.bank.dao.AccountDao;
>     import com.powernode.bank.pojo.Account;
>     import org.slf4j.Logger;
>     import org.slf4j.LoggerFactory;
>     import org.springframework.stereotype.Service;
>     import org.springframework.transaction.annotation.Isolation;
>     import org.springframework.transaction.annotation.Transactional;
>     
>     import javax.annotation.Resource;
>     
>     @Service("is")
>     public class IsolationService1
>     {
>         private static final Logger logger = LoggerFactory.getLogger(IsolationService1.class);
>         @Resource(name = "accountDao")
>         private AccountDao accountDao;
>         //1号负责查询信息
>         @Transactional(isolation = Isolation.READ_COMMITTED)
>         //设置为readOnly后,不能执行增删改语句,目的是提高select的查询效率,如果没有增删改,要启用readOnly
>         //READ_UNCOMMITTED当前事务可以读到隔壁事务没有提交的数据
>         //READ_COMMITTED读提交的
>         public void getByActNo(String actno)
>         {
>             Account account = accountDao.selectByAccountNo(actno);
>             logger.info(account.toString());
>         }
>     }
> 
>     package com.powernode.bank.service.impl;
>     
>     import com.powernode.bank.dao.AccountDao;
>     import com.powernode.bank.pojo.Account;
>     import org.slf4j.Logger;
>     import org.slf4j.LoggerFactory;
>     import org.springframework.stereotype.Service;
>     import org.springframework.transaction.annotation.Isolation;
>     import org.springframework.transaction.annotation.Transactional;
>     
>     import javax.annotation.Resource;
>     
>     @Service("is")
>     public class IsolationService1
>     {
>         private static final Logger logger = LoggerFactory.getLogger(IsolationService1.class);
>         @Resource(name = "accountDao")
>         private AccountDao accountDao;
>         //1号负责查询信息
>         @Transactional(isolation = Isolation.READ_COMMITTED)
>         //设置为readOnly后,不能执行增删改语句,目的是提高select的查询效率,如果没有增删改,要启用readOnly
>         //READ_UNCOMMITTED当前事务可以读到隔壁事务没有提交的数据
>         //READ_COMMITTED读提交的
>         public void getByActNo(String actno)
>         {
>             Account account = accountDao.selectByAccountNo(actno);
>             logger.info(account.toString());
>         }
>     }

>     @Test
>         public void Isolation()
>         {
>             ApplicationContext context = new ClassPathXmlApplicationContext("spring.xml");
>             IsolationService1 is = context.getBean("is", IsolationService1.class);
>             is.getByActNo("act-004");
>     //        读到了未提交的
>         }
>         @Test
>         public void TestIsolation() throws IOException {
>             ApplicationContext context = new ClassPathXmlApplicationContext("spring.xml");
>             IsolationService2 is2 = context.getBean("is2", IsolationService2.class);
>             Account account = new Account("act-004",1000);
>             is2.save(account);
>         }
> 
>     @Test
>         public void Isolation()
>         {
>             ApplicationContext context = new ClassPathXmlApplicationContext("spring.xml");
>             IsolationService1 is = context.getBean("is", IsolationService1.class);
>             is.getByActNo("act-004");
>     //        读到了未提交的
>         }
>         @Test
>         public void TestIsolation() throws IOException {
>             ApplicationContext context = new ClassPathXmlApplicationContext("spring.xml");
>             IsolationService2 is2 = context.getBean("is2", IsolationService2.class);
>             Account account = new Account("act-004",1000);
>             is2.save(account);
>         }