Spring + Hibernate DAO 事务
在eclipse3.4+spring2.5+hibernate3.2 +SQL2005下调试的DAO事务
?
1 Spring配置文件，applicationContext-db.xml
?
?
<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd"><beans><bean id="placeholderConfig"value="${db.driverClassName}" /><property name="url" value="${db.url};databaseName=${db.name.local}" /><property name="username" value="${db.username}" /><property name="password" value="${db.password}" /></bean><bean id="local_sessionFactory"/></property><property name="mappingResources"><list><value>edu/dlut/nihao/lvhl/domain/Person.hbm.xml</value></list></property><property name="hibernateProperties"><props><prop key="hibernate.dialect">org.hibernate.dialect.SQLServerDialect</prop><prop key="hibernate.show_sql">true</prop></props></property></bean><!--transactionManager--><bean id="local_transactionManager"/></property></bean><bean id="local_transactionInterceptor"ref="local_transactionManager" /><property name="transactionAttributeSource" ref="txAttributeSource" /></bean><bean id="txAttributeSource"/></property></bean></beans>?
2. 数据库表定义，数据库名称：Local，表名：Person，表结构：
?
USE [LOCAL]GO/****** 对象: Table [dbo].[Person] 脚本日期: 09/19/2010 10:01:32 ******/SET ANSI_NULLS ONGOSET QUOTED_IDENTIFIER ONGOSET ANSI_PADDING ONGOCREATE TABLE [dbo].[Person]([Id] [bigint] IDENTITY(1,1) NOT NULL,[Name] [varchar](50) NULL, CONSTRAINT [PK_Person] PRIMARY KEY CLUSTERED ([Id] ASC)WITH (PAD_INDEX = OFF, STATISTICS_NORECOMPUTE = OFF, IGNORE_DUP_KEY = OFF, ALLOW_ROW_LOCKS = ON, ALLOW_PAGE_LOCKS = ON) ON [PRIMARY]) ON [PRIMARY]GOSET ANSI_PADDING OFF
?
?3 定义数据库连接的属性文件，db.properties
#Created by JInto - www.guh-software.de#Wed Aug 25 16:36:01 CST 2010db.driverClassName=com.microsoft.sqlserver.jdbc.SQLServerDriverdb.password=1234db.port=1433db.url=jdbc\:sqlserver\://10.87.40.148db.username=sadb.name.local=Localdb.name.foreign=Foreign
?
4 domain对象，类Person
package edu.dlut.nihao.lvhl.domain;public class Person {private Long id;private String name;public Long getId() {return id;}public void setId(Long id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}}?
5 Hibernate映射文件，Person.hbm.xml
<?xml version="1.0"?><!DOCTYPE hibernate-mapping PUBLIC"-//Hibernate/Hibernate Mapping DTD 3.0//EN""http://hibernate.sourceforge.net/hibernate-mapping-3.0.dtd"><hibernate-mapping package="edu.dlut.nihao.lvhl.domain"><class name="edu.dlut.nihao.lvhl.domain.Person" table="Person"select-before-update="false" dynamic-update="false" dynamic-insert="false"optimistic-lock="version"><id name="id" column="Id" type="java.lang.Long" length="19"><generator type="java.lang.String" update="true"insert="true" access="property" column="Name" length="50" not-null="false" /></class></hibernate-mapping>
?6 DAO定义，分别定义接口? IPersonDAO.java和实现类? PersonDAO.java。
? ??? IPersonDAO.java的源代码：
package edu.dlut.nihao.lvhl.domain;public interface IPersonDAO {void insertPerson(Object person);}?
???? ?PersonDAO.java的源代码，继承自HibernateDaoSupport ：
package edu.dlut.nihao.lvhl.domain;import org.springframework.orm.hibernate3.support.HibernateDaoSupport;public class PersonDAO extends HibernateDaoSupport implements IPersonDAO {public void insertPerson(Object person) {getHibernateTemplate().save(person);ExceptionUtil.exceptionOccur();}}?
?? 注意有一行代码，ExceptionUtil.exceptionOccur();
?? 由于对数据库操作PersonDAO.insertPerson(Object person) 纳入事务管理，执行测试代码，在插入一条记录后，产生一个运行时异常，所以插入操作回滚，察看数据库Person表，显示没有插入记录。
????? 注释掉该行后，运行测试程序，察看数据库，插入成功。
????? ExceptionUtil用于产生异常
package edu.dlut.nihao.lvhl.domain;public final class ExceptionUtil {public static void exceptionOccur() {int[] arr = new int[1];arr[1] = 0;}}?
7? 测试代码，
package edu.dlut.nihao.lvhl.domain;import org.springframework.context.ApplicationContext;import org.springframework.context.support.ClassPathXmlApplicationContext;public class ContextFactory {static ApplicationContext ctx = null;static String PERSON_NAME = "nihao";public static Object findService(String beanId) {if (ctx == null) {ctx = new ClassPathXmlApplicationContext(new String[] { "applicationContext-db.xml" });}return ctx.getBean(beanId);}public static void main(String[] args) {IPersonDAO localDao = (IPersonDAO) ContextFactory.findService("local_personDAO");Person person = new Person();person.setName(PERSON_NAME);localDao.insertPerson(person);}}?