文档章节

数据库开发 - 事务单元作业

抢小孩糖吃
 抢小孩糖吃
发布于 2016/10/08 23:12
字数 646
阅读 24
收藏 0
点赞 0
评论 0

#问题 1(100分)有一个在线交易电商平台,有两张表,分别是库存表和订单表,如下:

输入图片说明

现在买家XiaoMing在该平台购买bag一个,需要同时在库存表中对bag库存记录减一,同时在订单表中生成该订单的相关记录。 请编写Java程序,实现XiaoMing购买bag逻辑。订单表ID字段为自增字段,无需赋值。

#解答 ##购买事务逻辑 XiaoMing购买bag一个,首先检查是否还有剩余库存,如果有库存,则进行购买,如果没有库存,返回没有库存异常。当有库存时,对库存表中的记录减一,并生成订单记录。 ##事务与锁的分析 这里必须进行加锁,不然会发生各种问题,通过查阅相关资料,确定悲观锁,是相对稳健的形式。 ##初始化数据库 homework.sql

CREATE TABLE `inventory` (
`ID`  int NOT NULL AUTO_INCREMENT ,
`ProductName`  varchar(100) NULL ,
`Inventory`  int NULL ,
PRIMARY KEY (`Id`)
);

INSERT INTO `inventory` (`ID`, `ProductName`, `Inventory`) VALUES ('1', 'watch', '25');
INSERT INTO `inventory` (`ID`, `ProductName`, `Inventory`) VALUES ('2', 'bag', '20');

CREATE TABLE `order` (
`ID`  int NOT NULL AUTO_INCREMENT ,
`buyer`  varchar(100) NULL ,
`ProductName` varchar(100) NULL ,
PRIMARY KEY (`Id`)
);

##执行测试类

package com.hava.transition;

import junit.framework.TestCase;

/**
 * Created by zhanpeng on 2016/10/8.
 */
public class OrderDAOTest extends TestCase {
    public void testTransferAccount() throws Exception {
        OrderDAO orderDAO = new OrderDAO();
        orderDAO.init();
        orderDAO.buyOne("XiaoMing","bag");
    }
}

##数据库访问类

package com.hava.transition;

import org.apache.commons.dbcp2.BasicDataSource;

import java.sql.*;

/**
 * Created by zhanpeng on 2016/10/8.
 */
public class OrderDAO {

    public static BasicDataSource basicDataSource = null;

    public final static String JDBC_DRIVER = "com.mysql.jdbc.Driver";
    public final static String DB_URL = "jdbc:mysql://192.168.1.200/test";
    public final static String USER = "root";
    public final static String PASSWORD = "dVHJtG0T:pf*";

    public void init()
    {
        basicDataSource = new BasicDataSource();
        basicDataSource.setUrl(DB_URL);
        basicDataSource.setDriverClassName(JDBC_DRIVER);
        basicDataSource.setUsername(USER);
        basicDataSource.setPassword(PASSWORD);
    }

