spring中使用编程级的事务

使用org.springframework.transaction.support.TransactionTemplate类,
TransactionTemplate封装了事务管理的功能，包括异常时的事务回滚，以及操作成
功后的事务提交。在doInTransaction中进行的操作，如果抛出未捕获异常将被自动回滚，
如果成功执行,则将被自动提交。使用TransactionTemplate类，必须实现TransactionCallback接口，
transactionCallback只有一个实现方法，使用匿名内部类，doInTransaction()处理事务。
类似与JDbcTemplate，Callback类的编写违背很多人的编程习惯,传进匿名类之前要改成final。
配置文件
<bean id="transactionTemplate" class="org.springframework.
transaction.support.TransactionTemplate">

<property name="transactionManager">

<ref bean="transactionManager"/>

</property>

</bean>

DAO中
<property name=" transactionTemplate">

<ref bean=" transactionTemplate"/>

</property>

使用TransactionTemplate的doInTransaction() 不能抛出任何checked exceptions，必须将异常包装为unchecked exceptions，
因为TransactionTemplate不支持throws
下面是代码
transactionTemplate.execute(
new TransactionCallback() {
public Object doInTransaction(TransactionStatus ts) {
try {
// do stuff
} catch (Exception e) {
ts.setRollbackOnly();
}
return null;
}
}
);
使用PlatformTransactionManager效率更高
package module;

import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.TransactionDefinition;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.support.DefaultTransactionDefinition;
import org.springframework.jdbc.datasource.DriverManagerDataSource;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.dao.DataAccessException;

import javax.sql.DataSource;

public class testTranORacleDAO {
    private static DataSource dataSource;
    private static PlatformTransactionManager transactionManager;
    private static JdbcTemplate jt;

    public static void main(String[] args) {
        DriverManagerDataSource dataSource = new DriverManagerDataSource();
        dataSource.setDriverClassName("oracle.jdbc.driver.OracleDriver");
        dataSource.setUrl("jdbc:oracle:thin:@localhost:1521:ILoveMM");
        dataSource.setUsername("system");
        dataSource.setPassword("manager");
        DataSourceTransactionManager tm = new DataSourceTransactionManager();
        tm.setDataSource(dataSource);
        transactionManager = tm;
        doUpdate(dataSource);
    }

    public static void doUpdate(DataSource dataSource) {
        DefaultTransactionDefinition td = new DefaultTransactionDefinition(
                TransactionDefinition.PROPAGATION_REQUIRED);
        td.setIsolationLevel(TransactionDefinition.ISOLATION_SERIALIZABLE);
        td.setTimeout(10);
        TransactionStatus status = transactionManager.getTransaction(td);

        try {
            update(dataSource);
        } catch (DataAccessException e) {
            transactionManager.rollback(status);
            throw e;
        }
        transactionManager.commit(status);
    }

    public static void update(DataSource dataSource) {
        jt = new JdbcTemplate(dataSource);
        jt.update("delete  from beers where id=2 ");
        jt.update("insert into beers(id,BRAND,price) values(1,'3',100)");
    }
}

评论

1 楼 Jason(aijun) 2008-09-18  

特别是在一些多事务源的程序里，这点千万不能搞错。如果多个事务源(如数据库在不同的服务器上，代码用的是事务源a的一些资源，比如到服务器a的一个datasource，但是你的transactionManager管理的是另一些资源，比如服务器b的一个datasource)之间要完成全局事务，还是老老实实用分布式事务管理服务吧（jta）