数据库

位置:IT落伍者 >> 数据库 >> 浏览文章

Hibernate 基于JDBC的事务


发布日期:2021年03月04日
 
Hibernate 基于JDBC的事务

Hibernate 是JDBC 的轻量级封装本身并不具备事务管理能力在事务管理层Hibernate将其委托给底层的JDBC或者JTA以实现事务管理和调度功能

Hibernate的默认事务处理机制基于JDBC Transaction我们也可以通过配置文件设定采用JTA作为事务管理实现

Java代码

    <hibernateconfiguration>

    <sessionfactory>

    ……

    <propertyname=hibernatetransactionfactory_class>

    netsfhibernatetransactionJTATransactionFactory

    <!netsfhibernatetransactionJDBCTransactionFactory>

    </property>

    ……

    </sessionfactory>

    </hibernateconfiguration>

<hibernateconfiguration><sessionfactory>……<property name=hibernatetransactionfactory_class>netsfhibernatetransactionJTATransactionFactory<!netsfhibernatetransactionJDBCTransactionFactory></property>……</sessionfactory></hibernateconfiguration>

基于JDBC的事务管理将事务管理委托给JDBC 进行处理无疑是最简单的实现方式Hibernate 对于JDBC事务的封装也极为简单

我们来看下面这段代码

Java代码

    session=sessionFactoryopenSession();

    Transactiontx=sessionbeginTransaction();

    ……

    mit();

session = sessionFactoryopenSession();Transaction tx = sessionbeginTransaction();……mit();

从JDBC层面而言上面的代码实际上对应着

Java代码

    Connectiondbconn=getConnection();

    dbconnsetAutoCommit(false);

    ……

    mit();

Connection dbconn = getConnection();dbconnsetAutoCommit(false);……mit();

就是这么简单Hibernate并没有做更多的事情(实际上也没法做更多的事情)只是将这样的JDBC代码进行了封装而已

这里要注意的是在sessionFactoryopenSession()中hibernate会初始化数据库连接与此同时将其AutoCommit 设为关闭状态(false)而其后在SessionbeginTransaction 方法中Hibernate 会再次确认Connection 的AutoCommit 属性被设为关闭状态( 为了防止用户代码对session 的ConnectionAutoCommit属性进行修改)

这也就是说我们一开始从SessionFactory获得的session其自动提交属性就已经被关闭(AutoCommit=false)下面的代码将不会对数据库产生任何效果

Java代码

    session=sessionFactoryopenSession();

    sessionsave(user);

    sessionclose();

session = sessionFactoryopenSession();sessionsave(user);sessionclose();

这实际上相当于 JDBC Connection的AutoCommit属性被设为false执行了若干JDBC操作之后没有调用commit操作即将Connection关闭如果要使代码真正作用到数据库我们必须显式的调用Transaction指令

Java代码

    session=sessionFactoryopenSession();

    Transactiontx=sessionbeginTransaction();

    sessionsave(user);

    mit();

    sessionclose();

session = sessionFactoryopenSession();Transaction tx = sessionbeginTransaction();sessionsave(user);mit();sessionclose();

基于JTA的事务管理

JTA 提供了跨Session 的事务管理能力这一点是与JDBC Transaction 最大的差异

JDBC事务由Connnection管理也就是说事务管理实际上是在JDBC Connection中实现事务周期限于Connection的生命周期之类同样对于基于JDBC Transaction的Hibernate 事务管理机制而言事务管理在Session 所依托的JDBC Connection中实现事务周期限于Session的生命周期

JTA 事务管理则由 JTA 容器实现JTA 容器对当前加入事务的众多Connection 进

行调度实现其事务性要求JTA的事务周期可横跨多个JDBC Connection生命周期

同样对于基于JTA事务的Hibernate而言JTA事务横跨可横跨多个Session

JTA 事务是由JTA Container 维护而参与事务的Connection无需对事务管理进行干涉这也就是说如果采用JTA Transaction我们不应该再调用HibernateTransaction功能

上面基于JDBC Transaction的正确代码这里就会产生问题

