2. 程式人生 > >Spring的資料訪問---------------事務管理

Spring的資料訪問---------------事務管理

阿新 • • 發佈：2018-11-19

ThreadLocal

　　ThreadLocal為每一個使用該變數的執行緒分配一個變數副本，所以每一個執行緒在改變自己的副本時，不會改變其他執行緒的副本資訊。該類主要包含四個方法：

　　public void set(Object obj)

　　public Object get()

　　public void remove()

　　protected Object InitialValue()

package thread;

public class ThreadLocalTest {
	private static final ThreadLocal<Integer> local = ThreadLocal.withInitial(()->0);
	public static void main(String[] args) throws InterruptedException {
	        for(int i = 0; i < 10;i++){
	            new MyThread(i).start();
	        }
	    }
	static class MyThread extends Thread{
		private int end;
		public MyThread(int end) {
			this.end = end;
			}
		@Override
		public void run() {
			System.out.println(Thread.currentThread().getName() + " start, local = " + local.get());
			for(int i = 0; i <= end;i++){
				local.set(local.get() + i); //計算(end+1)*end/2的值
				}
			System.out.println(Thread.currentThread().getName() + " end, local = " + local.get());
			}
		}
}

JDBC對事務的支援

　　JDBC在進行資料庫連線時，可以通過DataSource連線資料庫，並將PreparedStatement預處理關閉，並將資料庫連線關閉。例項如下：　

package com.kingdee.opensys.common.base.imp;

import java.lang.reflect.Method;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.util.HashMap;
import java.util.LinkedList;
import java.util.List;
import java.util.Map;

import org.springframework.jdbc.support.JdbcUtils;

