spring mvc 事务失效问题

0 0

spring mvc 事务失效问题15

同时向两个表插入数据，第一条成功，第二条数据插入失败，第一条未回滚，具体配置如下

applicationContext.xml 代码

<context:component-scan base-package="com">
<context:exclude-filter type="annotation"
expression="org.springframework.stereotype.Controller" />
</context:component-scan>

<util:properties id="settings"
location="classpath:config/global.properties" />

<bean id="configProperties"
  class="org.springframework.beans.factory.config.PropertiesFactoryBean">
  <property name="locations">
   <list>
    <value>classpath:config/jdbc.properties</value>
   </list>
  </property>
</bean>
<bean id="propertyConfigurer"
  class="org.springframework.beans.factory.config.PreferencesPlaceholderConfigurer">
  <property name="properties" ref="configProperties" />
</bean>
<mvc:annotation-driven />

<bean id="dataSource" class="org.logicalcobwebs.proxool.ProxoolDataSource">
  <property name="driver" value="${driver}" />
  <property name="driverUrl" value="${driverUrl}" />
  <property name="user" value="${user}" />
  <property name="password" value="${password}" />
  <property name="alias" value="proxool.aidecenter" />
  <property name="maximumActiveTime" value="300000" />
  <property name="prototypeCount" value="0" />
  <property name="maximumConnectionCount" value="${maximumConnectionCount}" />
  <property name="minimumConnectionCount" value="${minimumConnectionCount}" />
  <property name="simultaneousBuildThrottle" value="50" />
  <property name="houseKeepingTestSql" value="select form CURRENT_DATE" />
</bean>

<bean id="jdbc" class="org.springframework.jdbc.core.JdbcTemplate">
  <property name="dataSource" ref="dataSource" />
</bean>
<bean
  class="org.springframework.beans.factory.config.MethodInvokingFactoryBean">
  <property name="staticMethod" value="com.common.database.SpringDB.setJdbcTemplate" />
  <property name="arguments" ref="jdbc" />
</bean>

<bean id="transactionManager"
  class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  <property name="dataSource">
   <ref local="dataSource" />
  </property>
</bean>

<bean id="transactionTemplate"
  class="org.springframework.transaction.support.TransactionTemplate">
  <property name="transactionManager">
   <ref local="transactionManager" />
  </property>
</bean>
<aop:config>
  <aop:pointcut id="transactionPointcut"
   expression="execution(* com.service..*.*(..))" />
  <aop:advisor pointcut-ref="transactionPointcut"
   advice-ref="advice" />
</aop:config>
<tx:advice id="advice" transaction-manager="transactionManager">
  <tx:attributes>
   
   <tx:method name="find*" read-only="true" />
   
   <tx:method name="save*" propagation="REQUIRED" />
   <tx:method name="update*" />
   <tx:method name="delete*" />
  </tx:attributes>
</tx:advice>
<tx:annotation-driven transaction-manager="transactionManager"
  proxy-target-class="true" />
</beans>

dispatcher-servlet.xml

<context:component-scan base-package="com.controller">
  <context:include-filter type="annotation"
   expression="org.springframework.stereotype.Controller" />
  <context:exclude-filter type="annotation"
   expression="org.springframework.stereotype.Service" />
</context:component-scan>

<bean
  class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter">
  <property name="messageConverters">
   <list>
    <ref bean="mappingJacksonHttpMessageConverter" />
    <ref bean="stringHttpMessageConverter" />
   </list>
  </property>
</bean>

<bean id="stringHttpMessageConverter"
  class="org.springframework.http.converter.StringHttpMessageConverter">
  <property name="supportedMediaTypes">
   <list>
    <value>text/plain;charset=UTF-8</value>
   </list>
  </property>
</bean>

<bean id="mappingJacksonHttpMessageConverter"
  class="org.springframework.http.converter.json.MappingJacksonHttpMessageConverter">
  <property name="supportedMediaTypes">
   <list>
    <value>application/json;charset=UTF-8</value>
   </list>
  </property>
</bean>

<bean id="sessionInterceptor" class="com.interceptor.SessionInterceptor"></bean>

<bean id="viewResolver"
  class="org.springframework.web.servlet.view.InternalResourceViewResolver">
  <property name="viewClass"
   value="org.springframework.web.servlet.view.JstlView" />
  <property name="prefix" value="" />
  <property name="suffix" value=".jsp" />
</bean>

<cache:annotation-driven cache-manager="cacheManager" />
<bean id="cacheManager"
class="org.springframework.cache.concurrent.ConcurrentMapCacheManager" />

<mvc:resources mapping="/upload/**" location="/upload/"
cache-period="31556926" />
<mvc:resources mapping="/libs/**" location="/libs/"
cache-period="31556926" />
</beans>
上传的图片为包结构

