Hibernate中事务小案例

发布时间：2023-09-06 01:44责任编辑：熊小新关键词：Hibernate

理论知识：

什么是事务？

指作为单个逻辑工作单位执行的一系列操作，要么完全的执行，要么完全不执行。事务处理可以确保非事务性单元内的所有操作都完全完成，否则永久不会更新面向数据的资源。通过将一组操作组合为一个要么成功要么失败的单元，可以简化错误恢复并使应用程序更加可靠。

并发控制概述

事务是并发控制的基本单位，保证事务ACID的特性是事务处理的重要任务，而并发操作有可能会破坏其ACID特性。

DBMS并发控制机制的责任：

对并发操作进行正确调度，保证事务的隔离性更一般，确保数据库的一致性。

事务并发的问题：

（1）脏读：读到另一个事务未提交前的数据。

（2）不可重复读：同一条记录2次读取到的数据不一样。

（3）幻读（虚读）：同一个表，2次查询到的数据不一样。

事务的隔离级别：

（1）读，未提交（read uncommited）：什么都没解决，性能最好，一般不用。

（2）读已提交数据（read commited）：Oracle默认，解决了脏读。

（3）可重复读（repeatable read）：Mysql默认，解决了脏读，不可重复读。

（4）串行化（serializable序列化），容易产生死锁。解决所有上述并发问题。

#查询事务隔离级别SELECT @@tx_isolation;#修改隔离级别SET SESSION TRANSACTION ISOLATION LEVEL read UNCOMMITTED ;

案例演示：

A向B转账，A金额减少，B金额增加。若转账中出现问题，则A和B的金额都不变。

public class User { ???private Integer uid; ??// private String uid; ???private String ?name; ???private String ?password; ???private Double ?balance; //金额 ???public Integer getUid() { ???????return uid; ???} ???public void setUid(Integer uid) { ???????this.uid = uid; ???} ???public String getName() { ???????return name; ???} ???public void setName(String name) { ???????this.name = name; ???} ???public String getPassword() { ???????return password; ???} ???public void setPassword(String password) { ???????this.password = password; ???} ???public Double getBalance() { ???????return balance; ???} ???public void setBalance(Double balance) { ???????this.balance = balance; ???} ???@Override ???public String toString() { ???????return "User{" + "uid=" + uid + ", name=‘" + name + ‘\‘‘ + ", password=‘" + password + ‘\‘‘ + ", balance=" + balance + ‘}‘; ???}}

实体类

 1 <!DOCTYPE hibernate-mapping PUBLIC 2 ????????"-//Hibernate/Hibernate Mapping DTD 3.0//EN" 3 ????????"http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd"> 4 <hibernate-mapping> 5 ????<!-- 6 ????name:User的相对路径 7 ????table:数据库表的名称 8 ????--> 9 ????<class name="a_helloworld.entity.User" table="t_user">10 ????????<!--11 ????????一个类标签里面必须有一个id.12 ????????hibernate要求实体类有一个属性是唯一值。13 ????????column：数据库列名 ?可以省略，省略的话默认和name的值一样14 ????????-->15 ????????<id name="uid" column="uid">16 ????????????<!--17 ????????????主键的生成策略18 ????????????native:主键自动增长19 ????????????uuid:自动生成一个长度为32的字符串20 ????????????-->21 ????????????<generator class="native"></generator>22 ????????</id>23 ????????<!--24 ????????其他普通属性25 ????????type:一般不去设置 框架会自动对应26 ????????not-null:非空27 ????????-->28 ????????<property name="name"></property>29 ????????<property name="password"></property>30 ????????<property name="balance"></property>31 ????</class>32 </hibernate-mapping>

实体类映射文件

