java实现自动售货机

JAVA基础练手项目—自动售货机,供大家参考,具体内容如下

要求:

简易售货机

流程:

【投币】—>【显示货物清单】—>【选择一个商品编号购买】—>【提示出货】—>【找钱】

功能要求:

1. 使用mysql数据库,将所有货物存储在数据库中(货物应至少具有编号、名称、数量、价格等基本信息,可自行增加其他属性以完善程序)。
2. 要有友好的客户提示,例如:请输入购买商品的编号。
3. 清单要求包含每种商品的剩余数量。
4. 出货后,可以选择【找钱】,也可以选择【继续购买】,而不直接找钱

以下为解题思路及答案(略过数据库建表操作):

1、首先要先将JDBC链接包加入路径,这一步在之前的博客中已经讲过,这里就直接略过了。然后就是在代码中将驱动器打开:

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class DBUtil {

    //定义JDBC包导入路径
    private String dbDriver = "com.mysql.jdbc.Driver";
    //连接要操作的数据库
    private String url = "jdbc:mysql://localhost:3306/database";
    //数据库用户名
    private String user = "root";
    //数据库密码
    private String password = "123456";

    /**打开JDBC驱动器
     * 如果打开不成功,要抛出异常
     * @return
     * @throws Exception
     */
    public Connection getDBConn() throws Exception{

        try {
            Class.forName(dbDriver);
            return DriverManager.getConnection(url, user, password);
        } catch (ClassNotFoundException e) {
            throw new ClassNotFoundException("数据库驱动不存在!!");
        } catch (SQLException e) {
            throw new SQLException("数据库连接异常!");
        }
    }

    /**
     * 关闭Connection,
     * 如果关闭不成功要抛出异常
     */
    public void close(Connection conn){

        try {
            if(conn != null){
                conn.close();
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

    /**
     * 关闭Statement,
     * 如果关闭不成功要抛出异常
     */
    public void close(Statement stat){

        try {
            if(stat != null){
                stat.close();
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

    /**
     * 关闭ResultSet,
     * 如果关闭不成功要抛出异常
     */
    public void close(ResultSet rs){

        try {
            if(rs != null){
                rs.close();
            }
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }

}

2、操作完JDBC之后,新建一个类,用来定义自动售货机具有的各个属性及方法:

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Scanner;

public class SimpleVendingMachine {

    //实例化JDBC连接和输入方法
    DBUtil dbu = new DBUtil();
    Scanner scanner = new Scanner(System.in);

    //定义Connection,Statement和ResultSet
    Connection conn = null;
    Statement stat = null;
    ResultSet rs = null;

    //定义投入的金币和余额
    private double money;
    private static double balance = 0;  

    //投入金钱
    public void slot(double money){
        this.money = money;
    }

    //显示当前商品的信息
    public void displayAllGoods(){

        //结果集封装
        ArrayList<String[]> rsList = new ArrayList<String[]>(); 

        String[] strTemp = null;

        //sql显示操作
        String sql = "SELECT `Code`, `Name`, Number, Price FROM goods";

        try {
            //驱动器加载
            conn = dbu.getDBConn();
            stat = conn.createStatement();
            rs = stat.executeQuery(sql);

            ResultSetMetaData rsmd = rs.getMetaData();

            int columnCount = rsmd.getColumnCount();

            String[] columnNames = new String[columnCount];

            for(int i = 0 ; i < columnNames.length ; i++){
                columnNames[i] = rsmd.getColumnName(i + 1);
            }

            rsList.add(columnNames);

            //遍历赋值
            while(rs.next()){

                strTemp = new String[columnCount];

                for(int i = 0 ; i < columnNames.length ; i ++){
                    strTemp[i] = rs.getString(columnNames[i]);
                }
                rsList.add(strTemp);    
            }

            //遍历输出
            for(String[] datas : rsList){
                for(String data : datas){
                    System.out.print(data + "\t");
                }
                System.out.println();
            }

        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            //关闭连接
            dbu.close(rs);
            dbu.close(stat);
            dbu.close(conn);
        }
    }

    //进行购买
    public void buyByCode(){

        System.out.println("请输入您想购买的商品编号:");
        int code = scanner.nextInt();

        //如果购买成功,则商品数量减一,该商品销售所得金额增加自身价格
        String sql = "update Goods set Number = Number - 1, Gain = Gain + Price where Code = " + code;

        try {
            //驱动器加载
            conn = dbu.getDBConn();

            //手动提交
            //conn.setAutoCommit(false);

            stat = conn.createStatement();
            //操作影响行数
            int affectedRows = stat.executeUpdate(sql);

            //检查余额是否足够
            if(checkMoney(code, stat, this.money)){

                if(affectedRows > 0){
                    System.out.println("购买成功!");

                    //操作成功则手动提交
                    //conn.commit();

                    //后续操作:找零或继续购买
                    this.proceed();
                }
            }else{
                System.out.println("金额不足!");

                //回到驱动器加载的位置
                //conn.rollback();
            }

        } catch (ClassNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (SQLException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        } catch (Exception e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            dbu.close(rs);
            dbu.close(stat);
            dbu.close(conn);
        }
    }

    //检查投入金额是否足够购买商品
    public boolean checkMoney(int code, Statement stat, double money){

        ResultSet rs = null;

        try {
            rs = stat.executeQuery("select Price from goods where Code  = " + code);

            while(rs.next()){
                //对余额进行更改
                SimpleVendingMachine.balance = money - rs.getDouble("Price");

                if(SimpleVendingMachine.balance >= 0){
                    return true;
                }else{
                    return false; 
                }
            }

        } catch (SQLException e) {
            e.printStackTrace();
        }
        return false;
    }

    //定义后续操作
    public void proceed(){
        System.out.println("请选择找零(0)或继续购买(1):");
        int n = scanner.nextInt();

        switch(n){
            case 0:
                System.out.println("剩余零钱:" + SimpleVendingMachine.balance + "已退回!");
                break;
            case 1:
                this.money = SimpleVendingMachine.balance;
                buyByCode();
                break;
        }
    }
}

3 . 之后定义售货机服务菜单,让用户进行投币、购买及后续操作:

import java.util.Scanner;

public class SVMService {

    SimpleVendingMachine svm = new SimpleVendingMachine();
    Scanner scanner = new Scanner(System.in);

    public void service(){

        //显示所有商品
        svm.displayAllGoods();
        System.out.println("---------------------------");

        //投入金额准备购买商品
        System.out.println("请输入您要投入的金额:");
        svm.slot(scanner.nextDouble());

        svm.buyByCode();

    }

}

4、最后就是在主方法中将SVMService 实例化并进行调用:

public class Demo {
    public static void main(String[] args) {
        SVMService svms = new SVMService();
        svms.service();
    }
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持我们。

(0)

相关推荐

  • Java多线程之火车售票系统

    Java多线程之火车售票(Thread和Runnable的区别) java中实现多线程的方式有两种 继承Thread类 实现Runnable接口 继承了Thread类的类,使用对象.start()启动线程 实现了Runnable类的类,使用new Thread(new Runnable的实现类()).start()启动 下面有个经典例子,很适合用实现Runnable接口的类去实现. 火车售票问题简单分析: 1.票数是共用的,不能将一张票买多次.  2.同时有多个售票点在出售车票,即有多个线程存在

  • Java多线程模拟售票程序和线程安全问题

    Java中线程部分知识中,售票程序非常经典.程序中也有一些问题存在! 需求:模拟3个窗口同时在售100张票. 问题1:为什么100张票被卖出了300张票? 原因:因为tickets是非静态的,非静态的成员变量数据是在每个对象中都会维护一份数据的,三个线程对象就会有三份. 解决方案:把tickets票数共享出来给三个线程对象使用.使用static修饰. 问题2: 出现了线程安全问题 ? 线程安全问题的解决方案:sun提供了线程同步机制让我们解决这类问题的. java线程同步机制的方式: 方式一:同

  • java多线程模拟实现售票功能

    铁道部发布了一个售票任务,要求销售1000张票,要求有3个窗口来进行销售,请编写多线程程序来模拟这个效果. 1 线程类 测试方法: public static void main(String[] args) { MyThread t1 = new MyThread("窗口1"); MyThread t2 = new MyThread("窗口1"); MyThread t3 = new MyThread("窗口1"); t1.start(); t

  • Java多线程之简单模拟售票功能

    一.创建 二.完整代码 package com.ql; import lombok.SneakyThrows; import okhttp3.Call; import okhttp3.OkHttpClient; import okhttp3.Request; import okhttp3.Response; import java.io.IOException; public class Mythread extends Thread { public Mythread(String name)

  • Java实战之多线程模拟站点售票

    一.实验题目 二.分析 哦吼,这次的实验题目是一道非常经典的多线程买票问题.题目要求我们创建5个线程来模拟卖票,当然这其中就包含多线程存在也就是我们要解决的问题,重复卖票和超额卖票.即多个窗口卖出同一张票以及窗口卖出非正数编号的票. 不过这个问题可以先放一下,我们先来创建基础的线程模型,并在主方法中创建五个线程让他们跑起来: 话不多说,上代码. public class Ticket { public static void main(String[] args) { for(int i = 1

  • java多线程之火车售票系统模拟实例

    1.前言 为了学习多线程共享与通信,我们模拟一个火车售票系统,假设有10张火车票,三个窗口(也就是三个线程)同时进行售票. 2.非同步代码 package com.tl.skyLine.thread; /** * Created by tl on 17/3/6. */ public class SellTicket { public static void main(String[] args) { TicketWindow tw = new TicketWindow(); Thread t1

  • 浅析12306售票算法(java版)

    1.以G71列车为例,首先对车次站台进行占位编码(从1开始到最后一站递加) 对以上占位简单描述以下:G71总共18个站点那么我们的单个座位的座位标识可以用十八位长度的二进制字符串表示10000000000000000每一位代表一个站点,每天放票前初始化到下面的订票表中,数据如下余票根据座位标识中的0的个数决定最大余票数量 订票表中的始发受限站点和终到受限站点可以灵活搭配(这个就可以实现限制站点发售) 2.查询余票 如果我们要查询日期为2016-06-11,始发站保定东站(3)到韶关站(15)的G

  • Java多线程模拟电影售票过程

    用多线程模拟电影售票过程(Java实训) 实训目的: 多线程的实现.线程同步 实训要求: 总票数和售票窗口数由键盘输入,用每个线程处理一个窗口的售票. Test.java package program5; import java.util.Scanner; public class Test { public static void main(String[] args) { // TODO Auto-generated method stub Scanner sc=new Scanner(S

  • Java多线程窗口售票问题实例

    本文介绍了多线程实现多个窗口售票问题的两种枷锁方式, 分别是synchronized 和lock()和unlock() 具体代码如下: 第一种: package Runnable; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; /* * 同步 * 这里有两种方式加锁 * 分别是 * 1.synchronized * 2.lock()和unlock() */ publ

  • java多线程之铁路售票系统

    本文实例为大家分享了java多线程之铁路售票系统的具体代码,供大家参考,具体内容如下 问题:铁路售票,一共100张,通过四个窗口卖完. 要求:分别用 继承Thread类 和 实现Runnable接口 去实现 ①用继承Thread类去实现 package com.yy.syn; public class Demo3_Ticket { /** * 铁路售票,一共100张,通过四个窗口卖完 * 用继承Thread类去实现 * 分析: * 四个窗口就相当于四条线程,100张火车票就相当于成员变量 * *

随机推荐