spring4之service層事務控制

前言

對于經歷過直接用jdbc和ejb開發(fā)企業(yè)應用年代的人來說，spring強大的事務管理有時是選擇用它的真正理由。jdbc的編程式本地事務控制確實能讓程序員直命就里，但是大型項目的編程苦不堪言，ejb的容器托管的聲明式事務控制一定程度解放了程序員，在享受這種暢快的同時卻又陷入了ejb生態(tài)過于重量化的酸爽。
spring的事務管理的強大之處在于不論本地事務還是分布式事務控制，都提供統一的支持，包括編程式和聲明式。當然聲明式的事務管理是企業(yè)應用編程的首推方式，程序員的注意力只需關注一個事務的開始和結束，也就是事務邊界，至于事務涉及到哪些資源都交給框架去完成。
本文在前兩篇spring4系列博文基礎上完成sh 工程的service層事務控制，最終打造利用一個spring和hibernate提供restful api，具數據庫操作能力的web服務。

概念

@Transactional注解中可以配置propagation指定事務傳播方式，以及isolation指定事務隔離級別。

spring的Propagation提供了如下事務傳播屬性：

  • REQUIRED
    進入當前事務，如果沒有事務則創(chuàng)建新的事務
  • SUPPORTS
    支持當前事務狀態(tài)，如果有事務則進入，沒有則無事務方式運行
  • MANDATORY
    當前必須有事務，如果沒有則拋異常
  • REQUIRES_NEW
    無論如何都創(chuàng)建新的事務
  • 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托管事務的環(huán)境下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完成業(yè)務邏輯。
調整后的控制器如下：

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();
    }
}
最后編輯于 ：
?著作權歸作者所有,轉載或內容合作請聯系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成，瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明：文章內容（如有圖片或視頻亦包括在內）由作者上傳并發(fā)布，文章內容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務。

相關閱讀更多精彩內容

  • Spring Boot 參考指南 介紹 轉載自:https://www.gitbook.com/book/qbgb...
    毛宇鵬閱讀 47,290評論 6贊 342
  • Spring Cloud為開發(fā)人員提供了快速構建分布式系統中一些常見模式的工具（例如配置管理，服務發(fā)現，斷路器，智...
    卡卡羅2017閱讀 136,715評論 19贊 139
  • spring官方文檔：http://docs.spring.io/spring/docs/current/spri...
    牛馬風情閱讀 1,861評論 0贊 3
  • 曾經，想過約三五好友，來一場親密旅行，曾幻想來一場說走就走的自由旅行，也曾想能執(zhí)子之手，踏遍山河，然后擇一城終老…...
    煙花三色閱讀 631評論 0贊 0
  • 在學習的過程中，經常看到一個形容媽媽的詞——“容器”。媽媽是孩子的生命最初的保護罩，承載孩子的喜怒驚恐悲。 或許，...
    風千夏閱讀 548評論 4贊 1

友情鏈接更多精彩內容