public class CommonDao {
private IPage page;
public IPage getPage() {
	return page;
}
public void setPage(IPage page) {
	this.page = page;
}

//建立資料庫連線池
private  static ConnectionProvider connectionProvider;
//建立執行緒池
private static ThreadLocal<Connection> conWrapper = new ThreadLocal<Connection>();
//開啟連線
private static Connection getConnection() throws SQLException{
	Connection con = connectionProvider.getConnection();
	if(con != null || !con.isClosed()){
		return con;
	}
	//從執行緒池中獲取資料庫連線
	con = connectionProvider.getConnection();
	if(con == null){
		throw new SQLException("�޷���ȡ��ݿ�����"); 
	}
	//對新建立的資料庫連線放到執行緒池中
	conWrapper.set(con);
	return con;
}
//關閉連線
public static void closeConnection() throws SQLException{
	//從執行緒池中獲取連線池
	Connection con = conWrapper.get();
	if(con != null){
		con.close();
	}
	conWrapper.remove();
}
//關閉ResultSet和Statement
private void cleanup(ResultSet resultSet,PreparedStatement pre){
	if(resultSet != null){
		try {
			resultSet.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	if(pre != null){
		try {
			pre.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}
/**
 * 關閉PreparedStatement
 * @param pre
 */
private void cleanup(PreparedStatement pre){
	if(pre != null){
		try {
			pre.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
}
}

Spring對事務管理的支援

　　事務管理關鍵抽象

　　　　TransactionDefinition：主要用來定義事務的屬性，例如：事務隔離級別、超時時間、是否為只讀事務等。

　　　　PlatformTransactionManager：根據事務指定的屬性，建立事務。

　　　　TransactionStatus：事務狀態。

　　事務管理器實現類

　　　　Spring在不同的框架實現了事務管理器介面PlatformTransactionManager，其中Spring為基於DataSource資料來源的持久化技術例如SpringJDBC和iBats的事務管理器類為DataSourceTransactionManager。

　　　　基於DataSource資料來源的事務管理器　　

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"> 
	<property name="driverClassName"> 
		<value>oracle.jdbc.driver.OracleDriver</value> 
    </property> 
    <property name="url"> 
        <value>jdbc:oracle:thin:@localhost:1521:orcl</value> 
    </property> 
    <property name="username"> 
        <value>test</value> 
    </property> 
    <property name="password"> 
        <value>test</value> 
    </property> 
    <property name="maxActive"> 
        <value>255</value> 
    </property> 
    <property name="maxIdle"> 
        <value>2</value> 
    </property> 
    <property name="maxWait"> 
        <value>120000</value> 
    </property> 
</bean> 
<bean name="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="datasource" ref="dataSource"/>
</bean>

　　DataSourceTransactionManager使用DataSource的Connect的commit()和rollBack()等方法管理事務。

　　事務同步管理器

　　　　在訪問資料庫時建立的連線或者會話統稱為資源，該資源在同一時間無法實現多執行緒共享，Spring的事務同步管理器TransactionSynchronizationManager通過ThreadLocal為不同的事務執行緒提供獨立的資源副本。無論宣告式事務還是程式設計式事務都需要事務同步管理器。

程式設計式事務管理

　　Spring為程式設計式事務管理提供模板類TransactionTemplate，可以在多個業務類中共享TransactionTemplate例項進行事務管理。由於Spring事務管理是基於TransactionSynchronizationManager進行工作的，所以如果在回撥介面方法顯示訪問底層資料連線，必須通過資源工具類得到執行緒繫結的資料連線。

<bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource" destroy-method="close">
        <!-- Connection Info -->
        <property name="driverClassName" value="${jdbc.driver}"/>
        <property name="url" value="${jdbc.url}"/>
        <property name="username" value="${jdbc.username}"/>
        <property name="password" value="${jdbc.password}"/>
        <!-- Connection Pooling Info -->
        <property name="maxActive" value="3"/>
        <property name="defaultAutoCommit" value="false"/>
        <!-- 連線Idle一個小時後超時 -->
        <property name="timeBetweenEvictionRunsMillis" value="3600000"/>
        <property name="minEvictableIdleTimeMillis" value="3600000"/>
    </bean>
    <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">    
        <property name="dataSource" ref="dataSource"/>  
    </bean>

　　PlatformTransactionManager程式設計式事務管理的例項：

public void testPlatformTransactionManager() {
        DefaultTransactionDefinition def = new DefaultTransactionDefinition();
        def.setIsolationLevel(TransactionDefinition.ISOLATION_READ_COMMITTED);  
        def.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRED); 
        TransactionStatus status = txManager.getTransaction(def); 
        Connection connection = DataSourceUtils.getConnection(dataSource);
        try{
              connection.prepareStatement(CREATE_TABLE_SQL).execute();  
              PreparedStatement pstmt = connection.prepareStatement(INSERT_SQL);  
              pstmt.setString(1, "test");  
              pstmt.execute();  
              connection.prepareStatement(DROP_TABLE_SQL).execute();  
              txManager.commit(status);
        }catch(Exception ex){
            status.setRollbackOnly();  
            txManager.rollback(status);
        }finally{
            DataSourceUtils.releaseConnection(connection, dataSource);
        }
    }

　　TransactionTemplate程式設計式事務管理的例項：

　　建立TransactionTemplate類

public class TransactionTemplateUtils {
    private static TransactionTemplate getTransactionTemplate(
            PlatformTransactionManager txManager, int propagationBehavior,
            int isolationLevel) {
        TransactionTemplate transactionTemplate = new TransactionTemplate(txManager);
        transactionTemplate.setPropagationBehavior(propagationBehavior);
        transactionTemplate.setIsolationLevel(isolationLevel);
        return transactionTemplate;
    }
    public static TransactionTemplate getDefaultTransactionTemplate(PlatformTransactionManager txManager) {
        return getTransactionTemplate(txManager,
                TransactionDefinition.PROPAGATION_REQUIRED,
                TransactionDefinition.ISOLATION_READ_COMMITTED);
    }
}

　　通過TransactionTemplate類設定事務管理

public void save(final User user){
        TransactionTemplate transactionTemplate = TransactionTemplateUtils.getDefaultTransactionTemplate(txManager);
        transactionTemplate.execute(new TransactionCallbackWithoutResult(){
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus arg0) {
                userDao.save(user);  
                user.getAddress().setUserId(user.getId());  
                try {
                    addressService.save(user.getAddress());
                } catch (Exception e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }  
            }
        });
    }

XML配置宣告式事務管理

　　Spring的宣告式事務管理是通過SpringAOP實現的，Spring負責將事務管理器增強邏輯織入到業務方法連線點。

　　宣告式事務管理的過程：

　　　　1、建立目標類。

　　　　2、在xml中配置資料來源。

　　　　3、宣告事務管理器。

　　　　4、使用事務代理工廠類目標業務類織入增強。

　　例項：

<!-- 配置JDBC資料來源的區域性事務管理器，使用DataSourceTransactionManager類，該類實現了PlatformTransactionManager介面，是針對採用資料來源連線的特定實現 -->
<bean id="transactionManager"   class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<!-- 配置TransactionManager時需要注入資料來源引用 -->
<property name="dataSource" ref="dataSource" />
</bean>
<!-- 下面這個是前面定義的業務Bean -->
<bean id="newsDao" class="com.abc.dao.impl.NewsDaoImpl">
<!-- 為業務Bean注入屬性 -->
<property name="dataSource" ref="dataSource" />
</bean>
<bean id="newsDaoTransProxy" 
class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean">
<!-- 為事務代理工廠Bean注入事務管理器 -->
<property name="transactionManager" ref="transactionManager" />
<!-- 要在哪個Bean上面建立事務代理物件 -->
<property name="target" ref="newsDao" />
<!-- 指定事務屬性 -->
<property name="transactionAttributes">
<props>
<prop key="*">PROPAGATION_REQUIRED</prop>
</props>
</property>
</bean>

　　業務邏輯中使用事務

package com.abc.dao.impl;
public class NewsDaoImpl implements NewsDao {
    private DataSource dataSource;
    public void setDataSource(DataSrouce dataSource) {
        this.dataSource = dataSource;
    }
    public void insert(String title, String content) {
        JdbcTemplate template = new JdbcTemplate(dataSource);
        template.update("insert into news_table values (....)");
        //兩次相同的操作，將違反主鍵約束
        template.update("insert into news_table values (....)");
    }
}

註解配置宣告式事務管理

　　註解事務管理器的過程

　　　　1、在目標類註解事務@Transaction。

　　　　2、在xml中配置資料來源。

　　　　3、配置事務管理器。

　　　　4、通過<tx:annotation-driven>織入標註@Transaction註解的Bean進行加工處理事務管理器切面。

　　@Transaction屬性

　　　　ioslation：事務隔離級別

　　　　readOnly：事務讀寫屬性

　　　　timeOut：超時屬性

　　　　rollbackFor：遇到一組異常，需要回滾。

　　@Transaction標註位置

　　　@Transaction可以標註在類上或者方法上，如果只標註在類上表示整個類中的方法都會使用該事務。如果只標註在方法上表示該事務只對單獨的方法起作用。如果在類上或者方法上都存在事務，方法上的事務會覆蓋類上的事務。

　　使用不同事務管理器

　　　　在同一個類中不同的方法上會標註不同的事務管理器，不同的事務管理器所嵌入的資料來源不同。

　　例項：

<!-- PlatformTransactionMnager1-->
<bean id="txManager1" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource1" />
<qualifier value="transaction1"/> 
</bean>
<!-- enable transaction annotation support -->
<tx:annotation-driven transaction-manager="txManager1" />
<!-- PlatformTransactionMnager2 -->
<bean id="txManager2" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource2" />
<qualifier value="transaction2"/> 
</bean>
<!-- enable transaction annotation support -->
<tx:annotation-driven transaction-manager="txManager2" />

　　對業務處理進行事務註解　

@Transactional (value="transaction1")
public class TestServiceBean implements TestService { 
     private TestDao dao; 
     public void setDao(TestDao dao) { 
         this.dao = dao; 
} 
@Transactional(value="transaction2",propagation =Propagation.NOT_SUPPORTED)
public List getAll() { 
      return null; 
     } 
}

相關推薦

Spring的資料訪問---------------事務管理

ThreadLocal 　　ThreadLocal為每一個使用該變數的執行緒分配一個變數副本，所以每一個執行緒在改變自己的副本時，不會改變其他執行緒的副本資訊。該類主要包含四個方法： 　　public void set(Object obj) 　　public Object get() 　　publi

為spring添加事務管理

transacti man pan ota ger ring 今天 異常 自己的 今天把項目中的事務管理配置完成，在這個過程中可謂一波三折，剛開始出現不少問題，最後自己都一一克服了。 今天在做spring配置的時候比較心急，總想著讓自己快速的配置完成，這

Spring中的事務管理

java編程 聲明式事務 body ram 屬性 per col 註解 配置數據源 配置註解 <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTra

spring boot開啟事務管理，使用事務的回滾機制，使兩條插入語句一致

value nbsp tcl true 管理 配置 AI let dao spring boot 事務管理，使用事務的回滾機制 1：配置事務管理 在springboot 啟動類中添加 @EnableTransactionManagement //開啟事務管

第十二講：12，spring宣告式事務管理-註解式

1，複製專案spring404 ，改名spring404-3。修改BankServiceImpl類，添加註解，package com.cruise.service.impl;import org.springframework.transaction.annotation.Tra

第十一講：11.spring宣告式事務管理-xml方式

1，複製專案spring404 ，改名spring404-2，修改BankServiceImpl類，刪除宣告式事務的程式碼。宣告式事務管理的方式缺點是，事務程式碼嚴重嵌入邏輯程式碼中 package com.cruise.service.impl; import org.springframewor

spring宣告式事務管理方式( 基於tx和aop名字空間的xml配置[email&#

轉自：https://www.cnblogs.com/niceyoo/p/8732891.html 1. 宣告式事務管理分類 宣告式事務管理也有兩種常用的方式， 一種是基於tx和aop名字空間的xml配置檔案，另一種就是基於@Transactional註解。 顯然基於註解的方式更簡單

Spring整合MyBatis 事務管理

前言         spring事務管理包含兩種情況，程式設計式事務、宣告式事務。而宣告式事務又包括基於註解@Transactional和tx+aop的方式。那麼本文先分析程式設計式註解事務和基於註解的宣告式事務。 程式設計式事務管理使用TransactionTempla

spring service層事務管理小結

前言： 選擇spring作為開發的框架，很大一部分因素是spring框架完善的事務處理機制，spring的事務實現主要分為兩種，一種是基於Dao層，另一種是基於Service層，前者是針對單個dao的持久化操作做了事務控制，控制粒度比較小，後者則是基於業務的原則性需求，將一個原子性業務的

spring學習系列 --- 事務管理

1、事務管理 ---- 主要是保證事務執行過程中，輸入的資料不出現問題 在開發過程中，就是可能會出現程式執行中斷，原因可能是程式bug，一塊程式想實現一個完整的功能，要是無法全部完成，反倒是會造成錯誤，所以希望這塊程式碼要麼是執行完成，要麼就是全部沒有執行，即出現執行部分的

spring的一個事務管理，在controller層和dao層都可以用

import org.springframework.transaction.support.DefaultTransactionDefinition; public PlatformTransactionManager getTransactionManager() { re

Spring框架的事務管理之程式設計式的事務管理（瞭解）

1. 說明：Spring為了簡化事務管理的程式碼:提供了模板類 TransactionTemplate，所以手動程式設計的方式來管理事務，只需要使用該模板類即可！ 2. 手動程式設計方式的具體步驟如下： 1. 步驟一:配置一個事務管理器，Spring使用PlatformT

Java進階學習第二十四天（Spring框架：事務管理、Spring與Hibernate整合）

一、事務控制 1、引入 使用者訪問 > Action > Service > Dao 如何保證： 在service中呼叫2次dao，其中一個dao執行失敗，整個操作要回滾 2、事務控制概述 ① 程式設計式事務控制：自己手動控制事務 Jdbc程式

Spring框架的事務管理的基本概念

1. 事務：指的是邏輯上一組操作，組成這個事務的各個執行單元，要麼一起成功,要麼一起失敗！ 2. 事務的特性 * 原子性 * 一致性 * 隔離性 * 永續性 3. 如果不考慮隔離性,引發安全性問題 * 讀問題: * 髒讀: * 不可重複

Spring框架的事務管理之基於AspectJ的XML方式（重點掌握）

1. 步驟一:恢復轉賬開發環境（轉賬開發環境見“https://www.cnblogs.com/wyhluckdog/p/10137283.html”） 2.步驟二:引入AOP的開發包3.步驟三：引入applicationContext.xml配置檔案　　* 配置檔案的基本配置為： <?xml

Spring框架的事務管理之基於AspectJ的註解方式（重點掌握，最簡單的方式）

1. 步驟一:恢復轉賬的開發環境（具體開發環境實現見：https://www.cnblogs.com/wyhluckdog/p/10137283.html）2. 步驟二：applicationContext的基本配置為： <?xml version="1.0" encoding="UTF-8"?

詳解spring中的事務管理（程式設計式的事務管理，宣告式的事務管理）

spring提供的事務管理API 1. PlatformTransactionManager:平臺事務管理器. commit(TransactionStatus status) getTransaction(TransactionDefinition de

14 Spring框架的事務管理

通過手動編寫程式碼的方式完成事務的管理 1.配置DataSourceTransactionManager事務管理器傳入資料庫連線池屬性dataSource 2.配置TransactionTemplate事務模板傳入事務管理器屬性DataSourc

Spring學習11-- 事務管理

一、事務的四個特性 事務包括四個特徵（ACID） 1、原子性（Atomicity）：也就是說事務中的操作必須要保證是原子性的，不可再分的，意思就是說，一步失敗，則全部失敗，全部成功，才算成功。 2

Spring架構---Spring中的事務管理詳解

Spring中的事務管理詳解 1. 事務簡介： 事務管理是企業級應用程式開發中必不可少的技術，用來確保資料的完整性和一致性 事務就是一系列的動作，它們被當作一個單獨的工作單元。這些動作要麼全部完成，要麼全部不起作用 2. 事務的四個關鍵屬性(ACID) ① 原子性(atomici