文档章节

Spring学习笔记十六---事务

jimyao
 jimyao
发布于 2016/03/13 00:10
字数 571
阅读 45
收藏 2

Spring事务
ACID
原子性
一致性
隔离性
持久性


编程式/声明式
Spring事务管理抽象是PlatformTransactionManager
JDBC: DataSourceTransactionManager
JTA: JtaTransactionManager
Hibernate: HibernateTransactionManager


事务管理器以Bean形式声明在Spring IOC容器中



事务管理器


database: spring


create table book(
isbn varchar(50) primary key,
book_name varchar(50),
price int
);


create table account (
username varchar(50) primary key,
balance int,
check(balance >0 )
);



create table book_stock(
isbn varchar(50) primary key,
stock int
check(stock >0)
);


insert into book values(1001, 'java', 100);
insert into book values(1002, 'oracle', 70);
commit;


insert into account values('AA', 160);
commit;


insert into book_stock values(1001, 4);
insert into book_stock values(1002, 8);
commit;

package springjdbc.tx;

public interface IBookShopDao {
    //根据isbn查找价格
    public int findBookPriceByIsbn(String isbn);

    //根据isbn更新库存-1
    public void updateBookStock(String isbn);

    //更新账号余额,balance - price
    public void updateUserAccount(String userName, String price);
}
package springjdbc.tx;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.stereotype.Repository;

@Repository("bookShopDao")
public class BookShopDaoImple implements IBookShopDao {

    @Autowired
    private JdbcTemplate jdbcTemplate;

    @Override
    public int findBookPriceByIsbn(String isbn) {
        String sql = "SELECT price FROM book WHERE isbn = ?";

        return jdbcTemplate.queryForObject(sql, Integer.class, isbn);
    }

    @Override
    public void updateBookStock(String isbn) {
        String sql2 = "SELECT stock FROM book_stock WHERE isbn = ?";
        int stock = jdbcTemplate.queryForObject(sql2, Integer.class, isbn);
        if (stock == 0) {
            throw new BookStockException("库存不足");
        }
        //检查书的库存,如果不够抛出异常
        String sql = "UPDATE book_stock SET stock = stock -1 WHERE isbn = ?";
        jdbcTemplate.update(sql,isbn);

    }

    @Override
    public void updateUserAccount(String userName, String price) {
        String sql2 = "SELECT balance FROM account WHERE username = ?";
        int balance  = jdbcTemplate.queryForObject(sql2, Integer.class, userName);
        if (balance < Integer.valueOf(price)) {
            throw new UserAccountException("余额不足");
        }
        String sql = "UPDATE account SET balance = balance - ? WHERE userName = ?";
        jdbcTemplate.update(sql, price, userName);
    }
}
package springjdbc.tx;

public interface IBookShopService {
    public void purchase(String userName, String isbn);

}
package springjdbc.tx;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service("bookShopService")
public class BookShopServiceImpl implements IBookShopService {
    @Autowired
    private IBookShopDao iBookShopDao;

    @Override
    public void purchase(String userName, String isbn) {
        //get book price
        iBookShopDao.findBookPriceByIsbn(isbn);

        //update book stock
        iBookShopDao.updateBookStock(isbn);

        //update user account
        iBookShopDao.updateUserAccount(userName, isbn);

    }
}
package springjdbc.tx;

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

public class TestTx {
    private ApplicationContext ctx = null;

    private IBookShopDao iBookShopDao;
    private IBookShopService bookShopService;
    {
        ctx = new ClassPathXmlApplicationContext("springjdbc/application.xml");
        iBookShopDao = ctx.getBean(IBookShopDao.class);
        bookShopService = ctx.getBean(IBookShopService.class);
    }

    @Test
    public void testBookShopService() {
        bookShopService.purchase("AA", "100");
    }

    @Test
    public void testBookShopDaoFindPriceByIsbn() {
        System.out.println(iBookShopDao.findBookPriceByIsbn("1001"));
    }

    @Test
    public void testBookShopDaoUpdateBookStock() {

        iBookShopDao.updateBookStock("1001");
    }

