java

位置:IT落伍者 >> java >> 浏览文章

spring是如何对Service进行事务管理的


发布日期:2022年07月30日
 
spring是如何对Service进行事务管理的

本人也很想弄清楚spring是如何对Service进行事务管理的并且还去看了一下spring框架关于事务管理几个相关类的源码可惜由于本人功力有限只看懂了皮毛.

既然源代码看不懂那么只有运用例子进行测试虽然笨了点不过管是白猫还是黑猫能捉老鼠就是好猫.

为引起不必要的争论本帖子只针对本案例的测试结果进行小结并保证此测试代码在本人的运行环境绝对正确.

开发环境

OSwindows Server

Web Server: jakartatomcat

DataBase Server: MS SQL Server (打了SP3补丁)

IDE: Eclipse +MyEclipse GA

测试案例系统结构

web层<>Service层<>DAO层

web层使用struts DAO使用的spring的JDBCspring版本

数据库中有两张表

student和Student表结构相同idnameaddress.其中id为主键且为自增长型

student表中有一条记录

id name address

xiaoming wuhan

student表中记录为空

测试情形一

web层捕获异常并处理DAO层不捕获异常Service也不捕获异常.

Service层接口

public interface StudentManagerService {

public void bus_method();

}

DAO层接口

public interface StudentDAO {

public void deleteStudent();

public void insertStudent();

}

StudentDAO接口的实现

public class StudentDAOImp extends JdbcDaoSupport implements StudentDAO{

//删除student表中的id=的记录

public void deleteStudent(){

JdbcTemplate jt=thisgetJdbcTemplate();

jtupdate(delete from student where id=);

}

//将student表中删除的记录插入到student但是此方法实现有错因为

//id字段设置为自增长的所以在插入记录时我们不能指定值

public void insertStudent(){

JdbcTemplate jt=thisgetJdbcTemplate();

String arg[]=new String[];

arg[]=;

arg[]=xiaoming;

arg[]=wuhan;

jtupdate(insert student(idnameaddress) values(???)arg);

}

}

StudentManagerService 接口的实现

public class StudentManagerServiceImp implements StudentManagerService{

private StudentDAO stdDAO;

public void setStdDAO(StudentDAO stdDAO){

thisstdDAO=stdDAO;

}

//此方法为事务型的删除student中的记录成功且插入student的记录也成功

//如果insertStudent()方法执行失败那么deleteStudent()方法也应该会失败

public void bus_method(){

thisstdDAOdeleteStudent();

thisstdDAOinsertStudent();

}

}

web层:

三个jsp一个action:

indexjsp ==>首页面.上面仅仅有一个超链接<a herf=testdo>执行</a>

chenggongjsp ==>Service执行成功后转向的JSP页面

shibaijsp====>Service执行失败后转向的JSP页面

action实现

public class StudentManagerAction extends Action{

public ActionForward execute(ActionMapping mapping ActionForm form

HttpServletRequest request HttpServletResponse response) {

try{

WebApplicationContext appContext=WebApplicationContextUtils

getWebApplicationContext(thisgetServlet()getServletContext());

StudentManagerService stdm=(StudentManagerService)appContext

getBean(stdServiceManager);

stdmbus_method();

return mappingfindForward(chenggong);

}

catch(DataAccessException e){

Systemerrprintln(action execute service exception!);

return mappingfindForward(shibai);

}

}

}

配置文件

webxml

<?xml version= encoding=UTF?>

<webapp xmlns= xmlns:xsi=instance version= xsi:schemaLocation=; app__xsd>

<contextparam>

<paramname>logjConfigLocation</paramname>

<paramvalue>/WEBINF/logjproperties</paramvalue>

</contextparam>

<contextparam>

<paramname>contextConfigLocation</paramname>

<paramvalue>/WEBINF/applicationContextxml</paramvalue>

</contextparam>

<listener>

<listenerclass>orgspringframeworkwebutilLogjConfigListener</listenerclass>

</listener>

<listener>

<listenerclass>orgsprntextContextLoaderListener</listenerclass>

