基于泛型、反射，使用jdbcTemplate写了一个公共DAO，作为小例子前提测试一下业务层的事务，用的注解@Transactional
DAO代码片断：
[code="java"]
public boolean insertSingleData(final List datas) throws Exception{
if (null == datas || datas.size()==0)
return false;
...

    String sql = String.format("INSERT INTO %s %s VALUES %s",
            type.getSimpleName().toLowerCase(),
            fieldList.toString().replace('[', '(').replace(']', ')'),
            paramList.toString().replace('[', '(').replace(']', ')') );

    BatchPreparedStatementSetter setter = new BatchPreparedStatementSetter() {
        public void setValues(PreparedStatement arg0, int arg1) throws SQLException {
                final T currentVo = datas.get(arg1);
                for(int v=0;v<targetFields.size();v++){
                    try {
                        arg0.setObject(v+1, getBeanFieldValues(currentVo,targetFields.get(v).toLowerCase()));
                    } catch (Exception e) {
                        e.printStackTrace();
                    }
                }
        }

        public int getBatchSize() {
            return datas.size();
        }
    };

    int[] result = jdbcTemplate.batchUpdate(sql, setter);
    return (result.length == datas.size())?true:false;
}

[/code]

然后有一个业务层Services的方法片段
[code="java"]
@Transactional(rollbackFor=Exception.class)
public void TestTrans() throws Exception{
vo =xxx;
pvo = xxxx;
commonDbService.insertSingleData(vo);
commonDbService.insertSingleData(pvo);
}
[/code]

pvo我模拟插入一个超长字段值，引起了异常。预期结果应该是两个都要回滚，可是vo的值却插入到数据库中了，并没有回滚？
哪里有问题咧？
[b]问题补充：[/b]
To:lovewhzq

是基于注解的方式

想法是在业务层实现事务控制，DAO只是最小的数据处理单元，我在业务层做的事务定义
@Transactional(rollbackFor=Exception.class)

public void TestTrans() throws Exception

至于Dao这一层，做不做以下配置
@Transactional(propagation=Propagation.REQUIRED)
都不起作用，一次insertSingleData还是一个事务，二个一起跑第二个错了第一个没有回滚...
[b]问题补充：[/b]

感谢各位

TO:sunlightcs
DAO里面没有用@Trans...只在业务层使用了。

To:lovewhzq:
DAO只是做了一个反射，使用的jdbcTemplate，本身并没有使用与事务相关的东东

实在很郁闷...
[b]问题补充：[/b]
贴出源代码,以更新举例吧
[quote]
/**
* 根据主键ID更新
*/
public int updateDataById(T vo) throws RuntimeException{
try{
final Class<?> type = vo.getClass();
String fieldName = "";
ArrayList fieldList = new ArrayList();
ArrayList fieldNames = new ArrayList();
for(Field field : type.getDeclaredFields()){
fieldName = field.getName();
//结果值不为null并且字段名称不以_结束，即虚字段
if (null!=getBeanFieldValues(vo,fieldName) && !fieldName.endsWith("_")){
fieldList.add(fieldName.concat("=?"));
fieldNames.add(fieldName);
}
}
String sql = String.format("UPDATE %s SET %s WHERE id=?",
type.getSimpleName().toLowerCase(),
fieldList.toString().replace('[', ' ').replace(']', ' ') );
showLog(sql);
Object[] params = new Object[fieldNames.size()+1];
for(int m=0;m<fieldNames.size();m++){
params[m] = getBeanFieldValues(vo, fieldNames.get(m));
}
params[params.length-1] = getBeanFieldValues(vo, "id");
return jt.update(sql, params);
}catch (Exception e){
throw new RuntimeException();
}
}
[/quote]
业务层测试源代码
[code="java"]
@Transactional
public void TestTrans() throws RuntimeException{
Person vo=null;
Products pvo = null;
try{
vo = commonDbService.queryDataById(Person.class, null, null, "101",null);
vo.setName("aaa");
pvo = commonDbService.queryDataById(Products.class, null, null, 1, null);

    pvo.setProductname("jackjackjackjackjackjackjackjackjackjackjackjackjackjackjackjackjackjack");//这里引发异常
    commonDbService.updateDataById(vo); // 他居然提交了，没有回滚
    commonDbService.updateDataById(pvo);
    }catch (Exception e){
        throw new RuntimeException(){};
    }
}

[/code]
Spring配置
[code="java"]
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">

<tx:annotation-driven transaction-manager="txManager" />

<bean id="mainbean" class="net.duoer.MainBean" autowire="byName" />

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
    <property name="dataSource">
        <ref bean="dataSource" />
    </property>
</bean>

<bean id="commonDbService" class="net.duoer.service.impl.MySQLCommonDBServiceImpl">
    <property name="jt" ref="jdbcTemplate" />
    <property name="isDebug" value="true"></property>
</bean>

[/code]
不晓得哪里出了问题...

基于xxxx是什么意思啊？

weixin_43256057

2个回复