Spring中怎么使用注解實(shí)現(xiàn)聲明式事務(wù)操作

這篇文章將為大家詳細(xì)講解有關(guān)Spring中怎么使用注解實(shí)現(xiàn)聲明式事務(wù)操作，文章內(nèi)容質(zhì)量較高，因此小編分享給大家做個(gè)參考，希望大家閱讀完這篇文章后對(duì)相關(guān)知識(shí)有一定的了解。

一 配置文件

<?xml version="1.0" encoding="GBK"?><beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"   xmlns="http://www.springframework.org/schema/beans"   xmlns:p="http://www.springframework.org/schema/p"   xmlns:aop="http://www.springframework.org/schema/aop"   xmlns:tx="http://www.springframework.org/schema/tx"   xsi:schemaLocation="http://www.springframework.org/schema/beans   http://www.springframework.org/schema/beans/spring-beans-4.0.xsd   http://www.springframework.org/schema/aop   http://www.springframework.org/schema/aop/spring-aop-4.0.xsd   http://www.springframework.org/schema/tx   http://www.springframework.org/schema/tx/spring-tx-4.0.xsd">   <!-- 定義數(shù)據(jù)源Bean，使用C3P0數(shù)據(jù)源實(shí)現(xiàn)，并注入數(shù)據(jù)源的必要信息 -->   <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"      destroy-method="close"      p:driverClass="com.mysql.jdbc.Driver"      p:jdbcUrl="jdbc:mysql://localhost/spring"      p:user="root"      p:password="32147"      p:maxPoolSize="40"      p:minPoolSize="2"      p:initialPoolSize="2"      p:maxIdleTime="30"/>   <!-- 配置一個(gè)業(yè)務(wù)邏輯Bean -->   <bean id="newsDao" class="org.crazyit.app.dao.impl.NewsDaoImpl"      p:ds-ref="dataSource"/>   <!-- 配置JDBC數(shù)據(jù)源的局部事務(wù)管理器，使用DataSourceTransactionManager 類 -->   <!-- 該類實(shí)現(xiàn)PlatformTransactionManager接口，是針對(duì)采用數(shù)據(jù)源連接的特定實(shí)現(xiàn)-->   <!-- 配置DataSourceTransactionManager時(shí)需要依注入DataSource的引用 -->   <bean id="transactionManager"      class="org.springframework.jdbc.datasource.DataSourceTransactionManager"      p:dataSource-ref="dataSource"/>   <!-- 根據(jù)Annotation來生成事務(wù)代理 -->   <tx:annotation-driven transaction-manager="transactionManager"/></beans>

二 DAO

1 接口

package org.crazyit.app.dao;public interface NewsDao{   public void insert(String title, String content);}

2 實(shí)現(xiàn)類

package org.crazyit.app.dao.impl;import javax.sql.DataSource;import java.sql.Connection;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.transaction.annotation.*;import org.crazyit.app.dao.*;public class NewsDaoImpl implements NewsDao{  private DataSource ds;  public void setDs(DataSource ds)  {    this.ds = ds;  }  @Transactional(propagation=Propagation.REQUIRED ,    isolation=Isolation.DEFAULT , timeout=5)  public void insert(String title, String content)  {    JdbcTemplate jt = new JdbcTemplate(ds);    jt.update("insert into news_inf"      + " values(null , ? , ?)"      , title , content);    // 兩次插入的數(shù)據(jù)違反唯一鍵約束    jt.update("insert into news_inf"      + " values(null , ? , ?)"      , title , content);    // 如果沒有事務(wù)控制，則第一條記錄可以被插入    // 如果增加事務(wù)控制，將發(fā)現(xiàn)第一條記錄也插不進(jìn)去。  }}

三 測(cè)試類

package lee;import org.springframework.context.support.*;import org.springframework.context.*;import org.crazyit.app.dao.*;public class SpringTest{  public static void main(String[] args)  {    // 創(chuàng)建Spring容器    ApplicationContext ctx = new      ClassPathXmlApplicationContext("beans.xml");    // 獲取事務(wù)代理Bean    NewsDao dao = (NewsDao)ctx      .getBean("newsDaoTrans" , NewsDao.class);    // 執(zhí)行插入操作    dao.insert("瘋狂Java" , "輕量級(jí)Java EE企業(yè)應(yīng)用實(shí)戰(zhàn)");  }}

四 測(cè)試

數(shù)據(jù)庫沒生成數(shù)據(jù)，說明事務(wù)生效。

Exception in thread "main" org.springframework.dao.DuplicateKeyException: PreparedStatementCallback; SQL [insert into news_inf values(null , ? , ?)]; Duplicate entry '瘋狂Java' for key 'news_title'; nested exception is com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '瘋狂Java' for key 'news_title' at org.springframework.jdbc.support.SQLErrorCodeSQLExceptionTranslator.doTranslate(SQLErrorCodeSQLExceptionTranslator.java:239) at org.springframework.jdbc.support.AbstractFallbackSQLExceptionTranslator.translate(AbstractFallbackSQLExceptionTranslator.java:73) at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:660) at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:909) at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:970) at org.springframework.jdbc.core.JdbcTemplate.update(JdbcTemplate.java:980) at org.crazyit.app.dao.impl.NewsDaoImpl.insert(NewsDaoImpl.java:33) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:317) at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157) at org.springframework.transaction.interceptor.TransactionInterceptor$1.proceedWithInvocation(TransactionInterceptor.java:98) at org.springframework.transaction.interceptor.TransactionAspectSupport.invokeWithinTransaction(TransactionAspectSupport.java:262) at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:95) at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207) at com.sun.proxy.$Proxy4.insert(Unknown Source) at lee.SpringTest.main(SpringTest.java:28)Caused by: com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException: Duplicate entry '瘋狂Java' for key 'news_title' at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) at sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62) at sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45) at java.lang.reflect.Constructor.newInstance(Constructor.java:423) at com.mysql.jdbc.Util.handleNewInstance(Util.java:409) at com.mysql.jdbc.Util.getInstance(Util.java:384) at com.mysql.jdbc.SQLError.createSQLException(SQLError.java:1039) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4232) at com.mysql.jdbc.MysqlIO.checkErrorPacket(MysqlIO.java:4164) at com.mysql.jdbc.MysqlIO.sendCommand(MysqlIO.java:2615) at com.mysql.jdbc.MysqlIO.sqlQueryDirect(MysqlIO.java:2776) at com.mysql.jdbc.ConnectionImpl.execSQL(ConnectionImpl.java:2838) at com.mysql.jdbc.PreparedStatement.executeInternal(PreparedStatement.java:2082) at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2334) at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2262) at com.mysql.jdbc.PreparedStatement.executeUpdate(PreparedStatement.java:2246) at com.mchange.v2.c3p0.impl.NewProxyPreparedStatement.executeUpdate(NewProxyPreparedStatement.java:147) at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:916) at org.springframework.jdbc.core.JdbcTemplate$2.doInPreparedStatement(JdbcTemplate.java:909) at org.springframework.jdbc.core.JdbcTemplate.execute(JdbcTemplate.java:644) ... 18 more

關(guān)于Spring中怎么使用注解實(shí)現(xiàn)聲明式事務(wù)操作就分享到這里了，希望以上內(nèi)容可以對(duì)大家有一定的幫助，可以學(xué)到更多知識(shí)。如果覺得文章不錯(cuò)，可以把它分享出去讓更多的人看到。