【Java EE 学习 52】【Spring学习第四天】【Spring与JDBC】【JdbcTemplate创建的三种方式】【Spring事务管理】【事务中使用dbutils则回滚失败！！！？？】

一、JDBC编程特点

　　静态代码+动态变量=JDBC编程。

　　静态代码：比如所有的数据库连接池 都实现了DataSource接口，都实现了Connection接口。

　　动态变量：用户名、密码、连接的数据库、表名、SQL语句等信息。

　　在spring中动态变量能够通过注入的形式给予。这样的变成方式适合包装成模板。静态代码构成了模板，而动态变量是需要传入的参数。

二、核心类JdbcTemplate

　　1.基于模板的设置。

　　2.完成了资源的创建和释放的工作。

　　3.简化了我们的JDBC操作。

　　4.完成了对JDBC的核心流程的工作，包括SQL语句的创建和执行。

　　5.仅仅需要传递DataSource就可以将其实例化。

　　6.JdbcTemplate只需要创建一次。

　　7.JdbcTemplate是线程安全类。

三、使用三种方式将DataSource对象传递给JdbcTemplate，创建JdbcTemplate对象。

　　1.第一种方法：继承org.springframework.jdbc.core.support.JdbcDaoSupport类

　　　　（1）首先配置数据源DataSource，这里使用c3p0数据库连接池

 <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
         <constructor-arg index="0" value="namedconfig"></constructor-arg>
 </bean>

 <?xml version="1.0" encoding="UTF-8"?>
 <c3p0-config>
     <!-- 默认配置，只可以出现一次 -->
     <default-config>
         <!-- 连接超时设置30秒 -->
         <property name="checkoutTimeout">30000</property>
         <!-- 30秒检查一次connection的空闲 -->
         <property name="idleConnectionTestPeriod">30</property>
         <!--初始化的池大小 -->
         <property name="initialPoolSize">2</property>
         <!-- 最多的一个connection空闲时间 -->
         <property name="maxIdleTime">30</property>
         <!-- 最多可以有多少个连接connection -->
         <property name="maxPoolSize">10</property>
         <!-- 最少的池中有几个连接 -->
         <property name="minPoolSize">2</property>
         <!-- 批处理的语句-->
         <property name="maxStatements">50</property>
         <!-- 每次增长几个连接 -->
         <property name="acquireIncrement">3</property>
         <property name="driverClass">com.mysql.jdbc.Driver</property>
         <property name="jdbcUrl">
             <![CDATA[jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8]]>
         </property>
         <property name="user">root</property>
         <property name="password">5a6f38</property>
     </default-config> 

     <named-config name="namedconfig">
         <!-- 连接超时设置30秒 -->
         <property name="checkoutTimeout">30000</property>
         <!-- 30秒检查一次connection的空闲 -->
         <property name="idleConnectionTestPeriod">30</property>
         <!--初始化的池大小 -->
         <property name="initialPoolSize">2</property>
         <!-- 最多的一个connection空闲时间 -->
         <property name="maxIdleTime">30</property>
         <!-- 最多可以有多少个连接connection -->
         <property name="maxPoolSize">2</property>
         <!-- 最少的池中有几个连接 -->
         <property name="minPoolSize">2</property>
         <!-- 批处理的语句-->
         <property name="maxStatements">50</property>
         <!-- 每次增长几个连接 -->
         <property name="acquireIncrement">2</property>
         <property name="driverClass">com.mysql.jdbc.Driver</property>
         <property name="jdbcUrl">
             <![CDATA[jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8]]>
         </property>
         <property name="user">root</property>
         <property name="password">5a6f38</property>
     </named-config>
 </c3p0-config>

c3p0-config.xml

　　　　（2）定义Dao

 package com.kdyzm.spring.jdbc;

 public interface CourseDao {
     public Course getCourse(Long cid);
 }

com.kdyzm.spring.jdbc.CourseDao

　　　　（3）实现Dao，这是非常关键的一步，因为需要继承JdbcDaoSupport类。

 package com.kdyzm.spring.jdbc;

 import java.sql.SQLException;

 import org.apache.commons.dbutils.QueryRunner;
 import org.apache.commons.dbutils.handlers.BeanHandler;
 import org.springframework.jdbc.core.support.JdbcDaoSupport;

 public class CourseDaoImpl extends JdbcDaoSupport implements CourseDao{
     @Override
     public Course getCourse(Long cid) {
         String sql="select cid,cname from course where cid = ?";
         QueryRunner run=new QueryRunner(this.getDataSource());
         Course course=null;
         try {
             course = run.query(sql,new BeanHandler<Course>(Course.class),1L);
         } catch (SQLException e) {
             e.printStackTrace();
         }
         return course;
     }
 }

