关于Spring事务管理问题的探讨
大家好,我最近几天一直在调spring事务.可事务不回滚的问题一直困绕着我.
说一下我的大概思路,在Service层,分别调用两个DAO层的业务方法.实现保存功能.
我采用的数据库是Sql Server2000
Service层代码:
public class UserService implements IUserService {
private IUserDAO userDAO;
private IAddressDAO addressDAO;
public void saveUserAndAddress(User user, Address address) {
//我想要实现的效果: 当userDAO执行成功,并且addressDAO执行成功,则数据库中对应USER表,及ADDRESS保存数据.
//如果userDAO执行失败,或addressDAO执行失败,则USER表,及ADDRESS表不保存数据
userDAO.saveUser(user);
addressDAO.saveAddress(address);
}
//下面的get / set userDAO , addressDAO方法略
....
UserDAO层代码:
public class UserDAOImpl implements IUserDAO {
private JdbcTemplate jdbcTemplate;
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
public void saveUser(User user) {
String sql = "insert into ma_user_info (id , user_name , pass_word) values("+user.getId()+",'"+user.getUsername()+"' ,'"+user.getPassword()+"')";
jdbcTemplate.update(sql);
}
}
AddressDAO层代码:
public class AddressDAOImpl implements IAddressDAO {
private JdbcTemplate jdbcTemplate;
public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
this.jdbcTemplate = jdbcTemplate;
}
public void saveAddress(Address address) {
String sql = "insert into ma_address_info (i,address)values("+address.getId()+",'"+address.getAddName()+"')";;
jdbcTemplate.update(sql) ;
}
}
beans-config.xml配置:
<bean id="transactionDataSource" class="org.springframework.jdbc.datasource.DriverManagerDataSource">
<property name="driverClassName" value="com.microsoft.sqlserver.jdbc.SQLServerDriver" />
<property name="url" value="jdbc:sqlserver://127.0.0.1:1433;databaseName=hibernate_research" />
<property name="username" value="sa" />
<property name="password" value="sa" />
</bean>
<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate" >
<constructor-arg ref="transactionDataSource" />
</bean>
<!-- data access layer -->
<bean id="transactionUserDAO" class="com.transaction.dao.user.UserDAOImpl" >
<property name="jdbcTemplate" ref="jdbcTemplate" />
</bean>
<bean id="transactionAddressDAO" class="com.transaction.dao.address.AddressDAOImpl" >
<property name="jdbcTemplate" ref="jdbcTemplate" />
</bean>
<!-- business logic layer -->
<bean id="transactionUserService" class="com.transaction.service.UserService">
<property name="userDAO" ref="transactionUserDAO" />
<property name="addressDAO" ref="transactionAddressDAO" />
</bean>
<!-- proxy -->
<bean id="transactionUserServiceProxyBean" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<property name="proxyInterfaces">
<list>
<value>com.transaction.service.IUserService</value>
</list>
</property>
<property name="target" ref="transactionUserService" />
<property name="transactionAttributes">
<props>
<prop key="save*">PROPAGATION_REQUIRED,-java.lang.Exception</prop>
</props>
</property>
</bean>
最后的main方法测试类代码:
public static void main(String[] args) {
ApplicationContext context = new ClassPathXmlApplicationContext("beans-config.xml");
IUserService userService = (IUserService)context.getBean("transactionUserServiceProxyBean");
User user = new User();
user.setId(100);
user.setUsername("username_100");
user.setPassword("password_100");
Address address = new Address();
address.setId(100);
address.setAddName("address_100");
userService.saveUserAndAddress(user, address);
}
请各位不吝指教.万分感谢!
你的配置错了,你好像都没声明使用spring的事务代理机制,你最好把完整的配置文件发出来,如果你需要spring事务代理,你需要申明在application*.xml文件中的,比如
[code="java"]
class="org.springframework.orm.hibernate.HibernateTransactionManager">
[/code]
[code="java"] <!-- Transactional proxy for the services -->
class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean"
lazy-init="true">
PROPAGATION_REQUIRED
PROPAGATION_REQUIRED
PROPAGATION_REQUIRED
PROPAGATION_REQUIRED
PROPAGATION_REQUIRED
PROPAGATION_REQUIRED
PROPAGATION_REQUIRED
[/code]
下面的service类声明了parent调用的是spring的事务代理,这样才会回滚啊。
[code="java"]
class="com.stt.apps.doms.service.impl.AdminServiceImpl"
autowire="byName">
</bean>
[/code]
Service层代码:
public class UserService implements IUserService {
private IUserDAO userDAO;
private IAddressDAO addressDAO;
@Transactional() //加这句事物的注释
public void saveUserAndAddress(User user, Address address) {
userDAO.saveUser(user);
addressDAO.saveAddress(address);
}
@Transactional() //加这句事物的注释
这句话要不要都没影响的!
你用的是不是mysql?如果是的话,方言一定要是:org.hibernate.dialect.MySQLInnoDBDialect
可能少了这个:spring对DAO层的代理,以UserDAO为例:
在“
”这段代码后面加上:
com.transaction.dao.user.UserDAO~~接口路径改一下
修改下面的代码:替换为:userDAOProxy
可能少了这个:spring对DAO层的代理,以UserDAO为例:
在“
”这段代码后面加上:
com.transaction.dao.user.UserDAO~~接口路径改一下
修改下面的代码:替换为:userDAOProxy
没看到你要在哪个地方回滚啊,你是不是把异常处理了,Spring当然不会回滚了,而且RuntimeException和Exception会有不同的处理方式
PROPAGATION_REQUIRED,-java.lang.Exception
代码里没throw出来
[code="java"] public void saveUserAndAddress(User user, Address address) {
//我想要实现的效果: 当userDAO执行成功,并且addressDAO执行成功,则数据库中对应USER表,及ADDRESS保存数据.
//如果userDAO执行失败,或addressDAO执行失败,则USER表,及ADDRESS表不保存数据
userDAO.saveUser(user);
addressDAO.saveAddress(address);
}[/code]
没看见你加事务啊?
你跟本就没有配置事物,怎么出啊!要把事物配置在业务层就可以了,你再试试!
教你一个方法
@Transcational //这里打上事务标签,那么就会将这个类下的所有方法加上事务
public ClassYouWant{
//我们将两个方法封装成一个方法,这样就是你想要的结果了
public xxxx method(User user,Adress address){
userDAO.saveUser(user);
addressDAO.saveAddress(address);
}
}
[code="java"]
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<bean id="transactionTemplateOracle"
class="org.springframework.transaction.support.TransactionTemplate">
<property name="transactionManager">
<ref local="transactionManagerOracle" />
</property>
</bean>
<bean id="sqlMapClientTemplateOracle" class="org.springframework.orm.ibatis.SqlMapClientTemplate">
<property name="sqlMapClient">
<ref local="sqlMapClientOracle" />
</property>
<property name="dataSource">
<ref local="dataSourceOracle" />
</property>
</bean>
<bean id="sqlMapClientOracle" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
<property name="dataSource">
<ref local="dataSourceOracle" />
</property>
<property name="configLocation">
<value>settle/oracle-sql-map.xml</value>
</property>
</bean>
<context:property-placeholder location="file:config/*.properties" />
<aop:aspectj-autoproxy proxy-target-class="true"/>
<!--启动spring注解功能-->
<tx:annotation-driven transaction-manager="transactionManagerOracle" />[/code]
给你一段配制
[code="java"]
public ClassYouWant{
//加上注解,我们将两个方法封装成一个方法,这样就是你想要的结果了
@Transcational
public xxxx method(User user,Adress address){
userDAO.saveUser(user);
addressDAO.saveAddress(address);
}
}[/code]