spring boot基于注解的声明式事务配置详解

@Configuration

@EnableTransactionManagement (proxyTargetClass = true )

public class TransactionConfig implements TransactionManagementConfigurer{

     @Value ( "${spring.datasource.driver-class-name}" )

     private String driverClassName;

     @Value ( "${spring.datasource.druid.url}" )

     private String url;

     @Value ( "${spring.datasource.druid.username}" )

     private String username;

     @Value ( "${spring.datasource.druid.password}" )

     private String password;

     @Bean

     public DataSource dataSourceDb() {

         DruidDataSource dataSource = new DruidDataSource();

         dataSource.setDriverClassName(driverClassName);

         dataSource.setUrl(url);

         dataSource.setUsername(username);

         dataSource.setPassword(password);

         return dataSource;

     }

     /**

      * 【作用】事务管理器<br>

      * 【说明】（无）

      * @param

      * @author Kalvin

      * @Date 2017/12/19 10:39

      */

     @Bean

     public PlatformTransactionManager transactionManager() {

         return new DataSourceTransactionManager(dataSourceDb());

     }

     // 创建事务管理器2

     @Bean (name = "txManager2" )

     public PlatformTransactionManager txManager2(EntityManagerFactory factory) {

         return new JpaTransactionManager(factory);

     }

     /**

      * 【作用】如果没有指定事务，默认返回当前事务管理<br>

      * 【说明】（无）

      * @param

      * @author kkyc

      * @Date 2017/12/19 10:03

      */

     @Override

     public PlatformTransactionManager annotationDrivenTransactionManager() {

         return transactionManager();

     }

}

<!-- 事物 -->

< dependency >

     < groupId >org.springframework</ groupId >

     < artifactId >spring-tx</ artifactId >

    </ dependency >

package com.Transaction.controller;

import java.util.List;

import org.springframework.beans.factory.annotation.Autowired;

import org.springframework.stereotype.Controller;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.web.bind.annotation.ResponseBody;

import com.Transaction.entity.Alarmtype;

import com.Transaction.mapper.AlarmtypeMapper;

import com.Transaction.service.AlarmtypeService;

@Controller

//@Transactional //事务级别，如果该类中同时操作多个方法，只要失败则全部回滚

public class AlarmtypeController {

  @Autowired

  AlarmtypeMapper alarmtypeMapper;

  @Autowired

  AlarmtypeService alarmtypeService;

  @RequestMapping ( "index" )

  public synchronized String index(){

   //List<Alarmtype> list = alarmtypeMapper.getAlarmtypeList();

   List<Alarmtype> list = alarmtypeService.findAll();

   for ( int i = 0 ; i < list.size(); i++) {

    System.out.println(list.get(i).getId()+ "--" +list.get(i).getAlarmname());

   }

   return "index" ;

  }

  //批量插入

  @RequestMapping ( "addBatch" )

  @ResponseBody

  @Transactional //对整个方法进行事务处理，方法体内只要有一个方法没执行成功则全部回滚

  public synchronized int addBatch(){

   Alarmtype alarmtype = new Alarmtype();

   Alarmtype updatealarmtype = new Alarmtype();

   updatealarmtype.setId( 1 );

   updatealarmtype.setAlarmname( "修改前轮故障" );

   alarmtypeMapper.updateAlarmtypeById(updatealarmtype);

   int result = 0 ;

   try {

    for ( int i = 0 ; i < 5 ; i++) {

     if (i== 2 ){

      //alarmname在数据库中长度不超过50,赋值超过50报异常 Data too long

      alarmtype.setAlarmname( "测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试测试" );

      alarmtype.setAlarmtypeid(i);

     } else {

      alarmtype.setAlarmname( "测试" +i);

      alarmtype.setAlarmtypeid(i);

     }

     result = alarmtypeMapper.addAlarmtype(alarmtype);

    }

   } catch (Exception e) {

    e.printStackTrace();

   }

   return result;

  }

  @RequestMapping ( "test" )

  @ResponseBody

  public synchronized String test(){ 

   return "test" ;

  }

}