　　　　（4）在applicationContext.xml文件中进行配置，注意这里使用proerty标签相当于调用了JdbcDaoSupport的setDataSource方法。

<!-- 第一种方法：继承JdbcDaoSupport -->
    <bean id="courseDao" class="com.kdyzm.spring.jdbc.CourseDaoImpl">
        <property name="dataSource">
            <ref bean="dataSource"/>
        </property>
    </bean>

　　　　（5）测试代码：

 ApplicationContext context=new ClassPathXmlApplicationContext("com/kdyzm/spring/jdbc/applicationContext.xml");
 CourseDao courseDao = (CourseDao) context.getBean("courseDao");
 Course course=courseDao.getCourse(1L);
 System.out.println(course);

 package com.kdyzm.spring.jdbc;
 /*
  * 课程类
  */
 public class Course {
     private Long cid;
     private String cname;

     public Course() {
     }
     @Override
     public String toString() {
         return "Course [cid=" + cid + ", cname=" + cname + "]";
     }
     public Long getCid() {
         return cid;
     }
     public void setCid(Long cid) {
         this.cid = cid;
     }
     public String getCname() {
         return cname;
     }
     public void setCname(String cname) {
         this.cname = cname;
     }
 }

com.kdyzm.spring.jdbc.Course

　　　　　　测试结果：

　　　　　　

　　　　分析：继承了JdbcDaoSupport类为什么是关键？JdbcDaoSupport类中有一个非常关键的方法setDataSource，它有一个JdbcTemplate类型的成员变量，我们通过使用该成员变量来完成所有工作：

　　　　　　

　　　　通过上面的流程图可以看到实际上JdbcDaoSupport将DataSource的引用传递给了JdbcTemplate，JdbcTemplate对象使用该DataSource对象完成对数据库的增删查改操作。

　　2.第二种方法：使用JdbcTemplate对象作为成员变量

　　　　（1）配置数据源

<!-- 引入DataSource -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <constructor-arg index="0" value="namedconfig"></constructor-arg>
    </bean>

　　　　（2）创建CourseDaoImpl1类，该类不再继承JdbcDaoSupport类，只是实现了CourseDao接口，但是新增加了成员变量JdbcTemplate jdbcTemplate，并提供了set、get方法。

 package com.kdyzm.spring.jdbc;
 /*
  * 第二种实现方式：使用JdbcTemplate类作为成员变量
  */
 import java.sql.SQLException;

 import org.apache.commons.dbutils.QueryRunner;
 import org.apache.commons.dbutils.handlers.BeanHandler;
 import org.springframework.jdbc.core.JdbcTemplate;

 public class CourseDaoImpl1 implements CourseDao{

     JdbcTemplate jdbcTemplate=null;

     public JdbcTemplate getJdbcTemplate() {
         return jdbcTemplate;
     }

     public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
         this.jdbcTemplate = jdbcTemplate;
     }

     public Course getCourse(Long cid) {
         String sql="select cid,cname from course where cid = ?";
         QueryRunner run=new QueryRunner(this.getJdbcTemplate().getDataSource());
         Course course=null;
         try {
             course = run.query(sql,new BeanHandler<Course>(Course.class),cid);
         } catch (SQLException e) {
             e.printStackTrace();
         }
         return course;
     }
 }

　　　　（3）配置applicationContext.xml文件

　　　　　　　　* 将JdbcTemplate对象纳入Spring容器管理

<bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
        <constructor-arg index="0">
            <ref bean="dataSource"/>
        </constructor-arg>
    </bean>

　　　　　　　　* 将courseDao1纳入Spring容器管理

<bean id="courseDao1" class="com.kdyzm.spring.jdbc.CourseDaoImpl1">
        <property name="jdbcTemplate">
            <ref bean="jdbcTemplate"/>
        </property>
</bean>

　　　　　　原理分析：实际上JdbcDaoSupport类的核心就是JdbcTemplate，同理，我们也可以将该类对象作为成员变量，效果是相同的。

