JPA 加锁机制及@Version版本控制方式

更新时间：2021年10月15日 09:52:25 作者：black-ant

这篇文章主要介绍了JPA 加锁机制及@Version版本控制方式，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教

一简述悲观锁的用法

悲观锁通常是SQL级别的,通过读写时先拿到锁实现,在SQL语句中就会有体现.

1.1 EntityManager 用法

    return em.createQuery(sql 语句).setLockMode(LockModeType.NONE).getResultList();
    //分解写法大概是:
    Query query = getSession().createQuery(hql);
    query.setLockMode(LockModeType.NONE);

EntityManager 是一个辅助类,createQuery后返回的就是一个Query对象,然后通过

setLockMode设置锁的级别即可.

LockModeType 类型	解释
LockMode.READ	事务的隔离级别是Repeatable Read或Serializable时，请求读取数据库记录时自动获得
LockMode.WRITE	请求插入或更新数据库记录时自动获得
LockMode.OPTIMISTIC	乐观锁
LockMode.OPTIMISTIC_FORCE_INCREMENT	乐观锁,通过version控制
LockMode.PESSIMISTIC_READ	与LockMode.PESSIMISTIC_WRITE相同
LockMode.PESSIMISTIC_WRITE	事务开始即获得数据库的锁
LockMode.PESSIMISTIC_FORCE_INCREMENT	事务开始即设置version
LockMode.NONE	取消任何锁，如事务结束后的所有对象，或执行了Session的update()、

二乐观锁的详细用法

乐观锁本篇的主要内容

实体类是关键 , 乐观锁常用方法是通过version来控制 ,

数据库对应的表中需要有一个字段(名字随意),字段类型设置成BigInt即可
业务不对该字段进行控制,字段的控制交由系统处理
每一次修改都会导致version递增
当出现同时获得该记录的对象且均需要修改时,当第一个已经提交事务,version字段发生改变,后面提交的事务发现version版本不对,则无法提交,抛出异常

实体类(注意其中的@Version注解)

@Entity
public class User {
    @Id
    @GeneratedValue
    private Long id;
    private String username;
    private String userdesc;
    @Version
    private Long version;
    public User() {
    }
    public User(String username, String userdesc) {
        this.username = username;
        this.userdesc = userdesc;
    }
    public Long getId() {
        return id;
    }
    public void setId(Long id) {
        this.id = id;
    }
    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public String getUserDesc() {
        return userdesc;
    }
    public void setUserDesc(String userdesc) {
        this.userdesc = userdesc;
    }
    public Long getVersion() {
        return version;
    }
    public void setVersion(Long version) {
        this.version = version;
    }
}

controller中通过sleep将线程沉睡,测试事务的提交性

