Spring的事务管理

Spring提供了一致的事务管理抽象。这个抽象是Spring最重要的抽象之一， 它有如下的优点：

1.为不同的事务API提供一致的编程模型，如JTA、JDBC、Hibernate、iBATIS数据库层 和JDO

2.提供比大多数事务API更简单的，易于使用的编程式事务管理API

3.整合Spring数据访问抽象

4.支持Spring声明式事务管理

环境:Eclipse3.0,JDK1.4,spring1.2.3,MySQL

程序主体代码如下:

配置文件:

<?XML version="1.0" encoding="UTF-8"?>

<!DOCTYPE beans PUBLIC "-//SPRING//DTD BEAN//EN" "http://www.springframework.org/dtd/spring-beans.dtd">
<beans>
  <bean id="dataSource" class="org.springFramework.jdbc.datasource.DriverManagerDataSource" destroy-method="close">
   <property name="driverClassName">
    <value>com.mysql.jdbc.Driver</value>
   </property>
   <property name="url">
    <value>jdbc:mysql://localhost:3306/test</value>
   </property>
   <property name="username">
    <value>root</value>
   </property>
   <property name="password">
    <value>1234</value>
   </property>
  </bean>
  <bean id="business" class="databaserollback.BusinessImpl">
   <property name="dataSource">
    <ref bean="dataSource"/>
   </property>
  </bean>
 
     <bean id="dbTransactionManager"
     class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
     <property name="dataSource">
     <ref bean="dataSource"/>
    </property>

  </bean>
  
     <bean id="accountservice" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean" >
     <property name="transactionManager" ><ref bean="dbTransactionManager" /></property>
     <property name="target">
    <ref bean="business" />
  </property>
     <property name="transactionAttributes" >
      <props>
       <prop key="insertOne">PROPAGATION_REQUIRED</prop>
      </props>
     </property>
    </bean>
 
</beans>

业务类:

public class BusinessImpl implements Business {
    
    DataSource 

dataSource = null;
    /**
     * @throws SQLException
     * 
     

*/
    public void insertOne() {
        Connection conn = 

DataSourceUtils.getConnection(dataSource);
        Statement stat;
        

try {
            stat = conn.createStatement();
        
        

String sql = "insert into room1 (room_id,address) values 

('1','dalian')";
        String sql1 = "insert into room1 (room_id,address) 

values ('1','dalian')";
        
        

stat.executeUpdate(sql);
        stat.executeUpdate(sql1);
        } catch (SQLException e) {

        }
       

System.out.println("insertOne");
    }
    
    /**
     * @return Returns the ds.
     */
    public DataSource 

getDataSource() {
        return dataSource;
    }
    /**
     * 

@param ds The ds to set.
     */
    public void setDataSource(DataSource 

dataSource) {
        this.dataSource = dataSource;
    }
}

测试类:

public class Test {
   
    protected static PlatformTransactionManager transactionManager;
    protected static TransactionStatus transactionStatus;
    public static void main(String[] args) throws SQLException  {
     ClassPathResource res;
     XmlBeanFactory factory;
  res = new ClassPathResource("Appcontext.xml");
  factory = new XmlBeanFactory(res);
  
        //transactionManager = (PlatformTransactionManager) factory.getBean("dbTransactionManager");
        //transactionStatus = transactionManager.getTransaction(new DefaultTransactionDefinition());
  
  
  Business bi = (Business) factory.getBean("accountservice");
//  
//  try {
            bi.insertOne();

//        } catch (SQLException e) {
//            transactionManager.rollback(transactionStatus);
//        }
    }
}

因为使用的数据库是mysql,所以建立表的时候要指定INNODB,来支持事务!

CREATE TABLE room1 (
ROOM_ID varchar(10),
ADDRESS varchar(32),
PRIMARY KEY (ROOM_ID)
) TYPE=INNODB;

执行这段代码之后,控制台抛出错误,查询数据库,发现事务没有回滚,为什么呢??

首先要了解spring处理事务的本质,只有当程序抛出一个RuntimeException-->DataAccessException是spring才会捕获他,并且进行事务的处理!

标签：

版权申明：本站文章部分自网络，如有侵权，请联系：west999com@outlook.com
特别注意：本站所有转载文章言论不代表本站观点，本站所提供的摄影照片，插画，设计作品，如需使用，请与原作者联系，版权归原作者所有