 1 <!DOCTYPE hibernate-configuration PUBLIC 2 ????????"-//Hibernate/Hibernate Configuration DTD 3.0//EN" 3 ????????"http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd"> 4 <hibernate-configuration> 5 ????<session-factory> 6 ????????<!--1 数据库信息--> 7 ????????<property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property> 8 ????????<property name="hibernate.connection.url">jdbc:mysql://localhost:3306/hibernate001?characterEncording=UTF-8</property> 9 ????????<property name="hibernate.connection.username">root</property>10 ????????<property name="hibernate.connection.password">123456</property>11 12 ????????<!--2 配置hibernate信息 ?可选部分-->13 ????????<!--在控制台输出底层sql语句14 ????????项目在开发阶段设置为true ?项目发布的时候改成false15 ????????因为日志信息会写在文件中（io操作），浪费额外的资源16 ????????-->17 ????????<property name="show_sql">true</property>18 ????????<!--对输出的sql语句进行格式化-->19 ????????<property name="format_sql">true</property>20 21 ????????<!--hibernate帮助我们创建表的策略需要配置22 ??????????create:每次执行都重新创建表，数据会丢失23 ??????????update:如果已经有表，更新。如果没有就创建（一般使用）24 ??????????create-drop:每次执行都重新创建，数据丢失（开发的时候使用）25 ??????????validate:校验。每次运行校验数据库表是否正确（不会更新或创建表）26 ????????-->27 ????????<property name="hbm2ddl.auto">update</property>28 29 ????????<!--配置数据库方言30 ????????告诉hibernate你用的是什么方言31 ????????Mysql:limit32 ????????oracle:rownum33 ????????让hibernate识别不同数据库的自己特有的语句34 ????????-->35 ????????<property name="dialect">org.hibernate.dialect.MySQL5Dialect</property>36 37 ????????<!--设置事务隔离级别-->38 ????????<property name="hibernate.connection.isolation">4</property>39 40 ????????<!--当前session绑定本地线程-->41 ????????<property name="hibernate.current_session_context_class">thread</property>42 43 ????????<!--3 把映射文件加载-->44 ????????<mapping resource="b_Query/entity/User.hbm.xml"></mapping>45 ????</session-factory>46 </hibernate-configuration>

hibernate核心配置文件

public interface UserService { ???public void transfer(Integer from,Integer to,Double money);}

service层接口

 1 public class UserServiceImpl implements UserService { 2 ????private UserDAO userDAO = new UserDAOImpl(); 3 ????@Override 4 ????public void transfer(Integer from, Integer to, Double money) { 5 ?6 ????????Session session = HibernateUtils.getCurrentSession(); 7 ?8 ??????/* ?//验证 session是否相同 9 ????????Session session1 = HibernateUtils.getCurrentSession();10 ????????System.out.println(session == session1);*/11 12 ????????Transaction transaction = session.beginTransaction();13 14 ????????try {15 ????????????//from ?减少金额16 ????????????userDAO.reduce(from,money);17 18 ????????????int i =5/0;19 ????????????//to 增加金额20 ????????????userDAO.increase(to,money);21 ????????????transaction.commit();22 ????????}catch (Exception e){23 ????????????e.printStackTrace();24 ????????????transaction.rollback();25 ????????}26 27 ????}28 }

service层接口实现

public interface UserDAO { ???public void increase(Integer id,Double money); ???public void reduce(Integer id,Double money);}

DAO层接口

public class UserDAOImpl implements UserDAO { ???@Override ???public void increase(Integer id, Double money) { ???????Session session = HibernateUtils.getCurrentSession(); ???????User user = session.get(User.class, id); ???????user.setBalance(user.getBalance()+money); ???????session.update(user); ???} ???@Override ???public void reduce(Integer id, Double money) { ???????Session session = HibernateUtils.getCurrentSession(); ???????User user = session.get(User.class, id); ???????user.setBalance(user.getBalance()-money); ???????session.update(user); ???}}

DAO层接口实现

public class HibernateUtils { ???private static Configuration configure; ???private static SessionFactory sessionFactory; ???static { ???????configure = new Configuration().configure(); ???????sessionFactory = configure.buildSessionFactory(); ???} ???public static SessionFactory getsessionFactory(){ ???????return sessionFactory; ???} ???//获取session ???public static Session getSession(){ ???????return sessionFactory.openSession(); ???} ???//拿到和当前线程绑定的session ???public static Session getCurrentSession(){ ???????Session currentSession = sessionFactory.getCurrentSession(); ???????return currentSession; ???}}

hibernate工具类

public class BalanceDemo { ???@Test ???public void transfer(){ ???????UserService userService = new UserServiceImpl(); ???????userService.transfer(2,1,5.0); ???}}

测试类

在业务层如果转账过程中出现了问题，事务回滚，可以保证数据库的一致性。

转账前的记录：

处理业务时产生异常：

这时后刷新记录发现记录中的balance字段（表示金额）数值不变。业务逻辑实现类中，转账后捕获到了异常事务进行了回滚。

若没有产生异常，则两条记录的金额都发生变化。

注意：

1.在hibernate.cfg.xml核心配置文件中可以配置事务隔离级别 4表示repeatable read

2.在DAO层操作数据库需要用到session，在service层获取事务也需要session，我们要确保2个session为同一个对象

解决：将session与本地线程绑定。

需要在hibernate.cfg.xml核心配置文件中配置

<property name="hibernate.current_session_context_class">thread</property>

Hibernate中事务小案例

原文地址：https://www.cnblogs.com/whcwkw1314/p/8516742.html

Hibernate中事务小案例

知识推荐