spring JDBC事务管理

 

一直想学习怎么使用spring 的事务，在网上查了很多资料，还是不知道怎么写，大都是基于注解方式的，要么就是基于hibernate的事务，而且没有完整的例子，都是代码片段，这里我自己写了一个简单的demo，供给大家学习

 

1、建立一个对象（跟数据库中的表对应）

 

package hb.bean;

public class Book {
    private int id;
    private String name;
    private String author;
    private int num;

    public int getNum() {
        return num;
    }

    public void setNum(int num) {
        this.num = num;
    }

    public int getId() {
        return id;
    }

    public void setId(int id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public String getAuthor() {
        return author;
    }

    public void setAuthor(String author) {
        this.author = author;
    }
}

 

 2、建立一个接口（实现对表的相关操作）

 

package hb.dao;

import hb.bean.Book;
import java.util.List;
import org.springframework.transaction.annotation.Transactional;

@Transactional
public interface BookDAO {

    //查看book表中的所有数据
    public List listBook();

    //向book表中插入一条数据
    public void insertBook(Book book);
}

 

 3、实现接口的操作

 

package hb.dao.imp;

import hb.bean.Book;
import hb.dao.BookDAO;
import hb.row.UserRowMapper;

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;

import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.core.support.JdbcDaoSupport;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.transaction.TransactionStatus;
import org.springframework.transaction.annotation.Transactional;
import org.springframework.transaction.support.TransactionCallbackWithoutResult;
import org.springframework.transaction.support.TransactionTemplate;

import sun.jdbc.odbc.ee.DataSource;

@Transactional
public class BookDAOImpl extends JdbcDaoSupport implements BookDAO {

    public DataSourceTransactionManager transactionManager;

    public void setTransactionManager(DataSourceTransactionManager transactionManager) {
        this.transactionManager = transactionManager;
    }

    @SuppressWarnings("unchecked")
    public List listBook() {
        String sql = "select * from book";
        //JdbcDaoSupport里面有jdbcTemplate这个对象的set方法.JdbcTemplate这个类需要配置数据源
        List list = this.getJdbcTemplate().query(sql, new UserRowMapper());
        return list;
    }

    public void insertBook(final Book book) {
        final String sql = "insert into book(id,name,author,num)values(?,?,?,?)";
        TransactionTemplate transactionTemplate = new TransactionTemplate(transactionManager);
        final JdbcTemplate jdbcTemplate = this.getJdbcTemplate();
        transactionTemplate.execute(new TransactionCallbackWithoutResult(){
            @Override
            protected void doInTransactionWithoutResult(TransactionStatus arg0) {
                Object[] params = new Object[] {book.getId(), book.getName(), book.getAuthor(),book.getNum() };
                //下面的语句是用来测试事务异常的情况
//                new Integer("huangbiao");
                jdbcTemplate.update(sql, params);
            }
        });

    }

}

 

 4、继承RowMapper 接口接受返回过来的结果集

 

package hb.row;

import hb.bean.Book;

import java.sql.ResultSet;
import java.sql.SQLException;

import org.springframework.jdbc.core.RowMapper;

public class UserRowMapper implements RowMapper {

    public Object mapRow(ResultSet rs,int index) throws SQLException {
        Book book = new Book();
        System.out.println(rs.getString("name"));
        book.setName(rs.getString("name"));
        return book;
    }
}

 

5、相关的配置信息

 

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

        <!--  配置数据源   -->
        <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource">
          <property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>
          <property name="url" value="jdbc:oracle:thin:@127.0.0.1:1521:orcl" />
          <property name="username" value="huangbiao"/>
          <property name="password" value="huangbiao"/>

          <!-- 连接池启动时的初始值   -->
          <property name="initialSize" value="1" />
          <!-- 连接池的最大值  -->
          <property name="maxActive" value="500"/>
          <!-- 最大空闲值，当经过一个高峰时间后，连接池可以慢慢将已经用不到的连接释放，一直减少到msxIdle为止  -->
          <property name="maxIdle" value="2" />
          <!-- 最小空闲值，当空闲的连接数小于阀值时，连接池就会预申请一些连接，以免洪峰到来时来不及申请  -->
          <property name="minIdle" value="1" />
        </bean>

        <!-- 配置事务管理器 -->
        <bean id="txManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
          <property name="dataSource" ref="dataSource"/>
        </bean>

        <!-- 采用@Transactional注解方式使用事务   -->
        <tx:annotation-driven transaction-manager="txManager"/>

        <bean id="bookDao" class="hb.dao.imp.BookDAOImpl" >
        <!-- 因为继承了JdbcDaoSupport类，该类需要注入 JdbcTemplate类对象 -->
            <property name="jdbcTemplate" ref="jdbcTemplate"></property>
            <property name="transactionManager" ref="transactionManager"></property>
        </bean>


        <!-- jdbcTemplate需要配置dataSource，因为里面有一个set方法，所以注入给它 -->
        <bean id="jdbcTemplate" class="org.springframework.jdbc.core.JdbcTemplate">
            <property name="dataSource" ref="dataSource"></property>
        </bean>

        <!-- 事务处理类，该类用于管理事务，里面有set方法注入数据源 -->
        <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
            <property name="dataSource" ref="dataSource" />
        </bean>

</beans>

 

6、写一个测试类（使用JUnint）

 

package hb.test;

import hb.bean.Book;
import hb.dao.BookDAO;

import java.util.Iterator;
import java.util.List;


import org.junit.BeforeClass;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import org.springframework.context.support.FileSystemXmlApplicationContext;
import org.springframework.jdbc.core.JdbcTemplate;

public class SpringTest {

    private BookDAO bookDao;

    @BeforeClass
    public static void setUpBeforeClass() throws Exception {

    }

    @SuppressWarnings("unchecked")
    @Test
    //执行查询的方式
    public void doQueryTest(){
        try{
            ApplicationContext ctx = new FileSystemXmlApplicationContext("applicationContext.xml");
            bookDao = (BookDAO) ctx.getBean("bookDao");
            List list = bookDao.listBook();
            Iterator iter = list.iterator();
            while(iter.hasNext()){
                Book book = (Book)iter.next();
                System.out.println(book.getName());
            }
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Test
    public void doInsertTest(){
        Book book = new Book();
        book.setAuthor("huangbiao");
        book.setId(90);
        book.setName("hb");
        book.setNum(44);
        try{
            ApplicationContext ctx = new FileSystemXmlApplicationContext("applicationContext.xml");
            bookDao = (BookDAO) ctx.getBean("bookDao");
            bookDao.insertBook(book);
        }
        catch (Exception e) {
            e.printStackTrace();
        }

    }
}