</listener>

<servlet>

<servletname>action</servletname>

<servletclass>orgapachestrutsactionActionServlet</servletclass>

<initparam>

<paramname>config</paramname>

<paramvalue>/WEBINF/strutsconfigxml</paramvalue>

</initparam>

<initparam>

<paramname>debug</paramname>

<paramvalue></paramvalue>

</initparam>

<initparam>

<paramname>detail</paramname>

<paramvalue></paramvalue>

</initparam>

<loadonstartup></loadonstartup>

</servlet>

<servletmapping>

<servletname>action</servletname>

<urlpattern>*do</urlpattern>

</servletmapping>

</webapp>

sturtsconfigxml

<strutsconfig>

<actionmappings >

<action input=/indexjsp path=/test type=testStudentManagerAction >

<forward name=chenggong path=/chenggongjsp />

<forward name=shibai path=/shibaijsp />

</action>

</actionmappings>

<messageresources parameter=testApplicationResources />

</strutsconfig>

applicationContextxml

<?xml version= encoding=UTF?>

<!DOCTYPE beans PUBLIC //SPRING//DTD BEAN//EN beansdtd>

<beans>

<bean id=dataSource

class=monsdbcpBasicDataSource destroymethod=close >

<property name=driverClassName value=commicrosoftjdbcsqlserverSQLServerDriver></property>

<property name=url value=jdbc:microsoft:sqlserver://:;databasename=test></property>

<property name=username value=sa></property>

<property name=password value=sa></property>

</bean>

<bean id=transactionManager class=orgspringframeworkjdbcdatasourceDataSourceTransactionManager>

<property name=dataSource ref=dataSource/>

</bean>

<bean id=baseTxProxy class=orgspringframeworktransactioninterceptorTransactionProxyFactoryBean lazyinit=true>

<property name=transactionManager>

<ref bean=transactionManager />

</property>

<property name=transactionAttributes>

<props>

<prop key=*>PROPAGATION_REQUIRED</prop>

</props>

</property>

</bean>

<bean id=stdServiceManager parent=baseTxProxy >

<property name=target>

<bean class=testStudentManagerServiceImp>

<property name=stdDAO>

<ref bean=stdDAO/>

</property>

</bean>

</property>

</bean>

<bean id=stdDAO class=testStudentDAOImp>

<property name=dataSource ref=dataSource/>

</bean>

</beans>

运行程序启动服务器并部署.进入indexjsp页面点击执行超链接>页面跳向shibaijsp

查看控制台打印有action execute service exception!

查看数据库student表中的[ xiaoming wuhan] 记录仍然存在student表仍然为空.

小结如果DAO层和Service不捕获异常而在web层捕获异常web成功捕获异常spring事务管理成功!

测试情形二

web层捕获异常并处理Service捕获异常并处理DAO层不捕获异常.

修改StudentManagerServiceImp类

public class StudentManagerServiceImp implements StudentManagerService{

private StudentDAO stdDAO;

public void setStdDAO(StudentDAO stdDAO){

thisstdDAO=stdDAO;

}

//此方法为事务型的删除student中的记录成功且插入student的记录也成功

//如果insertStudent()方法执行失败那么deleteStudent()也应该会失败

public void bus_method(){

try{

thisstdDAOdeleteStudent();

thisstdDAOinsertStudent();

}

catch(DataAccessException de)

Systemerrprintln(service execute exception!);

}

}

}

运行程序启动服务器并部署.进入indexjsp页面点击执行超链接>页面跳向chenggongjsp

查看控制台打印有service execute exception!

查看数据库student表中的[ xiaoming wuhan] 记录不存在student表仍然为空.

小结如果Service捕获异常并处理而不向外抛出web层捕获不到异常spring事务管理失败!

测试情形(还原表中的数据)三

web层捕获异常Service捕获异常DAO层也捕获异常.

修改StudentDAOImp类代码

