前言
對(duì)于經(jīng)歷過直接用jdbc和ejb開發(fā)企業(yè)應(yīng)用年代的人來說蛙婴，spring強(qiáng)大的事務(wù)管理有時(shí)是選擇用它的真正理由。jdbc的編程式本地事務(wù)控制確實(shí)能讓程序員直命就里怪嫌，但是大型項(xiàng)目的編程苦不堪言，ejb的容器托管的聲明式事務(wù)控制一定程度解放了程序員，在享受這種暢快的同時(shí)卻又陷入了ejb生態(tài)過于重量化的酸爽焕檬。
spring的事務(wù)管理的強(qiáng)大之處在于不論本地事務(wù)還是分布式事務(wù)控制，都提供統(tǒng)一的支持澳泵，包括編程式和聲明式实愚。當(dāng)然聲明式的事務(wù)管理是企業(yè)應(yīng)用編程的首推方式，程序員的注意力只需關(guān)注一個(gè)事務(wù)的開始和結(jié)束兔辅，也就是事務(wù)邊界腊敲，至于事務(wù)涉及到哪些資源都交給框架去完成。
本文在前兩篇spring4系列博文基礎(chǔ)上完成sh 工程的service層事務(wù)控制幢妄，最終打造利用一個(gè)spring和hibernate提供restful api兔仰，具數(shù)據(jù)庫操作能力的web服務(wù)。
概念
@Transactional注解中可以配置propagation指定事務(wù)傳播方式蕉鸳，以及isolation指定事務(wù)隔離級(jí)別乎赴。
spring的Propagation提供了如下事務(wù)傳播屬性：
- REQUIRED
進(jìn)入當(dāng)前事務(wù)忍法，如果沒有事務(wù)則創(chuàng)建新的事務(wù) - SUPPORTS
支持當(dāng)前事務(wù)狀態(tài)，如果有事務(wù)則進(jìn)入榕吼，沒有則無事務(wù)方式運(yùn)行 - MANDATORY
當(dāng)前必須有事務(wù)饿序，如果沒有則拋異常 - REQUIRES_NEW
無論如何都創(chuàng)建新的事務(wù) - NOT_SUPPORTED
非事務(wù)方式運(yùn)行 - NEVER
非事務(wù)方式運(yùn)行，如果當(dāng)前有事務(wù)則拋出異常 - NESTED
新建一個(gè)事務(wù)羹蚣，如果當(dāng)前事務(wù)存在原探，則以嵌套事務(wù)運(yùn)行
為防止臟讀、不可重復(fù)讀顽素、幻讀咽弦，Isolation提供了如下隔離屬性：
- DEFAULT
隔離級(jí)別由數(shù)據(jù)庫來定 - READ_UNCOMMITTED
可讀未提交，允許一個(gè)事務(wù)讀取另一個(gè)事務(wù)的修改但未提交的內(nèi)容（會(huì)導(dǎo)致臟讀） - READ_COMMITTED
可讀已提交胁出，允許一個(gè)事務(wù)讀取另一個(gè)事務(wù)的已提交內(nèi)容（會(huì)不可重復(fù)讀） - REPEATABLE_READ
可重復(fù)讀型型，防止不可重復(fù)讀（會(huì)幻讀） - SERIALIZABLE
串行化
調(diào)整DAO
sh工程的DAO目前是方法內(nèi)自己通過hibernate的session編程式的完成事務(wù)管理，因?yàn)橐某蓅pring托管的事務(wù)管理方式全蝶，所以闹蒜，調(diào)整的內(nèi)容包括去掉這些方法自己的編程式事務(wù)管理代碼，并在DAO類上聲明@Repository注解抑淫，告訴spring框架該類是DAO绷落。
去掉事務(wù)控制代碼后的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實(shí)現(xiàn)PersonServiceImpl
該類添加了@Transactional注解始苇，告訴spring框架事務(wù)控制在該service的每個(gè)方法上砌烁。
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);
}
}
調(diào)整spring配置
打開springmvc-servlet.xml，添加dao和service掃描包
<context:component-scan base-package="sh.dao" />
<context:component-scan base-package="sh.service" />
刪除或注釋掉先前personDAO的bean聲明催式，因?yàn)樵贒AO的類上添加了注解往弓，并通過以上掃描包的配置告訴spring取收集bean.
<!-- <bean id="personDAO" class="sh.dao.PersonDAOImpl"/> -->
添加如下配置，支持事務(wù)通過注解來聲明
<tx:annotation-driven transaction-manager="transactionManager"/>
統(tǒng)一管理hibernate的配置：
刪除WEB-INF下的hibernate-cfg.xml蓄氧，將相關(guān)配置移到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>
改為如下內(nèi)容喉童，切記spring托管事務(wù)的環(huán)境下hibernate.current_session_context_class屬性不可以再配置為thread撇寞，可以不配置該屬性，spring會(huì)自動(dòng)選擇對(duì)應(yīng)的SpringSessionContext堂氯，如果非要設(shè)置就設(shè)置為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>
調(diào)整controller
增加service層后蔑担，controller完成數(shù)據(jù)庫訪問不再是直接和DAO交互了，因此咽白，改為注入service啤握，并調(diào)用service完成業(yè)務(wù)邏輯。
調(diào)整后的控制器如下：
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();
}
}