　　3.第三种方式：继承JdbcTemplate类。

　　　　（1）配置数据源，同上

　　　　（2）新建CourseDaoImpl2，该类继承了JdbcTemplate类，并且实现了CourseDao接口。

 package com.kdyzm.spring.jdbc;
 /*
  * 第二种实现方式：使用JdbcTemplate类作为成员变量
  */
 import java.sql.SQLException;

 import javax.sql.DataSource;

 import org.apache.commons.dbutils.QueryRunner;
 import org.apache.commons.dbutils.handlers.BeanHandler;
 import org.springframework.jdbc.core.JdbcTemplate;

 public class CourseDaoImpl2 extends JdbcTemplate implements CourseDao{
     public CourseDaoImpl2(DataSource dataSource) {
         super(dataSource);
     }

     public Course getCourse(Long cid) {
         String sql="select cid,cname from course where cid = ?";
         QueryRunner run=new QueryRunner(this.getDataSource());
         Course course=null;
         try {
             course = run.query(sql,new BeanHandler<Course>(Course.class),cid);
         } catch (SQLException e) {
             e.printStackTrace();
         }
         return course;
     }
 }

　　　　（3）配置applicationContext.xml文件

<!-- 第三种方法：继承JdbcTemplate类 -->
    <bean id="courseDao2" class="com.kdyzm.spring.jdbc.CourseDaoImpl2">
        <constructor-arg index="0">
            <ref bean="dataSource"/>
        </constructor-arg>
    </bean>

　　　　测试略。原理分析：最根本的就是JdbcTemplate类，所以干脆继承该类。

四、spring中的事务管理

　　1.Spring的事务管理是声明式的事务管理。什么是"声明式"的事务管理？在配置文件中声明某个方法需要开启事务进行管理，然后被声明的这个方法就会开启事务。

　　　　Spring事务管理相对于Hibernate和JDBC的优越之处：

　　　　　　

　　2.Spring的事务管理器

　　　　spring没有直接管理事务，而是将管理事务的责任委托给JTA或者相应的持久性机制所提供的某个特定平台的事务实现。

事务管理器	目标
org.springframework.transaction.PlatformTransactionManager	事务管理器的*接口
org.springframework.transaction.support.AbstractPlatformTransactionManager	事务管理器的超类
org.springframework.jdbc.datasource.DataSourceTransactionManager	在单一的JDBC DataSource中的事务管理
org.springframework.orm.hibernate3.HibernateTransactionManager	当持久化机制是hibernate的时候，使用它来管理事务
org.springframework.orm.jdo.JdoTransactionManager	使用一个JTA实现来管理事务，当一个事务跨越多个资源的时候必须使用

　　3.Spring事务的传播属性

　　　　

　　　　　　在实际工作当中，99%的使用过的是REQUIRED。

　　4.spring事务的隔离级别

　　　　

　　　　　　在实际工作中，99%使用的是DEFAULT。

　　5.XML配置练习

　　　　（1）引入命名空间

 <?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-2.5.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
         http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
            ">

 </beans>

　　　　（2）user表：

CREATE TABLE `user` (
   `id` varchar(32) NOT NULL,
   `name` varchar(32) DEFAULT NULL,
   `age` int(11) DEFAULT NULL,
   PRIMARY KEY (`id`)
 ) ENGINE=InnoDB DEFAULT CHARSET=utf8

　　　　（3）新建类：

 package com.kdyzm.spring.jdbc.transaction1;

 public class User {
     private String id;
     private String name;
     private Integer age;
     public User() {
     }
     public String getId() {
         return id;
     }
     public void setId(String id) {
         this.id = id;
     }
     public String getName() {
         return name;
     }
     public void setName(String name) {
         this.name = name;
     }
     public Integer getAge() {
         return age;
     }
     public void setAge(Integer age) {
         this.age = age;
     }
     @Override
     public String toString() {
         return "User [id=" + id + ", name=" + name + ", age=" + age + "]";
     }
 }

com.kdyzm.spring.jdbc.transaction1.User

 package com.kdyzm.spring.jdbc.transaction1;

 import java.sql.SQLException;

 public interface UserDao {
     public User updateUser(User user) throws SQLException;
 }

com.kdyzm.spring.jdbc.transaction1.UserDao

