3.2.5.1 本地事务（spring事务）

柔光的暖阳◎ 2022-01-27 01:39 146阅读 0赞

*  1 本文目标
 *  [2 练习场景][2]
 *  [3 操作步骤][3]
    
     *  [3.1 代码自动构建][3.1]
     *  [3.2 创建ExampleDemoList对象][3.2 _ExampleDemoList]
     *  [3.3 业务层开发][3.3]
        
         *  [3.3.1 只读事务][3.3.1]
         *  [3.3.2 事务异常控制][3.3.2]
         *  [3.3.3 批量数据提交][3.3.3]
     *  [3.4 Rest新增接口][3.4 Rest]
     *  [3.6 事务配置][3.6]
     *  [3.7 debug日志级别启动][3.7 debug]
     *  [3.7 swagger发起接口测试][3.7 swagger]
        
         *  [3.7.1 列表查询][3.7.1]
         *  [3.7.2 状态修改][3.7.2]
         *  [3.7.3 批量操作，数据都合法，全部入库][3.7.3]
         *  [3.7.4 批量操作，数据存在不合法，全部回滚][3.7.4]
 *  [4 扩展知识][4]
    
     *  [4.1 注解属性说明][4.1]
     *  [4.2 常见批量操作][4.2]
        
         *  [4.2.1 普通for循环插入][4.2.1 _for]
         *  [4.2.2 BATCH模式插入][4.2.2 BATCH]
         *  [4.2.3 foreach方式插入][4.2.3_foreach]

### 1 本文目标 ###

通过学习章节，将掌握基于Spring Transaction注解的事务开发，在开发原子级微服务时对查询类、提交类的事务控制、异常回滚；

文章最后，简单讲解常用的批量操作方式。

基于Spring Boot2.0.5 基础讲解；

### 2 练习场景 ###

实现客户状态的查询、单个修改、批量修改，单个修改支持异常回滚，批量操作支持批量提交和回滚；

前提

* 基于[3.2.1 微服务工程创建][3.2.1]章节，练习该场景
 * 模型设计
 * <table> 
 <tbody> 
 <tr> 
 <td> <code>-- Create table</code> <code>create</code> <code>table</code> <code>EXAMPLE_DEMO</code> <code>(</code> <code>&nbsp;&nbsp;</code><code>logic_seq&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; VARCHAR2(100) </code><code>not</code> <code>null</code><code>,</code> <code>&nbsp;&nbsp;</code><code>current_action VARCHAR2(100),</code> <code>&nbsp;&nbsp;</code><code>cust_id&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; VARCHAR2(32),</code> <code>&nbsp;&nbsp;</code><code>cust_name&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; VARCHAR2(32),</code> <code>&nbsp;&nbsp;</code><code>instance_id&nbsp;&nbsp;&nbsp; VARCHAR2(100),</code> <code>&nbsp;&nbsp;</code><code>node_id&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; VARCHAR2(32),</code> <code>&nbsp;&nbsp;</code><code>node_user&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; VARCHAR2(32),</code> <code>&nbsp;&nbsp;</code><code>ggg&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; NUMBER(16,3),</code> <code>&nbsp;&nbsp;</code><code>gg&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; NUMBER(2)</code> <code>);</code> <code>-- Add comments to the columns </code> <code>comment </code><code>on</code> <code>column</code> <code>EXAMPLE_DEMO.logic_seq&nbsp;&nbsp; </code><code>is</code> <code>'主键'</code><code>;</code> <code>comment </code><code>on</code> <code>column</code> <code>EXAMPLE_DEMO.current_action&nbsp; </code><code>is</code> <code>'资源码'</code><code>;</code> <code>comment </code><code>on</code> <code>column</code> <code>EXAMPLE_DEMO.cust_id&nbsp;&nbsp; </code><code>is</code> <code>'用户码'</code><code>;</code> <code>comment </code><code>on</code> <code>column</code> <code>EXAMPLE_DEMO.cust_name&nbsp;&nbsp; </code><code>is</code> <code>'用户名称'</code><code>;</code> <code>comment </code><code>on</code> <code>column</code> <code>EXAMPLE_DEMO.instance_id&nbsp;&nbsp; </code><code>is</code> <code>'实例码'</code><code>;</code> <code>comment </code><code>on</code> <code>column</code> <code>EXAMPLE_DEMO.node_id&nbsp;&nbsp; </code><code>is</code> <code>'节点码'</code><code>;</code> <code>comment </code><code>on</code> <code>column</code> <code>EXAMPLE_DEMO.node_user&nbsp;&nbsp; </code><code>is</code> <code>'节点名称'</code><code>;</code> <code>comment </code><code>on</code> <code>column</code> <code>EXAMPLE_DEMO.ggg&nbsp;&nbsp; </code><code>is</code> <code>'小数'</code><code>;</code> <code>comment </code><code>on</code> <code>column</code> <code>EXAMPLE_DEMO.gg&nbsp;&nbsp; </code><code>is</code> <code>'整数'</code><code>;</code> </td> 
 </tr> 
 </tbody> 
 </table>