@RestController
public class UserController {
    private Logger logger = LoggerFactory.getLogger(getClass());
    @Autowired
    UserService userService;
    @PostMapping("/changeone")
    @Transactional
    public String changeone() {
        User user = userService.findUser("gang");
        try {
            logger.info("修改1 before:user--{}--Versdion:{}", user.getUserDesc(), user.getVersion());
            Thread.sleep(25000);
            user.setUserDesc("修改1");
            logger.info("修改1 :user--{}--version:{}", user.getUserDesc(), user.getVersion());
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (Exception e) {
            logger.info("eeeeeeeeeeeeee");
            e.printStackTrace();
        }
        return "true";
    }
    @PostMapping("/changetwo")
    @Transactional
    public String changetwo() {
        User user = userService.findUser("gang");
        try {
            logger.info("修改2 before:user--{}--version:{}", user.getUserDesc(), user.getVersion());
            Thread.sleep(30000);
            user.setUserDesc("修改2");
            logger.info("修改2:user--{}--version:{}", user.getUserDesc(), user.getVersion());
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (Exception e) {
            logger.info("eeeeeeeeeeeeee");
            e.printStackTrace();
        }
        return "true";
    }
    @PostMapping("/changethree")
    @Transactional
    public String changethree() {
        User user = userService.findUser("gang");
        logger.info("修改3 before:user--{}--version:{}", user.getUserDesc(), user.getVersion());
        user.setUserDesc("修改3");
        logger.info("修改3 :user--{}--version:{}", user.getUserDesc(), user.getVersion());
        return "true";
    }
    @PostMapping("/newuser")
    @Transactional
    public String newuser() {
        logger.info("save user");
        User user = new User();
        user.setUserDesc("第一次创建");
        user.setUsername("gang");
        userService.saveUser(user);
        return "true";
    }
}

以及service及repository

@Service
public class UserService {
    @Autowired
    UserRepository userRepository;
    public User findUser(String username){
        return userRepository.findByUsername(username);
    }
    public void saveUser(User user){
        userRepository.save(user);
    }
}
UserRepository 
public interface UserRepository extends JpaRepository<User,Long> {
    User findByUsername(String username);
}

总结

使用很简单,version是自动增长的,唯一的缺点是抛出的异常不易捕获,捕获的方法:

    @Resource
    private UserTransaction rtc;
     try {
            rtc.begin();
            User user = userService.findUser("gang");
            user .setDesc("异常捕获");
             rtc.commit();
        } catch (OptimisticLockException e) {
            throw new OptimisticLockException ();
        } catch (Exception e) {
            throw new Exception ();
        }

注意其中的 rtc.begin(); 以及 rtc.commit();

不同于@Transaction,这种是手动的提交方法

以上为个人经验，希望能给大家一个参考，也希望大家多多支持脚本之家。

您可能感兴趣的文章:

阿里SpringBoot应用自动化部署实现IDEA版Jenkins
这篇文章主要为大家介绍了阿里SpringBoot应用自动化部署实现IDEA版Jenkins过程详解，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-07-07
Java中的@Async异步功能详解
这篇文章主要介绍了Java中的@Async异步功能详解,@Async注解,可以实现异步处理的功能,它可以有返回值,或者直接在新线程时并行执行一个任务,对于异步来说,它的执行是有条件的,你需要把异步代码块放在单独的类里,需要的朋友可以参考下
2023-11-11
MyBatis-Plus模糊查询特殊字符串转义的实现
使用MyBatis中的模糊查询时,当查询关键字中包括有_、\、%时,查询关键字失效,本文主要介绍了MyBatis-Plus模糊查询特殊字符串转义的实现,感兴趣的可以了解一下
2024-06-06
nexus安装及配置图文教程
Nexus 是Maven仓库管理器,通过nexus可以搭建maven仓库,同时nexus还提供强大的仓库管理功能,构件搜索功能等,文中有非常详细的图文介绍,对小伙伴们很有帮助,需要的朋友可以参考下
2021-05-05
java 中ThreadLocal本地线程和同步机制的比较
这篇文章主要介绍了java 中ThreadLocal本地线程和同步机制的比较的相关资料,需要的朋友可以参考下
2017-03-03
Java使用Hutool执行日期的加法和减法操作方法
使用Hutool进行日期的加法和减法操作,可以使用`DateUtil.offsetXXX()`方法来实现,这些方法会返回一个新的日期,而不是在原日期上进行修改,本文给大家介绍Java使用Hutool执行日期的加法和减法操作方法,感兴趣的朋友一起看看吧
2023-11-11
Java实时监控日志文件并输出的方法详解
这篇文章主要给大家介绍了关于Java实时监控日志文件并输出的方法，文中通过示例代码介绍的非常详细，对大家具有一定的参考学习价值，需要的朋友们下面跟着小编一起来学习学习吧。
2017-06-06
springboot中pom.xml文件注入test测试依赖时报错的解决
这篇文章主要介绍了springboot中pom.xml文件注入test测试依赖时报错的解决，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-03-03
Java concurrency之AtomicLong原子类_动力节点Java学院整理
AtomicLong是作用是对长整形进行原子操作。下面通过本文给大家介绍Java concurrency之AtomicLong原子类的相关知识，感兴趣的朋友一起看看吧
2017-06-06
Java、C++中子类对父类函数覆盖的可访问性缩小的区别介绍
这篇文章主要给大家介绍了关于Java、C++中子类对父类函数覆盖的可访问性缩小的区别的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧。
2018-01-01