spring 重写dao层怎么配置事务?

你说的事务没有生效具体情况没看运行结果看不出来，我这里说一下我做的测试和理解吧。

首先我这个项目使用了SpringMVC搭建，事务配置和你的基本一致：

因为我的事务管理器使用的id是默认id，所以<tx:annotation-driven />后面不需要跟id

连接池使用的是commchangev2c3p0ComboPooledDataSource

然后我查资料了解到：

所以我就不像你这样写了，反正都是默认值

接着做出如下几种测试：

1、在Service实现层方法上添加@Transactional注解：

控制器的注册方法这么写：

可以看到这个是重复插表了，必然引起违反唯一约束异常

把数据库清空：

postman准备：

冲！

好，服务器返回500了，我们看下日志：

第一次insert时，首先创建了一个会话，注册事务，连接入池，执行插入，插入成功，释放会话资源，事务提交，事务关闭。

第二次insert，还是创建会话吧啦吧啦一堆，然后插入失败，服务器发生commysqljdbcexceptionsjdbc4MySQLIntegrityConstraintViolationException异常，此时直接释放会话，在服务器打印错误信息，事务关闭。事务没有进行提交，所以事务得到回滚。

但是可以发现因为第一次插入的会话也好，事务也好，已经和第一次插入不是一个了，所以第一次插入还是成功了：

只有第二次事务得到了回滚。

所以我意识到只有将所有数据库 *** 作都包含在同一个事务之中，那么事务回滚的时候才能大家一起回滚。

因此，这次测试的时候，我将@Transactional直接放到控制器中：

再冲！

再次500了，我们看下日志：

第一次插入时，新建了会话，注册了事务，入池，然后执行，执行成功，释放会话资源，然后事务没有关闭，也没有提交。

紧接着就开始第二次插入，它直接fetched（获取）当前事务中的会话，执行插入，释放会话资源，此时再次发生MySQLIntegrityConstraintViolationException异常，打印异常信息，事务没有提交直接关闭，得到回滚。

查了下数据库确实没有新数据被插入。

综上所述，我这个事务回滚还是生效了的，关键还是在于@Transactional注解的设置位置。这个注解设置在某个方法上，只能将这个方法内所进行的所有数据库 *** 作归结到一个事务里，出了这个方法，那就管不了了。

所以我想看一下你的这个注解到底是怎么加的？

另外直接把注解加载服务层的类上我试了也不行

这样也是无法回滚的。

你好，dao层统一写，具体的业务写在service层中。因为你还可能有判断登录，注册，他们的实现是不一样的。下面给出一个dao的例子：
package orgfitdao;
import javasqlConnection;
import javasqlDriverManager;
import javasqlPreparedStatement;
import javasqlResultSet;
import javasqlSQLException;
import orgfitexSysException;
public class Dao {

private static final String DRIVER=
"commysqljdbcDriver";

private static final String URL=
"jdbc:mysql://localhost:3306/cateweb";

private static final String USER="root";

private static final String PASSWORD="0";

public Dao() throws SysException{
try {
ClassforName(DRIVER);
} catch (ClassNotFoundException e) {
eprintStackTrace();
throw new SysException("驱动没有找到！") ;
}
}

private Connection conn;
private PreparedStatement pt;
private ResultSet rs;
public ResultSet query(String sql,Object paramValues)
throws SQLException{

try {
conn=DriverManagergetConnection(URL,USER,PASSWORD);
pt=connprepareStatement(sql);
if(paramValues!=null){
for(int i=0;i<paramValueslength;i++){
ptsetObject(i+1, paramValues[i]);
}
}
rs=ptexecuteQuery();
return rs;
} catch (SQLException e) {
eprintStackTrace();
thisclose();
throw e;
}

}

public int update(String sql,Object paramValues)
throws SQLException{
try{
conn=DriverManagergetConnection(URL,USER,PASSWORD);
pt=connprepareStatement(sql);
if(paramValues!=null){
for(int i=0;i<paramValueslength;i++){
ptsetObject(i+1, paramValues[i]);
}
}

return ptexecuteUpdate();
}finally{
thisclose();
}

}

public void close(){
try {
if(rs!=null){
rsclose();
}
} catch (Exception e) {}
rs=null;

try {
if(pt!=null){
ptclose();
}
} catch (Exception e) {}
pt=null;

try {
if(conn!=null){
if(!connisClosed())connclose();
}
} catch (Exception e) {}
conn=null;
}
}

---