第11章 Hibernate的高级特性

null第11章 Hibernate的高级特性第11章 Hibernate的高级特性11.1 Hibernate的事务管理11.2 Hibernate的并发11.3 Hibernate的拦截器11.1 Hibernate的事务管理11.1 Hibernate的事务管理11.1.1 事务的概念 事务有4个重要特性：  原子性：即作为一个事务，它是一个不可分割的整体，只有全部操作都完成了，才算结束；其中任何一个操作执行失败，整个事务都要撤销。  一致性：即事务不能破坏数据库的完整性和业务逻辑的一致性。事务不管成功还是失败，事务结束时，整个数据库内部数据都是正确的。  隔离性：即在并发的数据库操作时，不同的事务操作相同的数据时，每个事务都有自己的完整的数据空间。一个事务不会看到或拿到另一个事务正修改到一半的数据，这些数据要么是另一个事务修改前的，要么是另一个事务修改后提交的。拥有这个特性，是为了在数据库并发操作过程中，保证所有并发操作的正确性。  持久性：即事务成功提交后，数据就被永久地保存到数据库，重新启动数据库系统后，数据仍然保存在数据库系统中。 11.1.2 Hibernate的事务11.1.2 Hibernate的事务将事务管理委托给JDBC进行处理是最简单的实现方式，Hibernate对于JDBC事务的封装也比较简单。例如下面的代码：  Session session=sessionFactory.openSession(); Transaction tx=session.beginTransaction(); ... tx.commit();  从JDBC层面而言，上面的代码实际上对应着：  Connection cn=getConnection; cn.setAutoCommit(false); // JDBC调用相关的SQL语句 cn.commit(); 11.1.2 Hibernate的事务11.1.2 Hibernate的事务在sessionFactory.openSession()语句中，Hibernate会初始化数据库连接。与此同时，将其AutoCommit设为关闭状态（false），即一开始从SessionFactory获得的session，其自动提交属性已经被关闭。下面的代码不会对数据库产生任何效果：  session session=session.Factory.openSession(); session.save(user); session.close();  这实际上相当于JDBC Connection的AutoCommit属性被设为false，执行了若干JDBC操作之后，没有调用commit操作。 如果要使代码真正作用到数据库，必须显示地调用Transaction指令，例如下面的代码：  Session session =sessionFactory.openSession(); Transaction tx=sessio.beginTransaction(); session.save(user); tx.commit(); session.close(); 11.1.2 Hibernate的事务11.1.2 Hibernate的事务Hibernate的事务应用一般分为下面几个步骤： （1）通过SessionFactoy获得Session对象，例如下面的代码：  Session session = sessionFactory.openSession();  （2）通过Session对象开始一个事务，例如下面的代码：  Transaction t=session.beginTransaction();  （3）进行相关的数据操作。 （4）事务提交，例如下面的代码：  t.commit();  （5）如果事务处理出现异常，则撤销事务（通常叫做事务回滚），例如下面的代码：  t.rollback();  （6）关闭Session，结束操作，例如下面的代码：  session.close();  一个完整的应用Hibernate事务的实例。 11.1.2 Hibernate的事务11.1.2 Hibernate的事务2．基于JTA的事务管理概念 JTA（Java Transaction API）是由Java EE Transaction Manager管理的事务，其最大的特点是调用UserTransaction接口的begin()、commit()和rollback()方法来完成事务范围的界定、事务的提交和回滚。JTA可以实现同一事务对应不同的数据库。 JTA主要用于分布式的多个数据源的两阶段提交的事务，而JDBC的Connection提供单个数据源的事务，后者因为只涉及一个数据源，所以其事务可以由数据库自己单独实现，而JTA事务因为其分布式和多数据源的特性，不可能由任何一个数据源实现事务。因此，JTA中的事务是由“事务管理器”来实现的，它会在多个数据源之间统筹事务，具体使用的技术就是所谓的“两阶段提交”。 JTA事务管理由JTA容器实现，JTA容器对当前加入事务的众多Connection进行调度，实现事务性要求。JTA的事务周期可横跨多个JDBC Connection生命周期。同样，对于基于JTA事务的Hibernate而言，JTA事务横跨多个Session。 11.2 Hibernate的并发11.2 Hibernate的并发11.2.1 并发产生的问题 一般情况下，数据库并发产生的问题可以分为4种：更新丢失、脏读、不可重复读及虚读。下面分别介绍这4种问题。  更新丢失。当多个事务同时操作同一数据时，由于事务之间完全没有进行隔离，撤销其中一个事务，结果覆盖了其他事务已经提交并成功更新的数据，对其他事务而言造成了数据丢失。例如，在存款和取款的情况下，如果没有采取措施，很容易出现如表11.1所示的并发问题带来的情况。 表11.1 更新丢失 11.2.1 并发产生的问题11.2.1 并发产生的问题 脏读。当多个事务同时操作同一数据时，如果事务A读到事务B尚未提交的更新数据，且对其进行操作，当事务B撤销了更新后，事务A所操作的数据便成了无效数据（即脏数据）。同样以存款与取款问题为例，如表11.2所示。 表11.2 脏读 11.2.1 并发产生的问题11.2.1 并发产生的问题 虚读。当多个事务同时操作同一数据时，如果事务A在操作过程中进行两次查询，很有可能第二次查询的结果包含了第一次查询中未出现的数据（这里并不要求两次查询的SQL语句相同）。这是因为，在两次查询过程中由事务B插入了新数据造成的，如表11.3所示。 表11.3 虚读 11.2.1 并发产生的问题11.2.1 并发产生的问题 不可重复读。当多个事务同时操作同一数据时，如果事务A对同一行数据重复读取两次，却得到了不同的结果，有可能在事务A两次读取的过程中，由事务B对该行数据进行了修改，并成功提交，如表11.4所示。 表11.4 不可重复读 11.2.2 解决 方案 气瓶 现场处置方案 .pdf气瓶 现场处置方案 .doc见习基地管理方案.doc关于群访事件的化解方案建筑工地扬尘治理专项方案下载 11.2.2 解决方案1．设置隔离级别 标准 excel标准偏差excel标准偏差函数exl标准差函数国标检验抽样标准表免费下载红头文件格式标准下载 SQL规范中提供了4种事务隔离级别，可以通过Hibernate的配置文件来设置隔离级别。  串行化（Serializable）：提供严格的事务隔离。它要求各事务串行化执行，事务只能一个接着一个地串行执行，不能并发执行。当数据库采用此隔离级别时，只要有一个事务在操作某个数据，其他欲操作此数据的事务必须停下来等待，直至那个事务结束，有效地防止了所有可能出现的并发问题，但并发性能较低。  可重复读取（Repeatable Read）：当数据库采用此隔离级别时，一个事务在执行过程中可以访问其他事务成功提交的新插入的数据，但不能访问成功修改的数据，因而有效地防止了不可重复读取和脏读两类并发问题的发生。  读已提交数据（Read Committed）：当数据库采用此隔离级别时，一个事务在执行过程中既可以访问其他事务成功提交的新插入的数据，又可以访问成功修改的数据，因而有效地防止了脏读。  读未提交数据（Read Uncommitted）：当数据库采用此隔离级别时，一个事务在执行过程中既可以访问其他事务未提交的新插入的数据，又可以访问未提交的修改数据，因而仅仅防止了更新丢失的发生。 11.2.2 解决方案11.2.2 解决方案2．锁 Hibernate支持两种锁机制，悲观锁（Pessimistic Locking）和乐观锁（Optimistic Locking）。悲观锁是指对数据被外界修改持保守态度。假定任何时刻存取数据时，都可能有一个客户也正在存取同一数据，为了保持数据被操作的移植性，于是对数据采取了数据库层次的锁定状态，依靠数据库提供的锁机制来实现。 乐观锁则乐观地认为数据很少发生同时存取的问题，因而不做数据库层次上的锁定。为了维护正确的数据，乐观锁采用应用程序上的逻辑实现版本控制的方法。 Hibernate中以通过版本号检索来实现更新为主，这也是Hibernate推荐的方式。在数据库中假如有一个Version记录，在读取数据时连带版本号一同读取，并在更新数据时递增版本号，然后比较此版本号和数据库中的版本号，如果大于数据库中的版本号，则给予更新，否则就报错误。 11.3 Hibernate的拦截器11.3 Hibernate的拦截器11.3.1 Interceptor接口 下面分别介绍这些方法的含义及执行阶段。  afterTransactionBegin(Transaction tx)：当Hibernate事务被调用后，该方法将被调用。  afterTransactionCompletion(Transaction tx)：当事务被提交或回滚后，该方法被调用。  beforeTransactionCompletion(Transaction tx)：该方法在一个事务提交前被调用，但是回滚前不被调用。  findDirty(Object entity,Serializable id, Object[] currentState, Object[] previousState,String[] propertyNames, Type[] types)：当调用flush()方法刷新缓存时会自动调用这个方法检查缓存中是否有脏数据（缓存中有数据库不一致的数据）。返回的数组是对象脏属性的索引。如果该数组不为空，说明这个对象需要被更新；如果是空的数组，说明这个对象不必被更新，默认返回null。Hibernate会自动使用默认的方式检查对象是否是脏数据。  onDelete(ObjectSerializable id,Object[] state, String[] propertyName,Type[] types)：在对象删除前被调用。不建议使用给“state”参数赋值来修改要被删除实体的属性值。 11.3.1 Interceptor接口11.3.1 Interceptor接口 onFlushDirty(Object entity,Serializable id, Object[] currentState, Object[] previousState, String[] propertyNames, Type[] types)：如果一个对象在flush执行时被发现是脏数据，则这个方法会被调用。可以给“currentState”参数赋值，这个赋值既会修改持久化类对象的属性值，也会修改数据库表对应的列值。不建议使用给“previousState”赋值来修改实体更新前的属性值。返回值是boolean类型，true说明在方法体中修改了对象的属性值“currentState”，false说明没有修改其当前属性值。  onLoad(Object entity,Serializable id,Object[] state,String[] propertyNames,Typ[]types)：当一个对象从数据库中载入时被调用。修改“state”参数，就可以修改持久化类对象的属性值。返回值是boolean类型，true说明在方法体中修改了对象的属性值state，false表示没有修改。  onSave(Object entity,Serializable id,Object[] state,String[] propertyNames,Type[]types)：在一个方法保存之前被调用。如果给相应的“state”赋值，这个值能够被insert语句保存到数据库中，同时也更改持久化类对象的属性值。返回boolean类型，true代表用户在其中修改了属性值state，false表示没有修改。 11.3.1 Interceptor接口11.3.1 Interceptor接口 onCollectionRecreate(Object collection, Serializable key)：在集合被创建或再次创建时被调用。如果一个持久化类中使用了Java集合属性，那么保存这个持久化类时，这个集合属性中的元素也被同时保存，这个onCollectionRecreate()方法会被自动调用。  onCollectionRemove(Object collection, Serializable key)：在集合被删除时被调用。  onCollectionUpdate(Object collection, Serializable key)：在集合被更新时被调用。  isTransient(Objectentity)：调用这个方法可以判断一个实体是持久化态还是游离态。返回值是boolean类型，如果返回true，代表这个实体是持久化态；如果返回false，代表这个实体是游离态；如果返回null，说明Hibernate使用映射文件中的unsaved-value或者其他方法来判断，这个实体还没有被保存，是临时态。  getEntity(String entityName, Serializable id)：以对象名字和id为参数，可以返回持久化对象实体。  getEntityName(Objectobject)：以持久态和游离态的实体类对象为参数，可以返回实体的名字。 11.3.1 Interceptor接口11.3.1 Interceptor接口 instantiate(String entityName, EntityMode entityMode, Serializable id)：这个方法可以显式地让Hibernate实例化一个实体类。参数entityName是实体对象的名字，entityMode是返回的实体实例的类型，参数id将作为新实体对象的id。  onPrepareStatement(String arg0)：这个方法可以返回要执行的SQL语句，参数arg0即是要执行的SQL语句。  postFlush(Iterator arg0)：该方法在持久化所做修改同步完成后会执行。  preFlush(Iterator arg0)：该方法在同步持久化所做修改之前会执行。 11.3.2 应用举例11.3.2 应用举例创建Hibernate程序Hibernate_Interceptor，添加Hibernate的类库（核心类库）及数据库驱动，创建配置文件，代码。 本例实现对数据库中userTable表的操作，故POJO类及映射文件如下。 User.java代码为：  package org.vo; public class User { private int id; private String username; private String password; //省略上面属性的get和set方法 } 11.3.2 应用举例11.3.2 应用举例映射文件User.hbm.xml代码为：     下面编写拦截器，代码。 11.3.2 应用举例11.3.2 应用举例编写测试类Test.java，代码。 运行该测试程序，结果如下：  该语句在事务开始之后执行！ 保存持久化实例时调用该方法 这里返回要执行的SQL语句 Hibernate: insert into userTable (username, password) values (?, ?) 在同步持久化所做修改之前调用该方法 持久化所做修改同步完成后，调用该方法 该语句在事务提交前被执行！回滚前不执行！ 该语句在事务提交或回滚后执行！