Spring + Hibernate+SQL2005 实现两个数据库实例 跨库DAO事务

开发中需要在同一台数据库服务器上，不同的数据库实例之间，执行跨库的事务。本文给出Spring+Hibernate+SQL2005的例子。

?

1 Spring配置文件，applicationContext-db.xml：

??? 拦截的类是PersonDS，方法是transferPerson,

?

<?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><bean id="foreign_dataSource" value="${db.driverClassName}" /><property name="url" value="${db.url};databaseName=${db.name.foreign}" /><property name="username" value="${db.username}" /><property name="password" value="${db.password}" /></bean><bean id="foreign_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><bean id="foreign_transactionManager"/></property></bean><bean id="foreign_transactionInterceptor"ref="foreign_transactionManager" /><property name="transactionAttributeSource" ref="txAttributeSource" /></bean><bean id="foreign_personDAO" /></property></bean><bean id="personDS" ref="foreign_personDAO"></property><property name="localDAO" ref="local_personDAO"></property></bean></beans>

?

?

2 数据库属性文件 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

?

3 涉及到两个数据库实例，一个叫做Local，另一个叫Foreign。都有一个表Person，结构一样，列ID为主键，assigned属性，定义为：

SET ANSI_NULLS ONGOSET QUOTED_IDENTIFIER ONGOSET ANSI_PADDING ONGOCREATE TABLE [dbo].[Person]([Id] [bigint] 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

?

4 hibernate映射文件，其中列ID为主键，assigned属性。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>

?

5 POJO类Person.java

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;}}

?

6 数据访问DAO定义，包括两个组件IPersonDAO和实现类PersonDAO?

? IPeronDAO.java源码

package edu.dlut.nihao.lvhl.domain;public interface IPersonDAO {void insertPerson(Object person);void remove(Object person);}

?

Person.DAO源码

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);}public void remove(Object person) {getHibernateTemplate().delete(person);}}

?

7 跨库事务拦截的方法，由以DS为后缀的类实现。

IPersonDS.java源码

package edu.dlut.nihao.lvhl.domain;public interface IPersonDS {void transferPerson(Person person) throws Exception;}

?

PersonDS.java源码，其中transferPerson方法中有ExceptionUtil.exceptionOccur();用于产生异常

package edu.dlut.nihao.lvhl.domain;public class PersonDS implements IPersonDS {private IPersonDAO localDAO;private IPersonDAO foreignDAO;public void transferPerson(Person person) throws Exception {localDAO.remove(person);foreignDAO.insertPerson(person);//ExceptionUtil.exceptionOccur();}public IPersonDAO getLocalDAO() {return localDAO;}public void setLocalDAO(IPersonDAO localDAO) {this.localDAO = localDAO;}public IPersonDAO getForeignDAO() {return foreignDAO;}public void setForeignDAO(IPersonDAO foreignDAO) {this.foreignDAO = foreignDAO;}}

?

ExceptionUtil.java源码

package edu.dlut.nihao.lvhl.domain;public final class ExceptionUtil {public static void exceptionOccur() {int[] arr = new int[1];arr[1] = 0;}}

?

8 测试代码

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";static long PERSON_ID = 12;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);person.setId(PERSON_ID);localDao.insertPerson(person);// 测试跨库事务IPersonDS personDS = (IPersonDS) ContextFactory.findService("personDS");try {personDS.transferPerson(person);} catch (Exception e) {e.printStackTrace();}}}

?

1 楼 liushu1234 2011-05-30 楼主确定这样子可以回滚么？我和你的配置几乎一样，但是却不能回滚。