Java代码

    publicclassClassA{

    publicvoidsaveUser(Useruser){

    session=sessionFactoryopenSession();

    Transactiontx=sessionbeginTransaction();

    sessionsave(user);

    mit();

    sessionclose();

    }

    }

    publicclassClassB{

    publicvoidsaveOrder(Orderorder){

    session=sessionFactoryopenSession();

    Transactiontx=sessionbeginTransaction();

    sessionsave(order);

    mit();

    sessionclose();

    }

    }

    publicclassClassC{

    publicvoidsave(){

    ……

    UserTransactiontx=newInitialContext()lookup(……);

    ClassAsave(user);

    ClassBsave(order);

    mit();

    ……

    }

    }

public class ClassA{public void saveUser(User user){session = sessionFactoryopenSession();Transaction tx = sessionbeginTransaction();sessionsave(user);mit();sessionclose();}}public class ClassB{public void saveOrder(Order order){session = sessionFactoryopenSession();Transaction tx = sessionbeginTransaction();sessionsave(order);mit();sessionclose();}}public class ClassC{public void save(){……UserTransaction tx = new InitialContext()lookup(……);ClassAsave(user);ClassBsave(order);mit();……}}

这里有两个类ClassA和ClassB分别提供了两个方法saveUsersaveOrder

用于保存用户信息和订单信息在ClassC中我们接连调用了ClassAsaveUser方法和ClassBsaveOrder 方法同时引入了JTA 中的UserTransaction 以实现ClassCsave方法中的事务性问题出现了ClassA 和ClassB 中分别都调用了Hibernate 的Transaction 功能在Hibernate 的JTA 封装中SessionbeginTransaction 同样也执行了InitialContextlookup方法获取UserTransaction实例mit方法同样也调用了mit方法实际上这就形成了两个嵌套式的JTA TransactionClassC 申明了一个事务而在ClassC 事务周期内ClassA 和ClassB也企图申明自己的事务这将导致运行期错误因此如果决定采用JTA Transaction应避免再重复调用Hibernate 的

Transaction功能上面的代码修改如下

Java代码

    publicclassClassA{

    publicvoidsave(TUseruser){

    session=sessionFactoryopenSession();

    sessionsave(user);

    sessionclose();

    }

    ……

    }

    publicclassClassB{

    publicvoidsave(Orderorder){

    session=sessionFactoryopenSession();

    sessionsave(order);

    sessionclose();

    }

    ……

    }

    publicclassClassC{

    publicvoidsave(){

    ……

    UserTransactiontx=newInitialContext()lookup(……);

    classAsave(user);

    classBsave(order);

    mit();

    ……

    }

    }

public class ClassA{public void save(TUser user){session = sessionFactoryopenSession();sessionsave(user);sessionclose();}……}public class ClassB{public void save (Order order){session = sessionFactoryopenSession();sessionsave(order);sessionclose();}……}public class ClassC{public void save(){……UserTransaction tx = new InitialContext()lookup(……);classAsave(user);classBsave(order);mit();……}}

上面代码中的ClassCsave方法也可以改成这样

Java代码

    publicclassClassC{

    publicvoidsave(){

    ……

    session=sessionFactoryopenSession();

    Transactiontx=sessionbeginTransaction();

    classAsave(user);

    classBsave(order);

    mit();

    ……

    }

    }

public class ClassC{public void save(){……session = sessionFactoryopenSession();Transaction tx = sessionbeginTransaction();classAsave(user);classBsave(order);mit();……}}

实际上这是利用Hibernate来完成启动和提交UserTransaction的功能但这样的做法比原本直接通过InitialContext获取UserTransaction 的做法消耗了更多的资源得不偿失

在EJB 中使用JTA Transaction 无疑最为简便我们只需要将save 方法配置为JTA事务支持即可无需显式申明任何事务下面是一个Session Bean的save方法它的事务属性被申明为RequiredEJB容器将自动维护此方法执行过程中的事务

Java代码

    /**

    *@ejbinterfacemethod

    *viewtype=remote

    *

    *@ejbtransactiontype=Required

    **/

    publicvoidsave(){

    //EJB环境中通过部署配置即可实现事务申明而无需显式调用事务

    classAsave(user);

    classBsave(log);

    }//方法结束时如果没有异常发生则事务由EJB容器自动提交

上一篇:利用HSQLDB进行Hibernate的单元测试一

下一篇:用Spring的JdbcTemplate实现分页功能