spring 事务管理（编程式）

spring事务管理（编程式）

1、关键抽象类：

Java代码

package org.springframework.transaction;
public interface PlatformTransactionManager {
TransactionStatus getTransaction(TransactionDefinition definition) throws TransactionException;
void commit(TransactionStatus status) throws TransactionException;
void rollback(TransactionStatus status) throws TransactionException;
}

TransactionDefinition定义了事务的隔离成都，传播行为，超时，只读等属性，TransactionStatus代表了一个新的事务发起或者已经存在的事务，可以通过它来控制事务的执行和调查的状态。

Java代码

package org.springframework.transaction;
public interface TransactionStatus extends SavepointManager {

boolean isNewTransaction();

boolean hasSavepoint();

void setRollbackOnly();

boolean isRollbackOnly();

boolean isCompleted();

}

spring提供编程式事务管理和声明式事务管理。

编程式事务管理可以实现细粒度的事务管理。spring提供两种方式，一种为PlatformTransactionManager，另一种为TransactionTemplate。
先使用PlatformTransactionManager实现。

Java代码

package cn.com.gan.spring.database;

public interface IUserDao {
public void insert(User user);
public User find(String name);
}

Java代码

package cn.com.gan.spring.database;

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

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

import javax.sql.DataSource;

public class UserDao implements IUserDao {
// private DataSource dataSource;
private JdbcTemplate jdbcTemplate;
private PlatformTransactionManager tm;
private DefaultTransactionDefinition df;
public void setDataSource(DataSource dataSource) {
jdbcTemplate = new JdbcTemplate(dataSource);
tm=new DataSourceTransactionManager(dataSource);
df=new DefaultTransactionDefinition();
df.setPropagationBehavior(DefaultTransactionDefinition.PROPAGATION_REQUIRED);
}
@Override
public User find(String name) {
List<Map> list = jdbcTemplate
.queryForList("select * from user where name='" + name + "'");
User user = null;
for (Map map : list) {
user = new User();
user.setName(map.get("name").toString());
user.setAge(Short.parseShort(map.get("age").toString()));
}
return user;
}
@Override
public void insert(User user) {
TransactionStatus ts=tm.getTransaction(df);
try{
jdbcTemplate.update("insert into user(name,age) values(?,?)",
new Object[] { user.getName(), user.getAge() });
jdbcTemplate.update("insert into user(name,age) values(?,?)",
new Object[] { user.getName(), user.getAge() });
}catch(DataAccessException e){
tm.rollback(ts);
e.printStackTrace();
}
tm.commit(ts);
}
}

其中insert为事务管理，如果其中一条插入失败就回滚。