非常重要的一个类：com.kdyzm.spring.jdbc.transaction1.UserDaoImpl

 package com.kdyzm.spring.jdbc.transaction1;

 import java.sql.SQLException;

 import org.apache.commons.dbutils.QueryRunner;
 import org.springframework.jdbc.core.JdbcTemplate;

 public class UserDaoImpl implements UserDao{
     private JdbcTemplate jdbcTemplate;

     public JdbcTemplate getJdbcTemplate() {
         return jdbcTemplate;
     }

     public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
         this.jdbcTemplate = jdbcTemplate;
     }

     /**
      * 使用该方法测试非跨dao事务回滚问题
      * 一定不能使用dbutils工具，否则不能回滚！！！！！！！！！！！！！
      * @throws SQLException
      */
     @Override
     public User updateUser(User user) throws SQLException {
         String sql="update user set age=age+1 where id='0001'";
 //        QueryRunner runner=new QueryRunner(this.jdbcTemplate.getDataSource());
 //        runner.update(this.jdbcTemplate.getDataSource().getConnection(),sql,"0001");
         this.jdbcTemplate.execute(sql);
         int a=1/0;
         sql="update user set age=age+1 where id='0002'";
         this.jdbcTemplate.execute(sql);
 //        runner.update(this.jdbcTemplate.getDataSource().getConnection(),sql,"0002");
         return null;
     }
 }

　　　　使用该类应当注意：不能使用dbutils处理事务相关的问题，否则不能回滚！！

 package com.kdyzm.spring.jdbc.transaction1;

 import java.sql.SQLException;

 public interface UserService {
     public User updateUser(User user) throws SQLException;
 }

com.kdyzm.spring.jdbc.transaction1.UserService

 package com.kdyzm.spring.jdbc.transaction1;

 import java.sql.SQLException;

 public class UserServiceImpl implements UserService{
     private UserDao userDao;
     public UserDao getUserDao() {
         return userDao;
     }

     public void setUserDao(UserDao userDao) {
         this.userDao = userDao;
     }

     @Override
     public User updateUser(User user) throws SQLException {
         return userDao.updateUser(user);
     }

 }

com.kdyzm.spring.jdbc.transaction1.UserServiceImpl

　　使用的数据库连接池：c3p0，配置文件如下：

 <?xml version="1.0" encoding="UTF-8"?>
 <c3p0-config>
     <!-- 默认配置，只可以出现一次 -->
     <default-config>
         <!-- 连接超时设置30秒 -->
         <property name="checkoutTimeout">30000</property>
         <!-- 30秒检查一次connection的空闲 -->
         <property name="idleConnectionTestPeriod">30</property>
         <!--初始化的池大小 -->
         <property name="initialPoolSize">2</property>
         <!-- 最多的一个connection空闲时间 -->
         <property name="maxIdleTime">30</property>
         <!-- 最多可以有多少个连接connection -->
         <property name="maxPoolSize">10</property>
         <!-- 最少的池中有几个连接 -->
         <property name="minPoolSize">2</property>
         <!-- 批处理的语句-->
         <property name="maxStatements">50</property>
         <!-- 每次增长几个连接 -->
         <property name="acquireIncrement">3</property>
         <property name="driverClass">com.mysql.jdbc.Driver</property>
         <property name="jdbcUrl">
             <![CDATA[jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8]]>
         </property>
         <property name="user">root</property>
         <property name="password">5a6f38</property>
     </default-config> 

     <named-config name="namedconfig">
         <!-- 连接超时设置30秒 -->
         <property name="checkoutTimeout">30000</property>
         <!-- 30秒检查一次connection的空闲 -->
         <property name="idleConnectionTestPeriod">30</property>
         <!--初始化的池大小 -->
         <property name="initialPoolSize">2</property>
         <!-- 最多的一个connection空闲时间 -->
         <property name="maxIdleTime">30</property>
         <!-- 最多可以有多少个连接connection -->
         <property name="maxPoolSize">2</property>
         <!-- 最少的池中有几个连接 -->
         <property name="minPoolSize">2</property>
         <!-- 批处理的语句-->
         <property name="maxStatements">50</property>
         <!-- 每次增长几个连接 -->
         <property name="acquireIncrement">2</property>
         <property name="driverClass">com.mysql.jdbc.Driver</property>
         <property name="jdbcUrl">
             <![CDATA[jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8]]>
         </property>
         <property name="user">root</property>
         <property name="password">5a6f38</property>
     </named-config>
 </c3p0-config>

