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