public class StudentDAOImp extends JdbcDaoSupport implements StudentDAO{

//删除student表中的id=的记录

public void deleteStudent(){

try{

JdbcTemplate jt=thisgetJdbcTemplate();

jtupdate(delete from student where id=);

}

catch(DataAccessException e){

Systemerrprintln(dao deleteStudentexecute exception!);

}

}

//将student表中删除的记录插入到student但是此方法实现有错因为

//id字段设置为自增长的所以在插入记录时我们不能指定值

public void insertStudent(){

try{

JdbcTemplate jt=thisgetJdbcTemplate();

String arg[]=new String[];

arg[]=;

arg[]=xiaoming;

arg[]=wuhan;

jtupdate(insert student(idnameaddress) values(???)arg);

}

catch(DataAccessException e){

Systemerrprintln(dao insertStudent execute exception!);

}

}

}

运行程序启动服务器并部署.进入indexjsp页面点击执行超链接>页面跳向chenggongjsp

查看控制台打印有dao insertStudent execute exception!

查看数据库student表中的 xiaomingwuhan 记录不存在student表仍然为空.

小结如果DAO的每一个方法自己捕获异常并处理而不向外抛出Service层捕获不到异常Web层同样捕获不到异常spring事务管理失败!

测试情形四

还原数据库中的数据

还原StudentDAOImp类中的方法为测试情形一中的实现

web层捕获异常Service抛出的自定义异常StudentManagerException

Service捕获DataAccessException并抛出StudentManagerException

StudentManagerException为DataAccessException的子类

DAO层不捕获异常

修改StudentManagerServiceImp类的实现

public class StudentManagerServiceImp implements StudentManagerService{

private StudentDAO stdDAO;

public void setStdDAO(StudentDAO stdDAO){

thisstdDAO=stdDAO;

}

//此方法为事务型的删除student中的记录成功且插入student的记录也成功

//如果insertStudent()方法执行失败那么deleteStudent()也应该会失败

public void bus_method() throws StudentManagerException{

try{

thisstdDAOdeleteStudent();

thisstdDAOinsertStudent();

}

catch(DataAccessException de)

Systemerrprintln(service execute exception!);

throw new StudentManagerException();//StudentManagerException类继承DataAcce//ssException异常

}

}

}

修改StudentManagerAction

public class StudentManagerAction extends Action{

public ActionForward execute(ActionMapping mapping ActionForm form

HttpServletRequest request HttpServletResponse response) {

try{

WebApplicationContext appContext=WebApplicationContextUtils

getWebApplicationContext(thisgetServlet()getServletContext());

StudentManagerService stdm=(StudentManagerService)appContext

getBean(stdServiceManager);

stdmbus_method();

return mappingfindForward(chenggong);

}

catch(StudentManagerExceptione){

Systemerrprintln(action execute service exception!);

return mappingfindForward(shibai);

}

}

}

运行程序启动服务器并部署.进入indexjsp页面点击执行超链接>页面跳向shibaijsp

查看控制台打印有service execute exception!

action execute service exception!

查看数据库student表中的 [xiaomingwuhan] 记录仍然存在student表仍然为空.

小结如果DAO的每一个方法不捕获异常Service层捕获DataAccessException异常并抛出自己定义异常(自定义异常为DataAccessException的子类)Web层可以捕获到异常spring事务管理成功!

结合源码总结

spring在进行声明时事务管理时通过捕获Service层方法的DataAccessException来提交和回滚事务的而Service层方法的DataAccessException又是来自调用DAO层方法所产生的异常.

我们一般在写DAO层代码时如果继承JdbcDaoSupport 类并使用此类所实现的JdbcTemplate来执行数据库操作此类会自动把低层的SQLException转化成DataAccessException以及DataAccessException

的子类.

一般在Service层我们可以自己捕获DAO方法所产成的DataAccessException然后再抛出一个业务方法有意义的异常(ps:此异常最好继承DataAccessException)然后在Web层捕获这样我们就可以手动编码的灵活实现通过业务方法执行的成功和失败来向用户转发不同的页面.

               

上一篇:Spring声明式事务管理源码解读之事务提交

下一篇:Eclipse 3.6——Java开发者的新选择