Service的注解在接口实现类中

@Service
@Transactional
public class SiteServiceImpl implements SiteService {

.......

}

请问是哪里配置错了么

问题补充：上传附件为包结构

问题补充：实现类
package com.service.site.impl;

import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;

import com.common.TableName;
import com.dao.BaseDao;
import com.service.site.SiteService;

@Service
@Transactional
public class SiteServiceImpl implements SiteService {

@Autowired
BaseDao baseDao;

@Override
public int saveSite(String tableName, Map<String, Object> map) throws Exception {
return baseDao.save(tableName, map, SiteServiceImpl.class);
}

@Override
public int updateSite(String tableName, Map<String, Object> updateMap, Map<String, Object> whereMap) throws Exception {
return baseDao.update(tableName, updateMap, whereMap, SiteServiceImpl.class);
}
}

问题补充：Controller类
package com.controller.site;

import java.util.HashMap;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.ResponseBody;

import com.common.Public;
import com.common.TableName;
import com.entity.site.Site;
import com.service.site.SiteService;
import com.service.systemmanage.FunctionMenuService;
import com.service.table.TableService;

@Controller
@RequestMapping(value = "/Site")
public class SiteController {

@Autowired
SiteService ss;

@Autowired
TableService ts;

@RequestMapping(value = "/addSite", method = RequestMethod.POST)
@ResponseBody
public int add(Site site) throws Throwable {
Map<String, Object> map = new HashMap<String, Object>();
map.put("site_id", Public.generalStandardId());
ss.saveSite(TableName.webissue_site_list, map); // 这个保存成功
Map<String, Object> map1 = new HashMap<String, Object>();
map1.put("id", Public.generalStandardId());
map1.put("name1", "aaa");
ts.saveTable("Table_1", map1); // 这个保存肯定失败
return 1;
}

}

问题补充：BaseDao实现类
package com.dao.impl;

import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;
import java.util.Map;

import org.springframework.stereotype.Repository;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

import com.common.database.SpringDB;
import com.dao.BaseDao;

@Repository
@Transactional
public class BaseDaoImpl extends SpringDB implements BaseDao {

/**
* 添加数据
*/
@Override
public <T> int save(String tableName, Map<String, Object> map, Class<T> clazz) throws Exception {
if (tableName != null && tableName.length() > 0) {
StringBuffer sql = new StringBuffer();
StringBuffer sql2 = new StringBuffer();
List<Object> params = new ArrayList<Object>();
sql.append("insert into " + tableName + " (");
for (Iterator<String> iterator = map.keySet().iterator(); iterator.hasNext();) {
String colName = iterator.next();
Object colVal = map.get(colName);
if (iterator.hasNext()) {
sql.append(colName + ",");
sql2.append("?, ");
} else {
sql.append(colName + ") values(");
sql2.append("?)");
}
params.add(colVal);
}
return this.executeUpdate(sql.toString() + sql2.toString(), params.toArray(), clazz);
} else {
return -1;
}
}
}

问题补充：数据库连接
package com.common.database;

import org.apache.log4j.Logger;
import org.springframework.jdbc.core.JdbcTemplate;

public class SpringDB {

private static JdbcTemplate jdbc;

public static void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
SpringDB.jdbc = jdbcTemplate;
}

/**
* 增、删、改，类型为int
*
* @param sql
*           要执行的sql语句
* @param params
*           sql所对应的参数列表
* @param clazz
*           调用类
* @return 成功返回1,失败返回-1
*/
protected <T> int executeUpdate(String sql, Object[] params, Class<T> clazz) {
Logger log = Logger.getLogger(clazz);
//try {
return jdbc.update(sql, params);
//} catch (Exception e) {
// log.error(clazz + e.getMessage(), e);
// return -1;
//}
}
}

问题补充：com
controller包
    site
      SiteController.java
dao包
    impl
      BaseDaoImpl.java
    BaseDao.java
service包
    site
      impl
        SiteServiceImpl.java
      SiteService.java

Spring

2014年6月30日 11:04

xiaotqc000
18
0 0 3

查看图片附件

4个答案按时间排序按投票排序

0 0

采纳的答案

这个错误多明显啊，你事物定义到service包上面，然后你在controller包里调用了2个service去操作两张表。这俩个service的事物已经不在一个上下文里了。

Spring的事物是需要这样的。

@tran.....
public void doxx() {
dao.save(A表)
dao.delete(B表)
}

这样才能生效啊。

2014年7月01日 14:14

FirstBlood
101
1 1 33

1条评论

0 0

dispatcher-servlet.xml文件中


<context:component-scan base-package="com.controller">

将base-package="com.controller"改为base-package="com"试试

只是猜测，未看到你controller的包结构

2014年6月30日 17:54