如何使用JPA加锁机制

这篇文章主要介绍"如何使用JPA加锁机制"，在日常操作中，相信很多人在如何使用JPA加锁机制问题上存在疑惑，小编查阅了各式资料，整理出简单好用的操作方法，希望对大家解答"如何使用JPA加锁机制"的疑惑有所帮助！接下来，请跟着小编一起来学习吧！

JPA的加锁机制有两种，乐观锁和悲观锁。

乐观锁：

乐观锁的特点在于认为数据冲突或者更新丢失等情况是很少发生的.当发生的时候,抛出异常和回滚就足够解决问题.

悲观锁：

悲观锁的逻辑在于认为每次数据操作都很有可能发生冲突,所以一开始就获得记录的锁,再进行记录的操作是解决问题的优先选择.

一 简述悲观锁的用法

悲观锁通常是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设置锁的级别即可.

二 乐观锁的详细用法

乐观锁本篇的主要内容

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

• 数据库对应的表中需要有一个字段(名字随意),字段类型设置成BigInt即可

• 业务不对该字段进行控制,字段的控制交由系统处理

• 每一次修改都会导致version递增

• 当出现同时获得该记录的对象且均需要修改时,当第一个已经提交事务,version字段发生改变,后面提交的事务发现version版本不对,则无法提交,抛出异常

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

@Entitypublic 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将线程沉睡,测试事务的提交性

@RestControllerpublic 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

@Servicepublic 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 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,这种是手动的提交方法

到此，关于"如何使用JPA加锁机制"的学习就结束了，希望能够解决大家的疑惑。理论与实践的搭配能更好的帮助大家学习，快去试试吧！若想继续学习更多相关知识，请继续关注网站，小编会继续努力为大家带来更多实用的文章！