一直想学习怎么使用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();
- }
- }
- }
相关推荐
实例详解Spring JDBC事务管理.doc 实例详解Spring JDBC事务管理.doc
两个项目,一个项目是基于spring jdbc实现的分布式事务,一个是基于spring hibernate的分布式事务,hibernate项目里的applicationContext2.xml是基于mysql和mssql, applicationContext3.xml基于两个mssql, ...
javaEE 实验三 Spring JDBC与事务管理, 一、实验目的 1、掌握Spring JDBC的配置; 2、掌握JdbcTemplae类中增删改查方法的使用; 3、了解Spring事务管理的3个核心接口; 4、了解Spring事务管理的两种方式; 5、掌握...
3、了解Spring事务管理的3个核心接口; 4、了解Spring事务管理的两种方式; 5、掌握基于XML和Annotation的声明式事务管理的使用。 二、 实验内容 1、在MySQL中创建以下三张表,其中account为账户表,book为书籍信息...
1、掌握Spring JDBC的配置; 2、掌握JdbcTemplae类中增删改查方法的使用;...3、了解Spring事务管理的3个核心接口; 4、了解Spring事务管理的两种方式; 5、掌握基于XML和Annotation的声明式事务管理的使用。
SpringJDBC注解事务.zip,SpringJDBC注解事务.zip
基于Spring JDBC的事务管理
spring声明式事务管理+jdbc+连接池 包内为代码,下载可直接执行。 一直用s2sh,感觉hibernate不好用,所以写了一个spring声明式事务管理+jdbc+连接池。
spring声明式事务管理+jdbc+连接池.zip
NULL 博文链接:https://kreding.iteye.com/blog/1680855
Spring集成的jdbc编码和事务管理
NULL 博文链接:https://zouhuiying.iteye.com/blog/2280681
Spring2.5+MySQL实现的JDBC操作(包括编程式事务的代码),如果有看不懂的地方可以去本人的博客:http://blog.csdn.net/Acceptedxukai,里面有具体讲解。
Spring JDBC Spring的JDBC模块负责数据库资源管理和错误处理,大大简化了开发人员对数据库的操作,使得开发人员可以从繁琐的数据库操作中解脱出来,从而将更多的精力投入到编写业务逻辑当中。 Spring JdbcTemplate...
Spring aop、jdbc和事务tx的学习,里面包含了三种的练习,都在不同的包内。
spring-jdbc.rar源码 学习分析用,了解jdbc内部原理,connection事务关系很有用
Spring JDBC应用实例讲解 ,具体效果和过程看博文 http://blog.csdn.net/evankaka/article/details/45477185
jdbc+spring+mysql事务理解和分析
注意:只是jdbc自带的jdbctample,不能 用于整合mybatis框架的事务,我整合了,事务不起作用!!!! 按老师的说法是基于xml方式,但不准确,因为也用到了注解 <aop:aspectj-autoproxy proxy-target-class="true">...