spring 事务管理 1（使用spring的JdbcTemplate访问数据库）

持久层和事务的关系

dao层脱离事务也能操作数据库，事务是保证dao层数据操作的完整性（即原子性、一致性、隔离性、持久性，也即所谓的 ACID）

事务可以保证一组操作要么全成功，要么全部失败，就是事务是一个不可分割的整体

使用spring 封装的jdbc访问数据库（未使用事务）

定义bean

package sping.jdbc;

import java.sql.SQLException;

import javax.annotation.Resource;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Propagation;
import org.springframework.transaction.annotation.Transactional;

@Service(value="jdbcWithoutTM")
public class JdbcWithoutTM {

@Resource(name="jdbcTemplate")
private JdbcTemplate jt;

public void addPerson(){
jt.execute("insert into person(pname) values ('名字')");
}

}

xml配置文件

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

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd ">

<context:component-scan base-package="sping.jdbc*"></context:component-scan>

<!-- 数据源默认将autoCommit设置为true -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy-method="close">
<property name="driverClass" value="${jdbc.driverClassName}" />
<property name="jdbcUrl" value="${jdbc.url}" />
<property name="user" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
</bean>

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

<context:property-placeholder location="jdbc.properties" />
</beans>

junit测试类
package sping.jdbc.test;

import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;

import sping.jdbc.JdbcWithoutTM;

public class SpringJdbcTest {
private static ApplicationContext context;
@BeforeClass
public static void setUpBeforeClass() throws Exception {
context = new ClassPathXmlApplicationContext(
new String[] { "jdbc.xml" });
}

@AfterClass
public static void tearDownAfterClass() throws Exception {
}

@Test
public void test() {
JdbcWithoutTM jtm=context.getBean("jdbcWithoutTM", JdbcWithoutTM.class);
jtm.addPerson();
}

}

此程序虽然没有配置和使用事务控制，但是数据还是插入到了数据库。这说明数据库操作并一定需要事务控制。

现在我们修改下JdbcWithoutTM的插入方法，让他在数据库插入操作完成之后手动抛出个异常，看数据是否还能插入。

public void addPerson(){

jt.execute("insert into person(pname) values ('王江涛')");
throw new RuntimeException();
}

运行程序，查看数据库，结果是数据还是插入到了数据库（事务自动提交），这明显不符合我们的要求，说明此操作没有回滚，造成操作的不完整性，当然，我们只是一个插入操作，如果我们在插入操作之后再有个与之相关的数据库操作，而在两个操作中间出了个异常，那么就造成数据不完整了。

所以我们就要加入事务，而spring让我们从繁琐的事务控制中解脱出来。

我们修改xml配置文件，加入事务的配置

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

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd ">

<context:component-scan base-package="sping.jdbc*"></context:component-scan>

<!-- 数据源默认将autoCommit设置为true -->
<bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"
destroy-method="close">
<property name="driverClass" value="${jdbc.driverClassName}" />
<property name="jdbcUrl" value="${jdbc.url}" />
<property name="user" value="${jdbc.username}" />
<property name="password" value="${jdbc.password}" />
</bean>

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

<!-- 事务管理配置 如果使用orm框架，则替换为相应的事务管理器，注意，如果想使用注解性事务，

则需引入cglib-nodep.jar，不是cglib.jar-->
<bean id="myTxManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
</bean>
<tx:annotation-driven transaction-manager="myTxManager"></tx:annotation-driven>

<context:property-placeholder location="jdbc.properties" />
</beans>

在插入操作方法上面加上事务注解

@Transactional(propagation=Propagation.REQUIRED)
public void addPerson(){

jt.execute("insert into person(pname) values ('王江涛')");//1
System.out.println(1/0);//2
jt.execute("insert into person(pname) values ('王江涛')");//3
}

再次执行程序，可以看到，数据库并没有插入任何数据，因为程序在2处出现了异常，所以以前做的所有操作全部回滚了。这就符合我们的要求啦