### 3 操作步骤 ###

3.1 代码自动构建

完成表EXAMPLE\_DEMO数据库初始化后，通过代码自动构建，完成基础代码创建；

3.2 创建ExampleDemoList对象

<table> 
 <tbody> 
 <tr> 
 <td> <code>package</code> <code>cn.com.yusys.yusp.domain;</code> <code>import</code> <code>java.io.Serializable;</code> <code>import</code> <code>java.util.List;</code> <code>/**</code> <code>&nbsp;</code><code>* 样例表列表.</code> <code>&nbsp;</code><code>* </code> <code>&nbsp;</code><code>* @since 2.1.1</code> <code>&nbsp;</code><code>*</code> <code>&nbsp;</code><code>*/</code> <code>public</code> <code>class</code> <code>ExampleDemoList </code><code>implements</code> <code>Serializable{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code> <code>static</code> <code>final</code> <code>long</code> <code>serialVersionUID = 1L;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code> <code>List&lt;ExampleDemo&gt; exampleList;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>List&lt;ExampleDemo&gt; getExampleList() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>exampleList;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>setExampleList(List&lt;ExampleDemo&gt; exampleList) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>this</code><code>.exampleList = exampleList;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

3.3 业务层开发

@Transactional 方法方法名上，只对这个方法有作用，同样必须是public的方法，事务的传递性可以查看本章内4.1节；

3.3.1 只读事务

查询类业务操作，如果仅仅是Service中一个独立的查询，为了提高访问效率，提升数据库资源利用率，可以设置为只读事务；  
\* 但是需要注意，开启只读事务中，如果发起提交类操作，会产生异常。

<table> 
 <tbody> 
 <tr> 
 <td> <code>@Service</code> <code>public</code> <code>class</code> <code>ExampleDemoService </code><code>extends</code> <code>CommonService { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code> <code>static</code> <code>final</code> <code>Logger logger = LoggerFactory.getLogger(ExampleDemoService.</code><code>class</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Autowired</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code> <code>ExampleDemoMapper exampleDemoMapper;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Override</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>protected</code> <code>CommonMapper&lt;?&gt; getMapper() { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>exampleDemoMapper;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Autowired</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>private</code> <code>SqlSessionTemplate sqlSessionTemplate;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>/**</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>* 只读事务.</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>* &lt;p&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>* 查询类业务操作，如果仅仅是Service中一个独立的查询，为了提高访问效率，提升数据库资源利用率，可以设置为只读事务；</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>* 但是需要注意，开启只读事务中，如果发起提交类操作，会产生异常。</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>* @param model</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>* @return</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>*/</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>@Transactional</code><code>(readOnly = </code><code>true</code><code>)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>List&lt;ExampleDemo&gt; query(QueryModel model) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//设置分页信息</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>PageHelper.startPage(model.getPage(), model.getSize());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>List&lt;ExampleDemo&gt; exampleList = exampleDemoMapper.selectByModel(model);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>//线程变量清理</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>PageHelper.clearPage();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>exampleList;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

3.3.2 事务异常控制

rollbackFor 该属性用于设置需要进行回滚的异常类数组，当方法中抛出指定异常数组中的异常时，则进行事务回滚。如果不指定该参数，默认只针对RuntimeException回滚。

3.3.3 批量数据提交

Mybatis 的ExcutorType支持三种方式：

*  ExecutorType.SIMPLE  为每个语句创建一个PreparedStatement，默认模式   
 *  ExecutorType.REUSE   重复使用PreparedStatements
 *  ExecutorType.BATCH    重复使用PreparedStatements，并批量更新，期间不运行select操作

<table> 
 <tbody> 
 <tr> 
 <td> <code>@Transactional</code><code>(readOnly = </code><code>false</code><code>, rollbackFor = { Exception.</code><code>class</code><code>, RuntimeException.</code><code>class</code> <code>})</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>void</code> <code>batchUpdate(List&lt;ExampleDemo&gt; exampleDemoList) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 步骤1 获取线程批量session</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>SqlSession session = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH, </code><code>false</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 步骤2 获取mapper</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>ExampleDemoMapper exampleDemoMapper = session.getMapper(ExampleDemoMapper.</code><code>class</code><code>);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 注意，事务内不允许做查询操作，否则无法做事务回滚，因为查询操作会执行flushStatements</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>try</code> <code>{ </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>exampleDemoList.forEach(demo -&gt; { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>exampleDemoMapper.insert(demo);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>});</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code>&nbsp; <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>// 步骤3 推送更新</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>session.flushStatements();</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>} </code><code>catch</code> <code>(Exception e) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>logger.error(</code><code>"逻辑系统初始化失败，错误信息:{}"</code><code>, e.getMessage());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>throw</code> <code>e;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

3.4 Rest新增接口

<table> 
 <tbody> 
 <tr> 
 <td> <code>/**</code> <code>&nbsp;</code><code>* 列表查询</code> <code>&nbsp;</code><code>* @param model</code> <code>&nbsp;</code><code>* @return</code> <code>&nbsp;</code><code>*/</code> <code>@GetMapping</code><code>(value = </code><code>"/idex"</code><code>)</code> <code>public</code> <code>ResultDto&lt;List&lt;ExampleDemo&gt;&gt; query(QueryModel model) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>List&lt;ExampleDemo&gt; demoList = exampleDemoService.query(model);&nbsp;&nbsp;&nbsp; </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>new</code> <code>ResultDto&lt;List&lt;ExampleDemo&gt;&gt;(demoList);</code> <code>}</code> &nbsp; <code>/**</code> <code>&nbsp;</code><code>* 修改信息</code> <code>&nbsp;</code><code>* @param model</code> <code>&nbsp;</code><code>* @return</code> <code>&nbsp;</code><code>*/</code> <code>@SuppressWarnings</code><code>({ </code><code>"rawtypes"</code><code>})</code> <code>@PostMapping</code><code>(value = </code><code>"/updatestatus"</code><code>)</code> <code>public</code> <code>ResultDto updateExamplStatus(</code><code>@RequestBody</code> <code>ExampleDemo exampleDemo) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>exampleDemoService.updateStatus(exampleDemo); </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>new</code> <code>ResultDto();</code> <code>}</code> &nbsp; <code>/**</code> <code>&nbsp;</code><code>* 批量修改</code> <code>&nbsp;</code><code>* @param model</code> <code>&nbsp;</code><code>* @return</code> <code>&nbsp;</code><code>*/</code> <code>@SuppressWarnings</code><code>({ </code><code>"rawtypes"</code><code>})</code> <code>@PostMapping</code><code>(value = </code><code>"/batchupdate"</code><code>)</code> <code>public</code> <code>ResultDto batchUpdate(</code><code>@RequestBody</code> <code>ExampleDemoList exampleDemoList) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>exampleDemoService.batchUpdate(exampleDemoList.getExampleList());</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>return</code> <code>new</code> <code>ResultDto();</code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

3.6 事务配置

首先，在启动类增加注解 @EnableTransactionManagement 开启事务，同时增加MapperScan路径扫描配置：

<table> 
 <tbody> 
 <tr> 
 <td> <code>@SpringBootApplication</code><code>(scanBasePackages = </code><code>"cn.com.yusys.yusp"</code><code>, exclude = {SecurityAutoConfiguration.</code><code>class</code><code>, JasyptSpringBootAutoConfiguration.</code><code>class</code><code>})</code> <code>@MapperScan</code><code>(</code><code>"cn.com.yusys.yusp.**.repository.mapper"</code><code>)</code> <code>@EnableTransactionManagement</code> <code>public</code> <code>class</code> <code>ExampleApp { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>public</code> <code>static</code> <code>void</code> <code>main(String[] args) { </code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>SpringApplication.run(ExampleApp.</code><code>class</code><code>, args);</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>}&nbsp;&nbsp; </code> <code>}</code> </td> 
 </tr> 
 </tbody> 
</table>

3.7 debug日志级别启动

开启debug日志，可以查看后台SQL的执行详情

方式一

应用开发--服务启动--CustmngMicroserviceApp--右键–调试方式–调试配置

在自变量输入：–logging.level.root=debug

![image2019-3-21_2019_3A59_3A24.png_version_1_modificationDate_1553169473000_api_v2][]

启动方式二

直接修改bootstrap.yml配置

![image2019-3-21_2020_3A0_3A58.png_version_1_modificationDate_1553169567000_api_v2][]

3.7 swagger发起接口测试

为数据表创建10条左右的测试数据。

3.7.1 列表查询

![image2019-3-21_2019_3A56_3A39.png_version_1_modificationDate_1553169308000_api_v2][]

查询结果

![image2019-3-21_2020_3A4_3A21.png_version_1_modificationDate_1553169771000_api_v2][]

3.7.2 状态修改

![image2019-3-21_2020_3A9_3A50.png_version_1_modificationDate_1553170100000_api_v2][]

后台SQL执行日志

3.7.3 批量操作，数据都合法，全部入库

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;"><img alt="" height="16" src="http://192.168.251.162:8090/images/icons/emoticons/information.png" width="16"></td> 
 <td> { "exampleList": [ { "logicSeq": "f1", "currentAction": "S", "custId": "f", "custName": "f", "instanceId": "f", "nodeId": "f", "nodeUser": "f", "ggg": "0", "gg": 0 }, { "logicSeq": "f2", "currentAction": "S", "custId": "f", "custName": "f", "instanceId": "f", "nodeId": "f", "nodeUser": "f", "ggg": "0", "gg": 0 } ] } </td> 
 </tr> 
 </tbody> 
</table>

![image2019-3-21_2020_3A24_3A50.png_version_1_modificationDate_1553170999000_api_v2][]

![image2019-3-21_2020_3A25_3A35.png_version_1_modificationDate_1553171045000_api_v2][]

后台SQl执行,成功提供

![image2019-3-21_2020_3A35_3A59.png_version_1_modificationDate_1553171669000_api_v2][]

3.7.4 批量操作，数据存在不合法，全部回滚

继续使用3.7.3的报文，修改logicSeq 第二个节点f2 为f3，但第一个节点logicSeq还是保持f1

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;"><img alt="" height="16" src="http://192.168.251.162:8090/images/icons/emoticons/information.png" width="16"></td> 
 <td> { "exampleList": [ { "logicSeq": "f1", "currentAction": "S", "custId": "f", "custName": "f", "instanceId": "f", "nodeId": "f", "nodeUser": "f", "ggg": "0", "gg": 0 }, { "logicSeq": "f3", "currentAction": "S", "custId": "f", "custName": "f", "instanceId": "f", "nodeId": "f", "nodeUser": "f", "ggg": "0", "gg": 0 } ] } </td> 
 </tr> 
 </tbody> 
</table>

系统报错500，

![image2019-3-21_2020_3A29_3A16.png_version_1_modificationDate_1553171266000_api_v2][]

数据未成功入库

![image2019-3-21_2020_3A29_3A47.png_version_1_modificationDate_1553171297000_api_v2][]

后台日志，第一条成功，第二条失败，全部回滚

![image2019-3-21_2020_3A33_3A34.png_version_1_modificationDate_1553171523000_api_v2][]

### 4 扩展知识 ###

4.1 注解属性说明

<table> 
 <thead> 
 <tr> 
 <th> 属性 </th> 
 <th> 类型 </th> 
 <th> 描述 </th> 
 </tr> 
 </thead> 
 <tbody> 
 <tr> 
 <td>value</td> 
 <td>String</td> 
 <td>可选的限定描述符，指定使用的事务管理器</td> 
 </tr> 
 <tr> 
 <td>propagation</td> 
 <td>enum: Propagation</td> 
 <td>可选的事务传播行为设置</td> 
 </tr> 
 <tr> 
 <td>isolation</td> 
 <td>enum: Isolation</td> 
 <td>可选的事务隔离级别设置</td> 
 </tr> 
 <tr> 
 <td>readOnly</td> 
 <td>boolean</td> 
 <td>读写或只读事务，默认读写</td> 
 </tr> 
 <tr> 
 <td>timeout</td> 
 <td>int (in seconds granularity)</td> 
 <td>事务超时时间设置</td> 
 </tr> 
 <tr> 
 <td>rollbackFor</td> 
 <td>Class对象数组，必须继承自Throwable</td> 
 <td>导致事务回滚的异常类数组</td> 
 </tr> 
 <tr> 
 <td>rollbackForClassName</td> 
 <td>类名数组，必须继承自Throwable</td> 
 <td>导致事务回滚的异常类名字数组</td> 
 </tr> 
 <tr> 
 <td>noRollbackFor</td> 
 <td>Class对象数组，必须继承自Throwable</td> 
 <td>不会导致事务回滚的异常类数组</td> 
 </tr> 
 <tr> 
 <td>noRollbackForClassName</td> 
 <td>类名数组，必须继承自Throwable</td> 
 <td>不会导致事务回滚的异常类名字数组</td> 
 </tr> 
 </tbody> 
</table>

propagation 事务的传播行为，默认值为 Propagation.REQUIRED。

*  Propagation.REQUIRED 如果当前存在事务，则加入该事务，如果当前不存在事务，则创建一个新的事务。
 *  Propagation.SUPPORTS 如果当前存在事务，则加入该事务；如果当前不存在事务，则以非事务的方式继续运行。
 *  Propagation.MANDATORY 如果当前存在事务，则加入该事务；如果当前不存在事务，则抛出异常。
 *  Propagation.REQUIRES\_NEW 重新创建一个新的事务，如果当前存在事务，暂停当前的事务。
 *  Propagation.NOT\_SUPPORTED 以非事务的方式运行，如果当前存在事务，暂停当前的事务。
 *  Propagation.NEVER 以非事务的方式运行，如果当前存在事务，则抛出异常。
 *  Propagation.NESTED 和 Propagation.REQUIRED 效果一样。

isolation 属性事务的隔离级别，默认值为 Isolation.DEFAULT。

*  Isolation.DEFAULT                        使用底层数据库的默认隔离级别
 *  Isolation.READ\_UNCOMMITTED 该隔离级别表示一个事务可以读取另一个事务修改但还没有提交的数据。该级别不能防止脏读，不可重复读和幻读，因此很少使用该隔离级别
 *  Isolation.READ\_COMMITTED      该隔离级别表示一个事务只能读取另一个事务已经提交的数据
 *  Isolation.REPEATABLE\_READ     该隔离级别表示一个事务在整个过程中可以多次重复执行某个查询，并且每次返回的记录都相同
 *  Isolation.SERIALIZABLE               所有的事务依次逐个执行，这样事务之间就完全不可能产生干扰，也就是说，该级别可以防止脏读、不可重复读以及幻读

4.2 常见批量操作

4.2.1 普通for循环插入

少量数据，100内，推荐使用

4.2.2 BATCH模式插入

本文 3.3.3节

4.2.3 foreach方式插入

<table> 
 <tbody> 
 <tr> 
 <td> <code>&lt;</code><code>insert</code> <code>id</code><code>=</code><code>"insertBatch"</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>INSERT INTO EXAMPLE_DEMO</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>(LOGIC_SEQ, CURRENT_ACTION, CUST_ID, CUST_NAME)</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>VALUES</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;</code><code>foreach</code> <code>collection</code><code>=</code><code>"list"</code> <code>item</code><code>=</code><code>"demo"</code> <code>separator</code><code>=</code><code>","</code><code>&gt;</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>(#{demo.logicSeq}, #{demo.currentAction}, #{demo.custId},</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;</code><code>#{demo.custName})</code> <code>&nbsp;&nbsp;&nbsp;&nbsp;</code><code>&lt;/</code><code>foreach</code><code>&gt;</code> <code>&lt;/</code><code>insert</code><code>&gt;</code> </td> 
 </tr> 
 </tbody> 
</table>

[2]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-2%E7%BB%83%E4%B9%A0%E5%9C%BA%E6%99%AF
[3]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3%E6%93%8D%E4%BD%9C%E6%AD%A5%E9%AA%A4
[3.1]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.1%E4%BB%A3%E7%A0%81%E8%87%AA%E5%8A%A8%E6%9E%84%E5%BB%BA
[3.2 _ExampleDemoList]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.2%E5%88%9B%E5%BB%BAExampleDemoList%E5%AF%B9%E8%B1%A1
[3.3]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.3%E4%B8%9A%E5%8A%A1%E5%B1%82%E5%BC%80%E5%8F%91
[3.3.1]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.3.1%E5%8F%AA%E8%AF%BB%E4%BA%8B%E5%8A%A1
[3.3.2]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.3.2%E4%BA%8B%E5%8A%A1%E5%BC%82%E5%B8%B8%E6%8E%A7%E5%88%B6
[3.3.3]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.3.3%E6%89%B9%E9%87%8F%E6%95%B0%E6%8D%AE%E6%8F%90%E4%BA%A4
[3.4 Rest]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.4Rest%E6%96%B0%E5%A2%9E%E6%8E%A5%E5%8F%A3
[3.6]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.6%E4%BA%8B%E5%8A%A1%E9%85%8D%E7%BD%AE
[3.7 debug]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.7debug%E6%97%A5%E5%BF%97%E7%BA%A7%E5%88%AB%E5%90%AF%E5%8A%A8
[3.7 swagger]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.7swagger%E5%8F%91%E8%B5%B7%E6%8E%A5%E5%8F%A3%E6%B5%8B%E8%AF%95
[3.7.1]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.7.1%E5%88%97%E8%A1%A8%E6%9F%A5%E8%AF%A2
[3.7.2]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.7.2%E7%8A%B6%E6%80%81%E4%BF%AE%E6%94%B9
[3.7.3]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.7.3%E6%89%B9%E9%87%8F%E6%93%8D%E4%BD%9C%EF%BC%8C%E6%95%B0%E6%8D%AE%E9%83%BD%E5%90%88%E6%B3%95%EF%BC%8C%E5%85%A8%E9%83%A8%E5%85%A5%E5%BA%93
[3.7.4]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-3.7.4%E6%89%B9%E9%87%8F%E6%93%8D%E4%BD%9C%EF%BC%8C%E6%95%B0%E6%8D%AE%E5%AD%98%E5%9C%A8%E4%B8%8D%E5%90%88%E6%B3%95%EF%BC%8C%E5%85%A8%E9%83%A8%E5%9B%9E%E6%BB%9A
[4]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-4%E6%89%A9%E5%B1%95%E7%9F%A5%E8%AF%86
[4.1]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-4.1%E6%B3%A8%E8%A7%A3%E5%B1%9E%E6%80%A7%E8%AF%B4%E6%98%8E
[4.2]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-4.2%E5%B8%B8%E8%A7%81%E6%89%B9%E9%87%8F%E6%93%8D%E4%BD%9C
[4.2.1 _for]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-4.2.1%E6%99%AE%E9%80%9Afor%E5%BE%AA%E7%8E%AF%E6%8F%92%E5%85%A5
[4.2.2 BATCH]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-4.2.2BATCH%E6%A8%A1%E5%BC%8F%E6%8F%92%E5%85%A5
[4.2.3_foreach]: http://192.168.251.162:8090/pages/viewpage.action?pageId=5014733#id-3.2.5.1%E6%9C%AC%E5%9C%B0%E4%BA%8B%E5%8A%A1-4.2.3foreach%E6%96%B9%E5%BC%8F%E6%8F%92%E5%85%A5
[3.2.1]: http://192.168.251.151:8090/pages/viewpage.action?pageId=5014723
[image2019-3-21_2019_3A59_3A24.png_version_1_modificationDate_1553169473000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2019%3A59%3A24.png?version=1&modificationDate=1553169473000&api=v2
[image2019-3-21_2020_3A0_3A58.png_version_1_modificationDate_1553169567000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2020%3A0%3A58.png?version=1&modificationDate=1553169567000&api=v2
[image2019-3-21_2019_3A56_3A39.png_version_1_modificationDate_1553169308000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2019%3A56%3A39.png?version=1&modificationDate=1553169308000&api=v2
[image2019-3-21_2020_3A4_3A21.png_version_1_modificationDate_1553169771000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2020%3A4%3A21.png?version=1&modificationDate=1553169771000&api=v2
[image2019-3-21_2020_3A9_3A50.png_version_1_modificationDate_1553170100000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2020%3A9%3A50.png?version=1&modificationDate=1553170100000&api=v2
[image2019-3-21_2020_3A24_3A50.png_version_1_modificationDate_1553170999000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2020%3A24%3A50.png?version=1&modificationDate=1553170999000&api=v2
[image2019-3-21_2020_3A25_3A35.png_version_1_modificationDate_1553171045000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2020%3A25%3A35.png?version=1&modificationDate=1553171045000&api=v2
[image2019-3-21_2020_3A35_3A59.png_version_1_modificationDate_1553171669000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2020%3A35%3A59.png?version=1&modificationDate=1553171669000&api=v2
[image2019-3-21_2020_3A29_3A16.png_version_1_modificationDate_1553171266000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2020%3A29%3A16.png?version=1&modificationDate=1553171266000&api=v2
[image2019-3-21_2020_3A29_3A47.png_version_1_modificationDate_1553171297000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2020%3A29%3A47.png?version=1&modificationDate=1553171297000&api=v2
[image2019-3-21_2020_3A33_3A34.png_version_1_modificationDate_1553171523000_api_v2]: http://192.168.251.162:8090/download/attachments/5014733/image2019-3-21%2020%3A33%3A34.png?version=1&modificationDate=1553171523000&api=v2