    @Test
    public void testBookShopDaoUserAccount() {
        iBookShopDao.updateUserAccount("AA","1000" );
    }
}
<?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"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd">

    <context:component-scan base-package="springjdbc"></context:component-scan>
    <!-- import resource files -->
    <context:property-placeholder location="classpath:springjdbc/db.properties"></context:property-placeholder>

    <!-- C3P0 DataSource -->
    <bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
        <property name="user" value="${jdbc.user}"/>
        <property name="password" value="${jdbc.password}"/>
        <property name="jdbcUrl" value="${jdbc.jdbcUrl}"/>
        <property name="driverClass" value="${jdbc.driverClass}"/>
        <property name="initialPoolSize" value="${jdbc.initPoolSize}"/>
        <property name="maxPoolSize" value="${jdbc.maxPoolSize}"/>
    </bean>

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

    <!-- 具名参数 -->
    <bean id="namedParameterJdbcTemplate" class="org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate">
        <constructor-arg ref="dataSource"/>
    </bean>
</beans>


© 著作权归作者所有

jimyao
粉丝 17
博文 66
码字总数 27856
作品 0
朝阳
私信 提问
Spring Boot学习笔记

多模块开发 [SpringBoot学习]-IDEA创建Gradle多Module结构的SpringBoot项目 RabbitMQ RabbitMQ 安装 linux安装RabbitMQ详细教程 Ubuntu 16.04 RabbitMq 安装与运行(安装篇) ubantu安装...

OSC_fly
2018/07/26
0
0
MyBatis学习笔记系列教程

【MyBatis学习笔记】系列之预备篇一:ant的下载与安装 【MyBatis学习笔记】系列之预备篇二:ant入门示例 【MyBatis学习笔记】系列之一:MyBatis入门示例 【MyBatis学习笔记】系列之二:MyBat...

HenrySun
2016/10/15
153
0
8月30日云栖精选夜读 | 谈谈“野生”Java程序员学习的道路!

一、引言 其实本来真的没打算写这篇文章,主要是LZ得记忆力不是很好,不像一些记忆力强的人,面试完以后,几乎能把自己和面试官的对话都给记下来。LZ自己当初面试完以后,除了记住一些聊过的...

yq传送门
2018/08/30
0
0
Spring Transaction + MyBatis SqlSession事务管理机制研究学习

原文地址:Spring Transaction + MyBatis SqlSession事务管理机制研究学习 线上的系统中,使用的是Spring+Mybatis+Mysql搭建的框架,由于客户需要,最近一直在对性能提升部分进行考虑,主要是...

Realfighter
2015/01/10
25K
1
day35_Spring学习笔记_03

一、事务管理 1.1、回顾事务 事务:一组业务操作ABCD,要么全部成功,要么全部不成功。 特性:ACID 原子性:整体 一致性:完成 隔离性:并发 持久性:结果 隔离问题: 脏读:一个事务读到另一...

黑泽明军
2018/08/08
0
0

没有更多内容

加载失败,请刷新页面

加载更多

JS实现使用Math.random()函数生成n到m间的随机数字

Math.random()函数返回0和1之间的伪随机数,可能为0,但总是小于1,[0,1) 生成n-m,包含n但不包含m的整数: 第一步算出 m-n的值,假设等于w 第二步Math.random()*w 第三步Math.random()*w+n...

张兴华ZHero
29分钟前
4
0
入门了解Service Mesh + Istio?从本文开始

下周六,深圳,阔别已久的线下技术沙龙要和你见面啦! 现场有Rancher Labs研发经理demo刚刚发布的Rancher 2.3中的Istio、Windows容器、集群模板等功能及使用,还有k3s首次线下workshop,由R...

RancherLabs
30分钟前
6
0
Gradle 发布 Jar 到 Archiva 时提示不能 Overwriting released artifacts is not allowed

系统提示错误信息: Received status code 409 from server: Overwriting released artifacts is not allowed. 这是在 Archiva 默认的配置下如果你不是使用 snapshot 配置的话,是不允许对仓...

honeymoose
31分钟前
5
0
二维码插件之qrcode.min.js

文件链接百度云地址 https://pan.baidu.com/s/1nWiBuT4Z7WOAMoUEFL8PZg 入门 http://www.jq22.com/jquery-info294 使用jquery.qrcode.min.js实现前台二维码生成(带Logo) https://blog.csd......

木九天
41分钟前
4
0
开源 java CMS - FreeCMS2.8 自定义标签 commentPage

项目地址:http://www.freeteam.cn/ commentPage 根据参数提取评论对象。 参数 说明 siteid 站点id objtype 评论对象类型 objid 评论对象id membername 会员名称 isanonymous 是否匿名 1是 ...

freeteam
41分钟前
4
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部