Spring3.X 分布式事务

男娘i 2022-03-08 05:28 79阅读 0赞

<table> 
 <tbody> 
 <tr> 
 <td style="vertical-align:top;">1.为什么要组建多数据源? &nbsp; &nbsp;一个系统中存在多个数据库读写操作,如Oralce+MySql......等 2.为什么要组建分布式事务? &nbsp; &nbsp;在同一个系统,同一个事务中对不同数据库进行写操作时,如若一个失败,那么应该对多个数据库进行回滚操作,否则应该全部提交. 3.分布式事务有哪些? &nbsp; &nbsp;在Spring 2.5中可以采用jta,在Spring3.X中则已经不对其提供支持,但可以使用atomikos. 4.需要提供哪些jar包支持? &nbsp; 6个必须的jar包,可以通过maven下载&nbsp; atomikos-util-3.9.3.jar&nbsp; jta-1.1.jar transactions-3.9.3.jar transactions-api-3.9.3.jar&nbsp; transactions-jdbc-3.9.3.jar&nbsp; transactions-jta-3.9.3.jar 5.Spring 配置如何配置? &lt;?xml version="1.0" encoding= "UTF-8"?&gt; &lt;beans xmlns= "<a href="http://www.springframework.org/schema/beans" rel="nofollow">http://www.springframework.org/schema/beans</a>" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;xmlns:xsi="<a href="http://www.w3.org/2001/XMLSchema-instance" rel="nofollow">http://www.w3.org/2001/XMLSchema-instance</a>" xmlns:aop= "<a href="http://www.springframework.org/schema/aop" rel="nofollow">http://www.springframework.org/schema/aop</a>" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;xmlns:tx="<a href="http://www.springframework.org/schema/tx" rel="nofollow">http://www.springframework.org/schema/tx</a>" xmlns:context="<a href="http://www.springframework.org/schema/context" rel="nofollow">http://www.springframework.org/schema/context</a>" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;xmlns:mvc="<a href="http://www.springframework.org/schema/mvc" rel="nofollow">http://www.springframework.org/schema/mvc</a>" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;xsi:schemaLocation=" &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <a href="http://www.springframework.org/schema/beans" rel="nofollow">http://www.springframework.org/schema/beans</a> <a href="http://www.springframework.org/schema/beans" rel="nofollow">http://www.springframework.org/schema/beans</a>/spring-beans-3.2.xsd &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <a href="http://www.springframework.org/schema/aop" rel="nofollow">http://www.springframework.org/schema/aop</a> <a href="http://www.springframework.org/schema/aop" rel="nofollow">http://www.springframework.org/schema/aop</a>/spring-aop-3.2.xsd &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <a href="http://www.springframework.org/schema/tx" rel="nofollow">http://www.springframework.org/schema/tx</a> <a href="http://www.springframework.org/schema/tx" rel="nofollow">http://www.springframework.org/schema/tx</a>/spring-tx-3.2.xsd &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <a href="http://www.springframework.org/schema/context" rel="nofollow">http://www.springframework.org/schema/context</a> <a href="http://www.springframework.org/schema/context" rel="nofollow">http://www.springframework.org/schema/context</a>/spring-context-3.2.xsd &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <a href="http://www.springframework.org/schema/mvc" rel="nofollow">http://www.springframework.org/schema/mvc</a> &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; <a href="http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd" rel="nofollow">http://www.springframework.org/schema/mvc/spring-mvc-3.2.xsd</a>"&gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;context:annotation-config /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;context:component-scan base-package ="com.cn" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- oracle数据源定义&nbsp; --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean id ="oracleDS" class= "com.atomikos.jdbc.AtomikosDataSourceBean" init-method= "init" destroy-method ="close"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;description &gt;oracle xa datasource &lt;/description &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="uniqueResourceName"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;value &gt;oracle_ds &lt;/value &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="xaDataSourceClassName"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;value&gt; oracle.jdbc.xa.client.OracleXADataSource&lt;/value &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="xaProperties"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;props &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop key ="user"&gt;dongruan&lt;/ prop&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop key ="password"&gt;dongruan&lt;/ prop&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop key= "URL"&gt;jdbc:oracle:thin:@100.100.100.30:1521: orcl&lt;/ prop&gt; &lt;!-- 注意这个URL是大写 --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/props &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="testQuery"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;value &gt;select 1 from dual &lt;/value &gt; &lt;!-- 尽量加上，不然会出现告警 --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp; &lt;/bean &gt; &nbsp; &nbsp;&nbsp;&nbsp; &lt;!-- mysql数据源定义&nbsp; --&gt; &nbsp;&nbsp;&nbsp; &lt;bean id ="mysqlDS" class= "com.atomikos.jdbc.AtomikosDataSourceBean" init-method= "init" destroy-method ="close"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;description &gt;mysql xa datasource&lt;/ description&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="uniqueResourceName"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;value &gt;mysql_ds &lt;/value &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="xaDataSourceClassName"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;value&gt; com.mysql.jdbc.jdbc2.optional.MysqlXADataSource&lt;/value &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="xaProperties"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;props &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop key ="user"&gt;datapre&lt;/ prop&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop key ="password"&gt;flow2012&lt;/ prop&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop key= "URL"&gt;jdbc:mysql://100.100.100.48:3306/ dataprepare&lt;/ prop&gt; &lt;!-- 注意这个URL是大写 --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/props &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="testQuery"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;value &gt;select 1 &lt;/value &gt;&lt;!-- 尽量加上，不然会出现告警 --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp; &lt;/bean &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- oracle SqlSessionFactoryBean 和 MapperScanner配置 --&gt; &nbsp;&nbsp;&nbsp; &lt;bean id ="oracleSqlSession" class= "org.mybatis.spring.SqlSessionFactoryBean" &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="dataSource" ref="oracleDS" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="mapperLocations" value= "classpath:com/cn/oraclemapper/*Mapper.xml" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="typeAliasesPackage" value= "com.cn.oraclepo" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/bean &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean id ="oracleMapperScanner" class= "org.mybatis.spring.mapper.MapperScannerConfigurer" &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="sqlSessionFactoryBeanName" value= "oracleSqlSession" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="basePackage" value= "com.cn.oraclemapper" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/bean &gt; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- mysql SqlSessionFactoryBean 和 MapperScanner配置 --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean id ="mysqlSqlSessionFactory" class= "org.mybatis.spring.SqlSessionFactoryBean" &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="dataSource" ref="mysqlDS" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="mapperLocations" value= "classpath:com/cn/mapper/*Mapper.xml" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="typeAliasesPackage" value= "com.cn.po" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/bean &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean id ="mysqlMapperScanner" class= "org.mybatis.spring.mapper.MapperScannerConfigurer" &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="sqlSessionFactoryBeanName" value= "mysqlSqlSessionFactory" &gt;&lt;/ property&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="basePackage" value="com.cn.mapper" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/bean &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;!-- atomikos事物管理器 --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean id ="atomikosUserTransaction" class= "com.atomikos.icatch.jta.UserTransactionImp" &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;description &gt;UserTransactionImp &lt;/description &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="transactionTimeout" value= "300" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/bean &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean id ="atomikosTransactionManager" class= "com.atomikos.icatch.jta.UserTransactionManager" init-method= "init" destroy-method ="close"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;description &gt;UserTransactionManager &lt;/description &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="forceShutdown"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;value &gt;true &lt;/value &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/bean &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean id ="springTransactionManager" class= "org.springframework.transaction.jta.JtaTransactionManager" &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;description &gt;JtaTransactionManager &lt;/description &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="transactionManager"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;ref bean ="atomikosTransactionManager" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="userTransaction"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;ref bean ="atomikosUserTransaction" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="allowCustomIsolationLevels" value= "true" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;!-- 必须设置，否则程序出现异常 JtaTransactionManager does not support custom isolation levels by default --&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;/bean &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&lt;bean id ="atomikosTransactionProxy" class= "org.springframework.transaction.interceptor.TransactionProxyFactoryBean" abstract ="true"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="transactionManager"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;ref bean ="springTransactionManager" /&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;property name ="transactionAttributes"&gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;props &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;prop key= "*"&gt;PROPAGATION_REQUIRED,-Exception &lt;/prop &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/props &gt; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &lt;/property &gt; &nbsp;&nbsp;&nbsp;&nbsp; &lt;/bean &gt; &nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp; &lt;!-- 使用spring事务 --&gt; &nbsp;&nbsp;&nbsp;&nbsp; &lt;tx:annotation-driven transaction-manager="springTransactionManager" /&gt; &lt;/beans&gt;&nbsp; 6.测试代码如下: package com.cn.main; import java.io.UnsupportedEncodingException; import org.springframework.context.support.ClassPathXmlApplicationContext; import com.cn.testService; &nbsp; public class main { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;public static void main(String[] args) throws UnsupportedEncodingException { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext("DataSource.xml" ); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; testService service = context.getBean(testService.class ); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; service.test(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} } 7.Service类: package com.cn; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.transaction.annotation.Transactional; import com.cn.mapper.SendPreMapper; import com.cn.oraclemapper.AirwayPointFlowMapper; import com.cn.oraclepo.AirwayPointFlow; import com.cn.po.SendPreWithBLOBs; @Service public class testService { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;@Autowired &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;public SendPreMapper mysqlMapper; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;@Autowired &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;public AirwayPointFlowMapper oracleMapper; &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;@Transactional &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;public void test() { &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;SendPreWithBLOBs pre = new SendPreWithBLOBs(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;pre.setId(123457); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; mysqlMapper.insert(pre); &nbsp; &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;AirwayPointFlow air = new AirwayPointFlow(); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;air.setId( "11111111112"); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp; oracleMapper.insert(air); &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;} } </td> 
 </tr> 
 </tbody> 
</table>