###前提・実現したいこと
mybatis-springを利用して複数DBへの更新処理を試みています。
現在、トランザクションを意識せずにinsert,update等のSQLは処理出来ています。
###発生している問題・エラーメッセージ
トランザクション制御をかけるため、@Transactionalを使用して実装したのですが
どうやらトランザクションが想定通りに動作していません。
特定のメソッドに@Transactionalを付与しているので、そのメソッドで例外が発生した場合、
ロールバックされる想定でしたが、例外発生するまでの更新処理はコミットされています。
###該当のソースコード
applicationContext.xml
<tx:annotation-driven /> <!-- Properties file load --> <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <list> <value>classpath:dbsetting.properties</value> </list> </property> </bean> <!-- ================== oracle ===================--> <bean id="oracleDataSource" class="org.apache.commons.dbcp2.BasicDataSource" p:driverClassName="${oracle.jdbc.driver}" p:url="${oracle.jdbc.url}" p:username="${oracle.jdbc.username}" p:password="${oracle.jdbc.password}" p:defaultAutoCommit="false" /> <!-- Transaction Manager --> <bean id="oracleTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager" p:dataSource-ref="oracleDataSource" p:rollbackOnCommitFailure="true" /> <!-- MyBatis3.x-Spring --> <!--SqlSessionFactory Injection --> <bean id="oracleSqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean" p:dataSource-ref="oracleDataSource"> <property name="configuration"> <bean class="org.apache.ibatis.session.Configuration" p:localCacheScope="STATEMENT" p:mapUnderscoreToCamelCase="true" p:lazyLoadingEnabled="true" p:aggressiveLazyLoading="false" p:defaultFetchSize="1000" p:defaultExecutorType="REUSE" /> </property> <property name="mapperLocations" value="classpath*:dao/oracle/*.xml" /> </bean> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="basePackage" value="xxx.dao.oracle" /> <property name="sqlSessionFactoryBeanName" value="oracleSqlSessionFactory" /> </bean> <!-- ================== postgres ===================--> <bean id="postgresDataSource" class="org.apache.commons.dbcp2.BasicDataSource" p:driverClassName="${postgres.jdbc.driver}" p:url="${postgres.jdbc.url}" p:username="${postgres.jdbc.username}" p:password="${postgres.jdbc.password}" p:defaultAutoCommit="false" /> <!-- Transaction Manager --> <bean id="postgresTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager" p:dataSource-ref="postgresDataSource" p:rollbackOnCommitFailure="true" /> <!-- MyBatis3.x-Spring --> <!--SqlSessionFactory Injection --> <bean id="postgresSqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean" p:dataSource-ref="postgresDataSource"> <property name="configuration"> <bean class="org.apache.ibatis.session.Configuration" p:localCacheScope="STATEMENT" p:mapUnderscoreToCamelCase="true" p:lazyLoadingEnabled="true" p:aggressiveLazyLoading="false" p:defaultFetchSize="1000" p:defaultExecutorType="REUSE" /> </property> <property name="mapperLocations" value="classpath*:dao/postgres/*.xml" /> </bean> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <property name="basePackage" value="xxx.dao.postgres" /> <property name="sqlSessionFactoryBeanName" value="postgresSqlSessionFactory" /> </bean>
SampleImpl.java
JAVA
1@Component 2public class SampleImpl implements Sample{ 3 4 @Autowired 5 SampleModel model; 6 7 @Override 8 @Transactional(value="postgresTransactionManager") 9 public void insert(Entity entity) { 10 11 model.insert(entity); 12 model.insert(entity); //一意制約エラーを起こす 13 } 14} 15
SampleModelImpl.java
JAVA
1@Component 2public class SampleModelImpl implements SampleModel { 3 4 @Autowired 5 private UserMapper mapper; 6 7 @Override 8 public void insert(Entity entity) { 9 mapper.insert(entity); 10 } 11} 12
###最後に
@Transactionalの使い方がよくないのでしょうか?
誤っている点などがありましたら、ご指摘ください。
どうぞよろしくお願い致します。
回答2件
あなたの回答
tips
プレビュー
バッドをするには、ログインかつ
こちらの条件を満たす必要があります。