    public void buyOne(String buyer,String productName) throws ClassNotFoundException {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {
            connection = basicDataSource.getConnection();
            //开启事务
            connection.setAutoCommit(false);
            //使用悲观锁
            String getproduct_sql = "SELECT Inventory FROM inventory WHERE(ProductName = ?) FOR UPDATE";
            preparedStatement = connection.prepareStatement(getproduct_sql);
            preparedStatement.setString(1,productName);
            resultSet = preparedStatement.executeQuery();
            int inventory = -1;
            while(resultSet.next())
                inventory = resultSet.getInt("Inventory");

            System.out.println("[inventory]:" + inventory);

            if(inventory <= 0)
            {
                System.out.println("没有库存");
                throw new SQLException();
            }
            else
            {
                //减少库存
                String subproduct_sql = "UPDATE inventory SET Inventory=? WHERE (ProductName = ?)";
                preparedStatement = connection.prepareStatement(subproduct_sql);
                preparedStatement.setInt(1,inventory - 1);
                preparedStatement.setString(2,productName);
                preparedStatement.execute();

                //新增订单
                String addorder_sql = "INSERT INTO `order` (`buyer`, `ProductName`) VALUES (?, ?)";
                preparedStatement = connection.prepareStatement(addorder_sql);
                preparedStatement.setString(1,buyer);
                preparedStatement.setString(2,productName);
                preparedStatement.execute();

                //提交事务
                connection.commit();
            }




        } catch (SQLException e) {
            // ignore
            System.out.println("[SQLException]:" + e.toString());
            //如果发生异常则回滚事务
            if(connection != null)
                try {
                    //发生异常回滚
                    connection.rollback();

                } catch (SQLException e1) {
                    e1.printStackTrace();
                }
        } finally {
            if (preparedStatement != null)
            {
                try {
                    preparedStatement.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }

            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
    }
}

#参考文献 mysql处理高并发,防止库存超卖
电商 对于特定数量的商品 如何在高并发下进行库存锁定呢?
订单系统中并发问题和锁机制的探讨
企业应用架构模式

© 著作权归作者所有

共有 人打赏支持
抢小孩糖吃

抢小孩糖吃

粉丝 67
博文 200
码字总数 223760
作品 0
东城
程序员
数据库中间件 Sharding-JDBC 源码分析 —— 事务(一)之BED

摘要: 原创出处 www.iocoder.cn/Sharding-JD… 「芋道源码」欢迎转载,保留摘要,谢谢! 本文主要基于 Sharding-JDBC 1.5.0 正式版 1. 概述 2. 最大努力送达型 3. 柔性事务管理器 3.1 概念 ...

芋道源码掘金Java群217878901 ⋅ 2017/11/05 ⋅ 0

大数据批处理框架 Spring Batch全面解析

如今微服务架构讨论的如火如荼。但在企业架构里除了大量的OLTP交易外,还存在海量的批处理交易。在诸如银行的金融机构中,每天有3-4万笔的批处理作业需要处理。针对OLTP,业界有大量的开源框...

huojiao2006 ⋅ 2017/01/09 ⋅ 0

SQL Server事务日志传送

原创作品,允许转载,转载时请务必以超链接形式标明文章 原始出处 、作者信息和本声明。否则将追究法律责任。http://jimshu.blog.51cto.com/3171847/590413 SQL Server 2012 日志传送 一、准...

DanEcho ⋅ 2016/08/09 ⋅ 0

J2EE快速应用开发平台 工作流平台 数据交换 和 规则引擎 代码生成

GAP全称是UFIDA Software Engineering Global Application Platform,是用友工程软件(现瑞友科技)集多年开发实施经验所提炼的J2EE快速应用构件化开发平台。它不仅是一套快速开发应用软件的...

孙义山 ⋅ 2012/01/12 ⋅ 0

业务层架构模式

一:业务层架构模式概述 在三层架构中,业务层负责所有业务相关的工作,包括根据输入数据或已有数据进行计算,对从表示层输入的数据进行验证,以及根据从表示层接收的命令来确定应该调用哪些...

陈嘻嘻哈哈 ⋅ 2015/07/22 ⋅ 0

详解Oracle后台进程

后台进程 为了实现为多用户提供服务且保证系统性能,在一个多进程 Oracle 系统(multiprocess Oracle system)中,存在多个被称为后台进程(background process)的 Oracle 进程。 一个 Orac...

青夜之衫 ⋅ 2017/12/06 ⋅ 0

浅谈数据库的 ACID 与 隔离级别

在谈论数据库的时候,我们总是希望它的查询性能更快一些,并行事务更多一些,然而在另一方面,却也在担忧数据同步、脏读、延迟带来的数据混乱。。。 什么是事务的 ACID Atomicity (原子性)...

longjuelegend ⋅ 2016/08/19 ⋅ 0

【转】事务策略: 了解事务陷阱

前沿(笔者加):事务(Transaction)是每一个与数据库有关的系统开发与设计人员都会接触到的东西,在Java中,传统的直接使用JDBC的事务开始、提交、回滚的方式已经随着各种应用开发框架(尤...

晨曦之光 ⋅ 2012/03/09 ⋅ 0

介绍事务与分布式事务原理与实践、事务在Java程序中的应用

一、事务 1、事务的简介 事务的本质核心就是锁和并发。 事务只是让传统意义上难以理解的事情用一种更容易让大家理解的方式来表述的方法。事务比传统意义的锁和并发更容易让大家理解。 2、单个...

AAASSSSddd ⋅ 2016/11/13 ⋅ 0

Apache Ignite(七):基于Ignite的企业级分布式并行计算

[TOC] 1.传统的方案 在各行各业中,批量业务处理都是常规需求,非常常见。它的特点是,离线处理、运行时间长、计算密集。传统的解决方式是,或者使用多线程技术,或者使用数据库计算,比如调...

李玉珏 ⋅ 2016/05/04 ⋅ 11

没有更多内容

加载失败,请刷新页面

加载更多

下一页

从零开始搭建Risc-v Rocket环境---(1)

为了搭建Rocke环境,我买了一个2T的移动硬盘,安装的ubuntu-16.04 LTS版。没有java8,gcc是5.4.0 joe@joe-Inspiron-7460:~$ java -version程序 'java' 已包含在下列软件包中: * default-...

whoisliang ⋅ 29分钟前 ⋅ 0

大数据学习路线(自己制定的,从零开始学习大数据)

大数据已经火了很久了,一直想了解它学习它结果没时间,过年后终于有时间了,了解了一些资料,结合我自己的情况,初步整理了一个学习路线,有问题的希望大神指点。 学习路线 Linux(shell,高并...

董黎明 ⋅ 35分钟前 ⋅ 0

systemd编写服务

一、开机启动 对于那些支持 Systemd 的软件,安装的时候,会自动在/usr/lib/systemd/system目录添加一个配置文件。 如果你想让该软件开机启动,就执行下面的命令(以httpd.service为例)。 ...

勇敢的飞石 ⋅ 38分钟前 ⋅ 0

mysql 基本sql

CREATE TABLE `BBB_build_info` ( `community_id` varchar(50) NOT NULL COMMENT '小区ID', `layer` int(11) NOT NULL COMMENT '地址层数', `id` int(11) NOT NULL COMMENT '地址id', `full_......

zaolonglei ⋅ 46分钟前 ⋅ 0

安装chrome的vue插件

参看文档:https://www.cnblogs.com/yulingjia/p/7904138.html

xiaoge2016 ⋅ 49分钟前 ⋅ 0

用SQL命令查看Mysql数据库大小

要想知道每个数据库的大小的话,步骤如下: 1、进入information_schema 数据库(存放了其他的数据库的信息) use information_schema; 2、查询所有数据的大小: select concat(round(sum(da...

源哥L ⋅ 今天 ⋅ 0

两个小实验简单介绍@Scope("prototype")

实验一 首先有如下代码(其中@RestController的作用相当于@Controller+@Responsebody,可忽略) @RestController//@Scope("prototype")public class TestController { @RequestMap...

kalnkaya ⋅ 今天 ⋅ 0

php-fpm的pool&php-fpm慢执行日志&open_basedir&php-fpm进程管理

12.21 php-fpm的pool pool是PHP-fpm的资源池,如果多个站点共用一个pool,则可能造成资源池中的资源耗尽,最终访问网站时出现502。 为了解决上述问题,我们可以配置多个pool,不同的站点使用...

影夜Linux ⋅ 今天 ⋅ 0

微服务 WildFly Swarm 管理

Expose Application Metrics and Information 要公开关于我们的微服务的有用信息,我们需要做的就是将监视器模块添加到我们的pom.xml中: 这将使在管理和监视功能得到实现。从监控角度来看,...

woshixin ⋅ 今天 ⋅ 0

java连接 mongo伪集群部署遇到的坑

部署mongo伪集群 #创建mongo数据存放文件地址mkdir -p /usr/local/config1/datamkdir -p /usr/local/config2/data mkdir -p /usr/local/config3/data mkdir -p /usr/local/config1/l......

努力爬坑人 ⋅ 今天 ⋅ 0

没有更多内容

加载失败,请刷新页面

加载更多

下一页

返回顶部
顶部