c3p0-config.xml

　　最后，最重要的com.kdyzm.spring.jdbc.transaction1.applicationContext.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-2.5.xsd
            http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-2.5.xsd
            http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-2.5.xsd
            http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-2.5.xsd
            ">
     <!-- 首先配置数据源 -->
     <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
         <constructor-arg index="0" value="namedconfig"></constructor-arg>
     </bean>
     <!-- 配置JdbcTemplate模板 -->
     <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
         <constructor-arg index="0">
             <ref bean="dataSource"/>
         </constructor-arg>
     </bean>
     <!-- 配置JDBC事务管理器 -->
<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
         <property name="dataSource">
             <ref bean="dataSource"/>
         </property>
     </bean>

     <!-- 配置通知 -->
 <tx:advice id="advice" transaction-manager="dataSourceTransactionManager">
         <tx:attributes >
             <tx:method name="update*" isolation="DEFAULT" propagation="REQUIRED" read-only="false"/>
         </tx:attributes>
     </tx:advice>

     <!-- 配置切入点 -->
     <aop:config>
         <!-- <aop:pointcut expression="execution(* com.kdyzm.spring.jdbc.transaction.*ServiceImpl.*(..))" id="perform"/> -->
         <aop:pointcut expression="execution(* com.kdyzm.spring.jdbc.transaction1.UserServiceImpl.updateUser(..))" id="perform"/>
 <aop:advisor advice-ref="advice" pointcut-ref="perform"/>
     </aop:config>

     <!-- 需要注意的是不需要配置切面，因为如果要配置切面的话就需要程序员完成（事务管理），
         这样spring就没有意义了 -->

     <!-- 程序员需要干的事情！ -->
     <!-- 需要纳入spring容器的 -->
     <bean id="userDao" class="com.kdyzm.spring.jdbc.transaction1.UserDaoImpl">
         <property name="jdbcTemplate" ref="jdbcTemplate"></property>
     </bean>
     <bean id="userService" class="com.kdyzm.spring.jdbc.transaction1.UserServiceImpl">
         <property name="userDao" ref="userDao"></property>
     </bean>
 </beans>

　　（4）测试

ApplicationContext context=new ClassPathXmlApplicationContext("com/kdyzm/spring/jdbc/transaction1/applicationContext.xml");
        UserService userService = (UserService) context.getBean("userService");
        User user=new User();
        userService.updateUser(user);

　　　　由于在UserDaoImpl.updateUser方法中存在/0的异常，所以方法会异常终止，但是spring会回滚方法中的事务。通过查看数据库中user的age字段可以得到结果。如果0001和0002并没有发生任何改变，则表示成功回滚；如果只有0001字段发生了自增长，则表示回滚失败。

　　6.小练习总结：

　　　　（1）事务的方法中不能使用dbutils工具，否则回滚失败！

　　　　（2）在service层控制事务，目标类是*ServiceImpl，目标方法是update方法。所以配置切入点表达式是：

　　　　　　　　<aop:pointcut expression="execution(* com.kdyzm.spring.jdbc.transaction1.UserServiceImpl.updateUser(..))" id="perform"/>

　　　　（3）事务管理器是Jdbc事务管理器，所以使用的类是DataSourceTransactionManager，创建对象的时候需要调用setDataSource方法传入DataSource参数。

<bean id="dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
        <property name="dataSource">
            <ref bean="dataSource"/>
        </property>
</bean>

　　　　（4）配置通知，需要制定事务管理器，这里的配置是一个模板，并不针对某个类中的方法，而是针对匹配到的所有方法：

<tx:advice id="advice" transaction-manager="dataSourceTransactionManager">
        <tx:attributes >
            <tx:method name="update*" isolation="DEFAULT" propagation="REQUIRED" read-only="false"/>
            <tx:method name="*" read-only="true" isolation="DEFAULT" propagation="REQUIRED"/>
        </tx:attributes>
</tx:advice>

　　　　　　* isolation：制定事务的隔离界别，使用default表示使用数据库制定的隔离级别，spring不再另外指定。

　　　　　　* propagation：指定事务的传播属性，默认是REQUIRED，表示如果当前方法已经在一个事务中运行则加入该事务，否则创建一个新事务。