Java事务管理学习之Hibernate详解
环境与版本
hibernate 版本:hibernate 4.2.2 (下载后的文件名为hibernate-release-4.2.2.final.zip,解压目录hibernate-release-4.2.2.final)
数据库: oracle 10g
导入lib\required 中的所有jar 包
理论说明
1、sessionfactory负责创建session,sessionfactory是线程安全的,多个并发线程可以同时访问一个sessionfactory 并从中获取session实例
2、session作为贯穿hibernate的持久化管理器核心,提供了众多的持久化的方法,如save(), update ,delete ,find(hibernate 3中已经取消了此方法)等,通过这些方法我们可以透明的完成对象的增删改查(crud-- create read update delete),这里所谓的透明是指,session在读取,创建和删除影射的实体对象的实例时,这一系列的操作将被转换为对数据库表中数据的增加,修改,查询和删除操作。
session有以下的特点
1)不是线程安全的,应该避免多个线程共享同一个session实例
2)session实例是轻量级的,所谓轻量级:是指他的创建和删除不需要消耗太多资源
3)session对象内部有一个缓存,被称为hibernate第一缓存,他存放被当前工作单元中加载的对象,每个session实例都有自己的缓存。
3、hibernate session缓存被称为hibernate的第一级缓存。sessionfactory的外置缓存称为hibernate的二级缓存。这两个缓存都位于持久层,它们存放的都是数据库数据的拷贝。sessionfactory的内置缓存 存放元数据和预定义sql, sessionfactory的内置缓存是只读缓存。
4、hibernate session缓存的三大作用:
1)减少数据库的访问频率,提高访问性能。
2)保证缓存中的对象与数据库同步,位于缓存中的对象称为持久化对象。
3)当持久化对象之间存在关联时,session 保证不出现对象图的死锁。
session 如何判断持久化对象的状态的改变呢?
session 加载对象后会为对象值类型的属性复制一份快照。当session 清理缓存时,比较当前对象和它的快照就可以知道那些属性发生了变化。
5、session 什么时候清理缓存?
1)commit()
方法被调用时
2)查询时会清理缓存,保证查询结果能反映对象的最新状态。
3)显示的调用session 的 flush方法。
session 清理缓存的特例:
当对象使用 native 生成器 时 会立刻清理缓存向数据库中插入记录。
实例代码
测试的代码目录如下:
hibernate.cfg.xml
<?xml version="1.0"?> <!doctype hibernate-configuration public "-//hibernate/hibernate configuration dtd 3.0//en" "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd"> <hibernate-configuration> <session-factory> <property name="show_sql">true</property> <property name="hibernate.connection.driver_class"> oracle.jdbc.driver.oracledriver </property> <property name="hibernate.connection.url"> jdbc:oracle:thin:@xx.26.158.43:1521:orcl </property> <property name="hibernate.connection.username"></property> <property name="hibernate.connection.password"></property> <property name="dialect">org.hibernate.dialect.oracledialect</property> <mapping resource="com/oscar999/trans/hibernate/product.hbm.xml"/> </session-factory> </hibernate-configuration>
product.java
/** * @title: product.java * @package com.oscar999.trans.hibernate * @description: * @author xm * @date feb 15, 2017 1:44:47 pm * @version v1.0 */ package com.oscar999.trans.hibernate; import java.io.serializable; /** * @author xm * */ public class product implements serializable { public product() { } private integer id; private string name; private string price; private static final long serialversionuid = 1l; public integer getid() { return id; } public void setid(integer id) { this.id = id; } public string getname() { return name; } public void setname(string name) { this.name = name; } public string getprice() { return price; } public void setprice(string price) { this.price = price; } }
product.hbm.xml
<?xml version="1.0"?> <!doctype hibernate-mapping system "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd" > <hibernate-mapping> <class name="com.oscar999.trans.hibernate.product" table="test_product"> <id name="id" column="id" type="java.lang.integer"> <generator class="assigned" /> </id> <property name="name" column="name" type="java.lang.string" not-null="true" unique="true" length="20" /> <property name="price" column="price" type="java.lang.string" not-null="false" unique="false" length="20" /> </class> </hibernate-mapping>
testmain.java
/** * @title: testmain.java * @package com.oscar999.trans.hibernate * @description: * @author xm * @date feb 15, 2017 2:02:17 pm * @version v1.0 */ package com.oscar999.trans.hibernate; import java.io.file; import org.hibernate.session; import org.hibernate.sessionfactory; import org.hibernate.transaction; import org.hibernate.cfg.configuration; import org.hibernate.service.serviceregistry; import org.hibernate.service.serviceregistrybuilder; /** * @author xm * */ public class testmain { /** * @param args */ public session getsession() { session session = null; configuration conf = new configuration().configure(new file("src/com/oscar999/trans/hibernate/hibernate.cfg.xml")); serviceregistry serviceregistry = new serviceregistrybuilder().applysettings(conf.getproperties()).buildserviceregistry(); sessionfactory sf = conf.buildsessionfactory(serviceregistry); session = sf.opensession(); return session; } public void addproduct(session session, string name, string price) { transaction t = session.begintransaction(); // 1. comment1 product product = new product(); product.setid(1); product.setname(name); product.setprice(price); try { session.save(product); t.commit(); // 2. comment2 } catch (exception e) { t.rollback(); } } public static void main(string[] args) { // todo auto-generated method stub testmain testmain = new testmain(); session session = testmain.getsession(); testmain.addproduct(session, "product1", "price1"); if (session != null && session.isopen()) { session.close(); } } }
说明:
1. <generator class="assigned" />
id 的产生策略是自己指定, 所以在代码中有 product.setid(1);
否则无法添加成功
2. transaction t = session.begintransaction();
hibernate本身没有实现自己的事务管理功能,而是对底层jdbc事务或jta事务的轻量级封装
3.hibernate可以配置为jdbctransaction或者是jtatransaction,这取决于你在hibernate.properties中的配置:
#hibernate.transaction.factory_class net.sf.hibernate.transaction.jtatransactionfactory #hibernate.transaction.factory_class net.sf.hibernate.transaction.jdbctransactionfactory
如果你什么都不配置,默认情况下使用jdbctransaction
4. 在hibernate中,session打开的时候,就会自动conn.setautocommit(false)
,不像一般的jdbc,默认都是true,所以你最后不写commit也没有关系,由于hibernate已经把autocommit给关掉了,所以用hibernate的时候,你在程序中不写transaction的话,数据库根本就没有反应。
jdbc和hibernate 处理事务的关联
hibernate本身没有实现自己的事务管理功能,而是对底层jdbc事务或jta事务的轻量级封装
jta
jta来管理跨session的长事务,那么就需要使用jtatransaction
javax.transaction.usertransaction tx = new initialcontext();.lookup("javax.transaction.usertransaction");; session s1 = sf.opensession();; ... s1.flush();; s1.close();; ... session s2 = sf.opensession();; ... s2.flush();; s2.close();; tx.commit();;
hibernate transaction是从session中获得的,tx = session.begintransaction()
,最后要先提交tx,然后再session.close
,这完全符合jdbc的transaction的操作顺序,但是这个顺序是和jta的transactioin操作顺序彻底矛盾的!!! jta是先启动transaction,然后启动session,关闭session,最后提交transaction,因此当你使用jta的transaction的时候,那么就千万不要使用hibernate的transaction,而是应该像我上面的jta的代码片断那样使用才行。
总结
以上就是这篇文章的全部内容了,希望本文的内容对大家学习或者使用java能带来一定的帮助,如果有疑问大家可以留言交流,谢谢大家对的支持。