前言
对于经历过直接用jdbc和ejb开发企业应用年代的人来说，spring强大的事务管理有时是选择用它的真正理由。jdbc的编程式本地事务控制确实能让程序员直命就里，但是大型项目的编程苦不堪言，ejb的容器托管的声明式事务控制一定程度解放了程序员，在享受这种畅快的同时却又陷入了ejb生态过于重量化的酸爽。
spring的事务管理的强大之处在于不论本地事务还是分布式事务控制，都提供统一的支持，包括编程式和声明式。当然声明式的事务管理是企业应用编程的首推方式，程序员的注意力只需关注一个事务的开始和结束，也就是事务边界，至于事务涉及到哪些资源都交给框架去完成。
本文在前两篇spring4系列博文基础上完成sh 工程的service层事务控制，最终打造利用一个spring和hibernate提供restful api，具数据库操作能力的web服务。
概念
@Transactional注解中可以配置propagation指定事务传播方式，以及isolation指定事务隔离级别。
spring的Propagation提供了如下事务传播属性：
- REQUIRED
进入当前事务，如果没有事务则创建新的事务 - SUPPORTS
支持当前事务状态，如果有事务则进入，没有则无事务方式运行 - MANDATORY
当前必须有事务，如果没有则抛异常 - REQUIRES_NEW
无论如何都创建新的事务 - NOT_SUPPORTED
非事务方式运行 - NEVER
非事务方式运行，如果当前有事务则抛出异常 - NESTED
新建一个事务，如果当前事务存在，则以嵌套事务运行
为防止脏读、不可重复读、幻读，Isolation提供了如下隔离属性：
- DEFAULT
隔离级别由数据库来定 - READ_UNCOMMITTED
可读未提交，允许一个事务读取另一个事务的修改但未提交的内容（会导致脏读） - READ_COMMITTED
可读已提交，允许一个事务读取另一个事务的已提交内容（会不可重复读） - REPEATABLE_READ
可重复读，防止不可重复读（会幻读） - SERIALIZABLE
串行化
调整DAO
sh工程的DAO目前是方法内自己通过hibernate的session编程式的完成事务管理，因为要改成spring托管的事务管理方式，所以，调整的内容包括去掉这些方法自己的编程式事务管理代码，并在DAO类上声明@Repository注解，告诉spring框架该类是DAO。
去掉事务控制代码后的PersonImpl代码如下：
package sh.dao;
import java.util.List;
import org.hibernate.Session;
import org.hibernate.SessionFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Repository;
import sh.pojo.Person;
@Repository
public class PersonDAOImpl implements PersonDAO {
@Autowired
private SessionFactory sessionFactory;
@Override
public List<Person> getAll() {
Session session = sessionFactory.getCurrentSession();
List<Person> all all = session.createQuery("from Person").getResultList();
return all;
}
@Override
public void add(Person person) {
Session session = sessionFactory.getCurrentSession();
session.save(person);
}
}
增加service层
新建sh.service包，新建PersonService接口
package sh.service;
import java.util.List;
import sh.vo.Person;
public interface PersonService {
public List<Person> getAll();
public void add(Person person);
}
增加service实现PersonServiceImpl
该类添加了@Transactional注解，告诉spring框架事务控制在该service的每个方法上。
package sh.service;
import java.util.ArrayList;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;
import sh.dao.PersonDAO;
import sh.vo.Person;
@Service
@Transactional
public class PersonServiceImpl implements PersonService {
@Autowired
private PersonDAO personDAO;
@Override
@Transactional(propagation=Propagation.NOT_SUPPORTED,readOnly=true)
public List<Person> getAll() {
List<sh.pojo.Person> list = personDAO.getAll();
List<Person> list2= new ArrayList<Person>();
if(list!=null){
for(sh.pojo.Person p:list){
Person p2 = new Person();
p2.setAge(p.getAge());
p2.setName(p.getName());
list2.add(p2);
}
}
return list2;
}
@Override
public void add(Person person) {
sh.pojo.Person p = new sh.pojo.Person();
p.setAge(person.getAge());
p.setName(person.getName());
personDAO.add(p);
}
}
调整spring配置
打开springmvc-servlet.xml，添加dao和service扫描包
<context:component-scan base-package="sh.dao" />
<context:component-scan base-package="sh.service" />
删除或注释掉先前personDAO的bean声明，因为在DAO的类上添加了注解，并通过以上扫描包的配置告诉spring取收集bean.
<!-- <bean id="personDAO" class="sh.dao.PersonDAOImpl"/> -->
添加如下配置，支持事务通过注解来声明
<tx:annotation-driven transaction-manager="transactionManager"/>
统一管理hibernate的配置：
删除WEB-INF下的hibernate-cfg.xml，将相关配置移到springmvc-servlet.xml的sessionFactory配置中，方便管理。
原先配置如下：
<bean id="sessionFactory" class="org.springframework.orm.hibernate5.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="configLocation" value="/WEB-INF/hibernate-cfg.xml" />
</bean>
改为如下内容，切记spring托管事务的环境下hibernate.current_session_context_class属性不可以再配置为thread，可以不配置该属性，spring会自动选择对应的SpringSessionContext，如果非要设置就设置为org.springframework.orm.hibernate5.SpringSessionContext
<bean id="sessionFactory" class="org.springframework.orm.hibernate5.LocalSessionFactoryBean">
<property name="dataSource" ref="dataSource" />
<property name="hibernateProperties">
<props>
<prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
<prop key="hibernate.show_sql">true</prop>
<prop key="hibernate.current_session_context_class">org.springframework.orm.hibernate5.SpringSessionContext</prop>
</props>
</property>
<property name="packagesToScan">
<list>
<value>sh.pojo</value>
</list>
</property>
</bean>
调整controller
增加service层后，controller完成数据库访问不再是直接和DAO交互了，因此，改为注入service，并调用service完成业务逻辑。
调整后的控制器如下：
package sh.controller;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import sh.service.PersonService;
import sh.vo.Person;
@Controller
public class HelloController {
@Autowired
PersonService personService;
@RequestMapping(value = "/person", method = RequestMethod.POST)
public @ResponseBody
Person addPerson(@RequestBody Person person) {
personService.add(person);
return person;
}
@RequestMapping(value = "/person", method = RequestMethod.GET)
public @ResponseBody
List<Person> getAllPerson() {
return personService.getAll();
}
}
网友评论