问题描述
|
我在使用mybatis的CMT Spring事务时遇到问题，我有一个使用2 Mapperfactorybean插入记录的类。
当插入记录时得到FOREIGN KEY约束异常；似乎两者都在不同的会话中运行，第二个会话找不到新插入的ID。
在第二条记录的外键中传递null时；不会引发异常，但不会提交事务。
如果引发任何异常，则回滚工作正常。
这是我的配置
<tx:jta-transaction-manager />
<bean id=\"dataSource\" class=\"org.apache.commons.dbcp.BasicDataSource\" destroy-method=\"close\">
<property name=\"url\" value=\"${database.url}\"/>
<property name=\"driverClassName\" value=\"${database.driverClassName}\"/>
<property name=\"username\" value=\"${database.username}\"/>
<property name=\"password\" value=\"${database.password}\"/>
<property name=\"defaultAutoCommit\" value=\"false\" />
</bean>
<bean id=\"transactionManager\" class=\"org.springframework.jdbc.datasource.DataSourceTransactionManager\">
<property name=\"dataSource\" ref=\"dataSource\"/>
<property name=\"nestedTransactionAllowed\" value=\"true\" />
<property name=\"validateExistingTransaction\" value=\"true\" />
</bean>
<bean id=\"sqlSessionFactory\" class=\"org.mybatis.spring.sqlSessionfactorybean\">
<property name=\"dataSource\" ref=\"dataSource\" />
<property name=\"configLocation\" value=\"classpath:dataAccess-config.xml\"/>
</bean>
<bean id=\"taskRecordMapper\" class=\"org.mybatis.spring.Mapperfactorybean\">
<property name=\"sqlSessionFactory\" ref=\"sqlSessionFactory\" />
<property name=\"mapperInterface\" value=\"TaskRecordMapper\"/>
</bean>
<bean id=\"taskTagRecordMapper\" class=\"org.mybatis.spring.Mapperfactorybean\">
<property name=\"sqlSessionFactory\" ref=\"sqlSessionFactory\" />
<property name=\"mapperInterface\" value=\"TaskTagRecordMapper\"/>
</bean>
@Transactional(propagation= Propagation.required)
public boolean assignTask(Object source,TaskType taskType,String description,long assignedTo,long createdBy,long escalationId,boolean isAssignedToGroup,long parentTaskId,Date deadline,TaskPriority taskPriority) throws Exception
{
EntityType entityType = TaskUtil.getEntityType(source);
long entityId = TaskUtil.getIdFromObject(source);
TaskRecord newTask = new TaskRecord();
newTask.setAssignedTo((isAssignedToGroup) ? null : assignedTo);
newTask.setCategory(entityType.toString());
newTask.setCreatedBy(createdBy);
newTask.setCreatedOn(new Date());
newTask.setDeadline(deadline);
newTask.setDescription(description);
newTask.setEntityId(entityId);
newTask.setEscalationId(escalationId);
newTask.setIsAssignedToGroup(isAssignedToGroup);
newTask.setIsDeleted(false);
newTask.setModifiedBy(null);
newTask.setModifiedOn(null);
newTask.setowner(createdBy);
newTask.setParentId((parentTaskId == 0) ? null : parentTaskId);
newTask.setPriority(taskPriority.toString());
newTask.setReferenceNo(null);
newTask.setResult(null);
newTask.setStatus(TaskStatus.InProgress.toString());
newTask.setType(taskType.toString());
boolean rValue = taskRecordMapper.insert(newTask) > 0;
if(rValue && isAssignedToGroup)
{
TaskTagRecord tag = new TaskTagRecord();
tag.setTaskId(newTask.getId());
tag.setName(\"RoleId\");
tag.setValue(String.valueOf(assignedTo));
rValue = taskTagRecordMapper.insert(tag) > 0;
}
return rValue;
}
org.springframework.dao.DataIntegrityViolationException: sqlSession operation; sql []; The INSERT statement conflicted with the FOREIGN KEY constraint \"FK_task_tag_task\". The conflict occurred in database \"TEMP\",table \"dbo.task\",column \'id\'.; nested exception is com.microsoft.sqlserver.jdbc.sqlServerException: The INSERT statement conflicted with the FOREIGN KEY constraint \"FK_task_tag_task\". The conflict occurred in database \"TEMP\",column \'id\'.
at org.springframework.jdbc.support.sqlStatesqlExceptionTranslator.doTranslate(sqlStatesqlExceptionTranslator.java:101)
at org.springframework.jdbc.support.AbstractFallbacksqlExceptionTranslator.translate(AbstractFallbacksqlExceptionTranslator.java:72)
at org.springframework.jdbc.support.AbstractFallbacksqlExceptionTranslator.translate(AbstractFallbacksqlExceptionTranslator.java:80)
at org.springframework.jdbc.support.AbstractFallbacksqlExceptionTranslator.translate(AbstractFallbacksqlExceptionTranslator.java:80)
at org.mybatis.spring.sqlSessionTemplate.wrapException(sqlSessionTemplate.java:364)
at org.mybatis.spring.sqlSessionTemplate$7$1.doInsqlSession(sqlSessionTemplate.java:344)
at org.mybatis.spring.sqlSessionTemplate.execute(sqlSessionTemplate.java:173)
at org.mybatis.spring.sqlSessionTemplate.execute(sqlSessionTemplate.java:155)
at org.mybatis.spring.sqlSessionTemplate$7.invoke(sqlSessionTemplate.java:339)
at $Proxy18.insert(UnkNown Source)
at com.task.service.TaskService.assignTask(TaskService.java:184)
at com.task.service.TaskService.assignTask(TaskService.java:137)
at com.core.mapper.TaskServiceTest.main(TaskServiceTest.java:38)
Caused by: com.microsoft.sqlserver.jdbc.sqlServerException: The INSERT statement conflicted with the FOREIGN KEY constraint \"FK_task_tag_task\". The conflict occurred in database \"TEMP\",table \"dbo._task\",column \'id\'.
at com.microsoft.sqlserver.jdbc.sqlServerException.makeFromDatabaseError(sqlServerException.java:196)
at com.microsoft.sqlserver.jdbc.sqlServerStatement.getNextResult(sqlServerStatement.java:1454)
at com.microsoft.sqlserver.jdbc.sqlServerPreparedStatement.doExecutePreparedStatement(sqlServerPreparedStatement.java:388)
at com.microsoft.sqlserver.jdbc.sqlServerPreparedStatement$PrepStmtExecCmd.doExecute(sqlServerPreparedStatement.java:338)
at com.microsoft.sqlserver.jdbc.TDSCommand.execute(IOBuffer.java:4026)
at com.microsoft.sqlserver.jdbc.sqlServerConnection.executeCommand(sqlServerConnection.java:1416)
at com.microsoft.sqlserver.jdbc.sqlServerStatement.executeCommand(sqlServerStatement.java:185)
at com.microsoft.sqlserver.jdbc.sqlServerStatement.executeStatement(sqlServerStatement.java:160)
at com.microsoft.sqlserver.jdbc.sqlServerPreparedStatement.execute(sqlServerPreparedStatement.java:320)
at org.apache.commons.dbcp.DelegatingPreparedStatement.execute(DelegatingPreparedStatement.java:169)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.apache.ibatis.logging.jdbc.PreparedStatementLogger.invoke(PreparedStatementLogger.java:45)
at $Proxy38.execute(UnkNown Source)
at org.apache.ibatis.executor.statement.PreparedStatementHandler.update(PreparedStatementHandler.java:22)
at org.apache.ibatis.executor.statement.RoutingStatementHandler.update(RoutingStatementHandler.java:51)
at org.apache.ibatis.executor.SimpleExecutor.doUpdate(SimpleExecutor.java:29)
at org.apache.ibatis.executor.BaseExecutor.update(BaseExecutor.java:75)
at org.apache.ibatis.executor.CachingExecutor.update(CachingExecutor.java:43)
at org.apache.ibatis.session.defaults.DefaultsqlSession.update(DefaultsqlSession.java:118)
at org.apache.ibatis.session.defaults.DefaultsqlSession.insert(DefaultsqlSession.java:107)
at org.apache.ibatis.binding.MapperMethod.execute(MapperMethod.java:56)
at org.apache.ibatis.binding.MapperProxy.invoke(MapperProxy.java:38)
at $Proxy18.insert(UnkNown Source)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
at java.lang.reflect.Method.invoke(Method.java:597)
at org.mybatis.spring.sqlSessionTemplate$7$1.doInsqlSession(sqlSessionTemplate.java:342)
... 7 more
02:41:32,465 INFO main [ClasspathXmlApplicationContext] Refreshing org.springframework.context.support.ClasspathXmlApplicationContext@1bc887b: startup date [Thu May 26 02:41:32 GST 2011]; root of context hierarchy
02:41:32,512 INFO main [XmlBeanDeFinitionReader] Loading XML bean deFinitions from class path resource [dataAccessApplicationContext.xml]
02:41:33,034 INFO main [DefaultListablebeanfactory] Pre-instantiating singletons in org.springframework.beans.factory.support.DefaultListablebeanfactory@173b262: defining beans [org.springframework.beans.factory.config.PropertyPlaceholderConfigurer#0,org.springframework.context.config.internalBeanConfigurerAspect,org.springframework.context.annotation.internalConfigurationAnnotationProcessor,org.springframework.context.annotation.internalAutowiredAnnotationProcessor,org.springframework.context.annotation.internalrequiredAnnotationProcessor,org.springframework.context.annotation.internalCommonAnnotationProcessor,org.springframework.beans.factory.config.PropertyOverrideConfigurer#0,dataSource,transactionManager,sqlSessionFactory,managedTransactionFactory,springApplicationContext]; root of factory hierarchy
02:41:34,512 DEBUG main [Connection] ooo Connection Opened
02:41:34,659 DEBUG main [PreparedStatement] ==> Executing: select id,order_number,com_id,order_date,status,source,created_on,created_by,is_deleted,modified_on,modified_by from order WHERE ( id = ? and is_deleted = ? )
02:41:34,660 DEBUG main [PreparedStatement] ==> Parameters: 264(Long),false(Boolean)
02:41:34,699 DEBUG main [ResultSet] <== Columns: id,modified_by
02:41:34,709 DEBUG main [ResultSet] <== Row: 264,00277-100410,1041,2010-01-01 00:00:00.0,Pending,COMPANY A,2011-05-24 00:21:00.337,1,null,null
02:41:34,723 DEBUG main [Connection] xxx Connection Closed
02:41:34,742 DEBUG main [Connection] ooo Connection Opened
02:41:34,747 DEBUG main [PreparedStatement] ==> Executing: insert into task (type,owner,description,context_id,deadline,assigned_to,parent_id,priority,escalation_id,reference_no,result,modified_by,category,entity_id,is_assigned_to_group) values (?,?,?)
02:41:34,747 DEBUG main [PreparedStatement] ==> Parameters: Investigation(String),InProgress(String),1(Long),Please investigate this order(String),2011-05-27 02:41:34.736(Timestamp),normal(String),2011-05-26 02:41:34.737(Timestamp),Order(String),264(Long),false(Boolean),true(Boolean)
02:41:34,757 DEBUG main [PreparedStatement] ==> Executing: select @@identity
02:41:34,757 DEBUG main [PreparedStatement] ==> Parameters:
02:41:34,763 DEBUG main [ResultSet] <== Columns:
02:41:34,763 DEBUG main [ResultSet] <== Row: 94
02:41:34,782 DEBUG main [Connection] xxx Connection Closed
02:41:34,800 DEBUG main [Connection] ooo Connection Opened
02:41:34,803 DEBUG main [PreparedStatement] ==> Executing: insert into task_tag (name,value,task_id ) values (?,? )
02:41:34,804 DEBUG main [PreparedStatement] ==> Parameters: RoleId(String),1(String),94(Long)
02:41:34,842 INFO main [XmlBeanDeFinitionReader] Loading XML bean deFinitions from class path resource [org/springframework/jdbc/support/sql-error-codes.xml]
02:41:34,859 INFO main [sqlErrorCodesFactory] sqlErrorCodes loaded: [DB2,Derby,H2,Hsql,Informix,MS-sql,MysqL,Oracle,Postgresql,Sybase]
02:41:34,944 DEBUG main [Connection] xxx Connection Closed
解决方法
从DEBUG日志中，看起来好像tx从未启动。我认为问题是默认情况下未启用
@Transactional
<tx:jta-transaction-manager/>
<bean id=\"transactionManager\" class=\"org.springframework.jdbc.datasource.DataSourceTransactionManager\">
<property name=\"dataSource\" ref=\"dataSource\"/>
<property name=\"nestedTransactionAllowed\" value=\"true\" />
<property name=\"validateExistingTransaction\" value=\"true\" />
</bean>