首页 > 编程语言 >Java超市收银系统（八、数据导入）

Java超市收银系统（八、数据导入）

时间：2024-08-17 19:52:24浏览次数：10  
标签：product Java String System Product 导入 收银 println new

引言

        当选择1时，程序读取 “商品信息.xls” 文件，将所有数据存放于product集合中，然后将集合中的所有数据增加到商品表中，增加的时候要检查每条记录的条形码在商品表中是否存在，若存在，则不需要增加到数据库中，所有数据增加完毕后，显示“成功从excel文件导入XXX条商品数据”，返回子菜单。

        当选择2时，程序读取 “商品信息.xls” 文件，将所有数据存放于product集合中，然后将集合中的所有数据增加到商品表中，增加的时候要检查每条记录的条形码在商品表中是否存在，若存在，则不需要增加。

功能实现

第三方库导入

        jxl包导入，用于实现对excel处理。从Maven仓库中下载jar文件，之前的数据库连接mysql同样如此，也要下载jar包。Maven仓库链接如下：

​​​​​​Maven Repository: Search/Browse/Explore (mvnrepository.com)

在搜索栏搜索mysql和jxl：

点击合适版本进入，点击jar自动下载对应包：

将jar添加到idea编译器中，最后点击OK：

导入功能

        ok，相信前面博客的dao、vo、util已经讲的很明白了，我们重点来看ui中Driver函数的实现。

public static void main(String[] args) {
    while(true) {
        System.out.println("===****超市商品管理维护====");
        System.out.println("1、从excel中导入数据");
        System.out.println("2、从文本文件导入数据");
        System.out.println("3、返回主菜单");
        System.out.println("请选择（1-3）：");
        Scanner scanner = new Scanner(System.in);
        int choice = scanner.nextInt();
        switch (choice) {
            case 1:
                inputExcel();
                break;
            case 2:
                inputTxt();
                break;
            case 3:
                System.out.println("返回主菜单");
                break;
            default:
                System.out.println("错误");
        }
    }
}
  • 这个方法在一个无限循环中显示菜单，让用户选择要执行的操作。
  • 根据用户的选择，程序调用不同的方法来处理数据导入。
private static void inputExcel() {
    File file = new File("D:\\1111111111111111111111111\\数据导入\\excel\\商品信息.xls");
    List<Product> productList = new ArrayList<>();

    try {
        FileInputStream fis = new FileInputStream(file);
        Workbook workbook = Workbook.getWorkbook(fis);

        // 获取第一个工作表
        Sheet sheet = workbook.getSheet(0);

        // 循环访问行
        for (int i = 1; i < sheet.getRows(); i++) { // 跳过表头（假设第一行是表头）
            String barCode = sheet.getCell(0, i).getContents();
            String productName = sheet.getCell(1, i).getContents();
            String priceStr = sheet.getCell(2, i).getContents(); // 读取价格字符串
            String supply = sheet.getCell(3, i).getContents();

            float price;
            try {
                price = Float.parseFloat(priceStr);
            } catch (NumberFormatException e) {
                System.err.println("发现无效的价格数据：" + priceStr);
                continue; // 跳过无效的数据行
            }

            // 检查具有相同条形码的产品是否已存在
            Product existingProduct = ProductDAO.queryByBarcode(barCode);
            if (existingProduct == null) {
                Product product = new Product(barCode, productName, price, supply);
                productList.add(product);
            }
        }

        // 将产品插入数据库
        int count = 0;
        for (Product product : productList) {
            boolean success = ProductDAO.insert(product);
            if (success) {
                count++;
            }
        }

        System.out.println("成功插入了 " + count + " 个产品到数据库中。");

    } catch (IOException | BiffException e) {
        e.printStackTrace();
    }
}
  • 该方法从指定路径的Excel文件中读取数据。
  • 跳过表头（第一行是表头），然后逐行读取商品信息。
  • 解析价格并检查商品是否已存在数据库中，如果不存在，则将商品信息添加到产品列表中。
  • 最后，将产品列表中的商品信息插入数据库，并显示成功插入的数量。

 

private static void inputTxt() {
    List<Product> productList = new ArrayList<>();
    String filePath = "D:\\1111111111111111111111111\\数据导入\\txt\\商品信息.txt";

    try (BufferedReader reader = new BufferedReader(new FileReader(filePath))) {

        // 读取并丢弃前两行
        String line = reader.readLine(); // 第一行
        if (line != null) {
            line = reader.readLine(); // 第二行
        }

        while ((line = reader.readLine()) != null) {
            String[] parts = line.split("\t"); // 使用制表符作为分隔符
            if (parts.length == 4) {
                String barCode = parts[0];
                String productName = parts[1];
                String price = parts[2];
                String supply = parts[3];

                // 检查条形码是否已存在
                if (ProductDAO.queryByBarcode(barCode) == null) {
                    Product product = new Product(barCode, productName, Float.parseFloat(price), supply);
                    productList.add(product);
                }
            } else {
                System.out.println("文本文件格式错误：" + line);
            }
        }
    } catch (IOException e) {
        throw new RuntimeException("无法读取文本文件", e);
    }

    // 将 productList 中的商品信息插入数据库
    int successfulInsertions = 0;
    for (Product product : productList) {
        if (ProductDAO.insert(product)) { // 插入商品信息
            successfulInsertions++;
        }
    }

    System.out.println("成功从文本文件导入 " + successfulInsertions + " 条商品数据");
}
  • 该方法从指定路径的文本文件中读取数据。
  • 跳过前两行，然后逐行读取商品信息。
  • 根据制表符（\t）分隔字段，并检查商品是否已存在数据库中，如果不存在，则将商品信息添加到产品列表中。
  • 最后，将产品列表中的商品信息插入数据库，并显示成功导入的数量。

        这个程序提供了一个命令行界面，通过选择菜单选项，用户可以从Excel或文本文件中导入商品数据，并将数据插入到数据库中。它包含了基本的错误处理和数据验证，以确保导入过程的正确性。 

结果展示

相关导入excel和txt文件如下：

导入前数据库：

 导入后数据库更新：

完整代码

ui—Driver

package ui;

import dao.ProductDAO;
import jxl.Cell;
import jxl.Sheet;
import jxl.Workbook;
import jxl.read.biff.BiffException;
import vo.Product;

import java.io.*;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;

public class Driver {
    public static void main(String[] args) {
        while(true) {
            System.out.println("===****超市商品管理维护====");
            System.out.println("1、从excel中导入数据");
            System.out.println("2、从文本文件导入数据");
            System.out.println("3、返回主菜单");
            System.out.println("请选择（1-3）：");
            Scanner scanner = new Scanner(System.in);
            int choice = scanner.nextInt();
            switch (choice) {
                case 1:
                    inputExcel();
                    break;
                case 2:
                    inputTxt();
                    break;
                case 3:
                    System.out.println("返回主菜单");
                    break;
                default:
                    System.out.println("错误");

            }
        }
    }

    private static void inputExcel() {
        //Scanner scanner = new Scanner(System.in);
        //System.out.println("请输入要导入的 Excel 文件路径：");
        //String filePath = scanner.nextLine();
        File file = new File("D:\\1111111111111111111111111\\数据导入\\excel\\商品信息.xls");
        List<Product> productList = new ArrayList<>();

        try {
            FileInputStream fis = new FileInputStream(file);
             Workbook workbook = Workbook.getWorkbook(fis);

            // 获取第一个工作表
            Sheet sheet = workbook.getSheet(0);

            // 循环访问行
            for (int i = 1; i < sheet.getRows(); i++) { // 跳过表头（假设第一行是表头）
                String barCode = sheet.getCell(0, i).getContents();
                String productName = sheet.getCell(1, i).getContents();
                String priceStr = sheet.getCell(2, i).getContents(); // 读取价格字符串
                String supply = sheet.getCell(3, i).getContents();

                float price;
                try {
                    price = Float.parseFloat(priceStr);
                } catch (NumberFormatException e) {
                    System.err.println("发现无效的价格数据：" + priceStr);
                    continue; // 跳过无效的数据行
                }

                // 检查具有相同条形码的产品是否已存在
                Product existingProduct = ProductDAO.queryByBarcode(barCode);
                if (existingProduct == null) {
                    Product product = new Product(barCode, productName, price, supply);
                    productList.add(product);
                }
            }

            // 将产品插入数据库
            int count = 0;
            for (Product product : productList) {
                boolean success = ProductDAO.insert(product);
                if (success) {
                    count++;
                }
            }

            System.out.println("成功插入了 " + count + " 个产品到数据库中。");

        } catch (IOException | BiffException e) {
            e.printStackTrace();
        }
    }

    private static void inputTxt() {
        List<Product> productList = new ArrayList<>();
        String filePath = "D:\\1111111111111111111111111\\数据导入\\txt\\商品信息.txt";

        try (BufferedReader reader = new BufferedReader(new FileReader(filePath))) {

            // 读取并丢弃前两行
            String line = reader.readLine(); // 第一行
            if (line != null) {
                line = reader.readLine(); // 第二行
            }

            while ((line = reader.readLine()) != null) {
                String[] parts = line.split("\t"); // 使用制表符作为分隔符
                if (parts.length == 4) {
                    String barCode = parts[0];
                    String productName = parts[1];
                    String price = parts[2];
                    String supply = parts[3];

                    // 检查条形码是否已存在
                    if (ProductDAO.queryByBarcode(barCode) == null) {
                        Product product = new Product(barCode, productName, Float.parseFloat(price), supply);
                        productList.add(product);
                    }
                } else {
                    System.out.println("文本文件格式错误：" + line);
                }
            }
        } catch (IOException e) {
            throw new RuntimeException("无法读取文本文件", e);
        }

        // 将 productList 中的商品信息插入数据库
        int successfulInsertions = 0;
        for (Product product : productList) {
            if (ProductDAO.insert(product)) { // 插入商品信息
                successfulInsertions++;
            }
        }

        System.out.println("成功从文本文件导入 " + successfulInsertions + " 条商品数据");
    }
}

vo—Product

package vo;

public class Product {
    private String barCode;
    private String productName;
    private float price;
    private String supply;

    public Product() {
    }

    public Product(String barCode, String productName, float price, String supply) {
        this.barCode = barCode;
        this.productName = productName;
        this.price = price;
        this.supply = supply;
    }

    public String getBarCode() {
        return barCode;
    }

    public void setBarCode(String barCode) {
        this.barCode = barCode;
    }

    public String getProductName() {
        return productName;
    }

    public void setProductName(String productName) {
        this.productName = productName;
    }

    public float getPrice() {
        return price;
    }

    public void setPrice(float price) {
        this.price = price;
    }

    public String getSupply() {
        return supply;
    }

    public void setSupply(String supply) {
        this.supply = supply;
    }
}

dao—ProductDAO

package dao;

import util.DBUtil;
import vo.Product;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class ProductDAO {
    public static Product queryByBarcode(String barcode) {
        Connection con = null;
        PreparedStatement pst = null;
        ResultSet rs = null;
        Product product = null;
        try {
            con = DBUtil.getConnection();
            String sql = "SELECT * FROM t_shangping WHERE tiaoma = ?";
            pst = con.prepareStatement(sql);
            pst.setString(1, barcode);
            rs = pst.executeQuery();
            if (rs.next()) {
                product = new Product();
                product.setBarCode(rs.getString("tiaoma"));
                product.setProductName(rs.getString("mingcheng"));
                product.setPrice(rs.getFloat("danjia"));
                product.setSupply(rs.getString("gongyingshang"));
            }
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } finally {
            DBUtil.close(con, pst);
        }
        return product;
    }

    public static boolean insert(Product product) {
        Connection con = null;
        PreparedStatement pst = null;
        boolean success = false;
        try {
            con = DBUtil.getConnection();
            String sql = "INSERT INTO t_shangping (tiaoma, mingcheng, danjia, gongyingshang) VALUES (?, ?, ?, ?)";
            pst = con.prepareStatement(sql);
            pst.setString(1, product.getBarCode());
            pst.setString(2, product.getProductName());
            pst.setFloat(3, product.getPrice());
            pst.setString(4, product.getSupply());
            int rowsAffected = pst.executeUpdate();
            if (rowsAffected > 0) {
                success = true;
            }
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            DBUtil.close(con, pst);
        }
        return success;
    }

}

util—DBUtil

package util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class DBUtil {

    //驱动加载，只需执行一次
    static{
        String driveName = "com.mysql.cj.jdbc.Driver";
        try {
            Class.forName(driveName);
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        }
    }

    //获取链接
    public static Connection getConnection(){
        String url = "jdbc:mysql://localhost:3306/sale?useUnicode=true&characterEncoding=utf-8";
        String user = "root";
        String password = "123456";
        Connection con = null;
        try {
            con = DriverManager.getConnection(url,user,password);
        } catch (SQLException e) {
            throw new RuntimeException(e);
        }
        return con;
    }

    //关闭资源
    public static void close(Connection con, PreparedStatement pst){
        if(con!=null) {
            try {
                con.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
        if(pst!=null) {
            try {
                pst.close();
            } catch (SQLException e) {
                throw new RuntimeException(e);
            }
        }
    }

}

mysql

/*
Navicat MySQL Data Transfer
 
Source Server         : localhost_3306
Source Server Version : 80032
Source Host           : localhost:3306
Source Database       : xiaoshou
 
Target Server Type    : MYSQL
Target Server Version : 80032
File Encoding         : 65001
 
Date: 2023-05-11 10:27:07
*/
 
SET FOREIGN_KEY_CHECKS=0;
use sale;
-- ----------------------------
-- Table structure for t_shangping
-- ----------------------------
DROP TABLE IF EXISTS `t_shangping`;
CREATE TABLE `t_shangping` (
  `tiaoma` varchar(255) NOT NULL,
  `mingcheng` varchar(255) DEFAULT NULL,
  `danjia` decimal(10,2) DEFAULT NULL,
  `gongyingshang` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`tiaoma`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
select * from t_shangping;
 
-- ----------------------------
-- Records of t_shangping
-- ----------------------------
INSERT INTO `t_shangping` VALUES ('100001', '手机', '4500.00', '华为');
INSERT INTO `t_shangping` VALUES ('100002', '鼠标', '61.00', '华为');
INSERT INTO `t_shangping` VALUES ('100003', '矿泉水', '2.50', '农夫山泉');
INSERT INTO `t_shangping` VALUES ('100004', '香烟', '20.00', '武汉卷烟厂');
INSERT INTO `t_shangping` VALUES ('100005', '牙膏', '4.50', '中华牙膏厂');
INSERT INTO `t_shangping` VALUES ('200001', '电脑', '4300.00', 'dell');
INSERT INTO `t_shangping` VALUES ('200002', '小明同学', '5.50', '武汉饮料集团');
 
-- ----------------------------
-- Table structure for t_shouyinmingxi
-- ----------------------------
DROP TABLE IF EXISTS `t_shouyinmingxi`;
CREATE TABLE `t_shouyinmingxi` (
  `liushuihao` varchar(255) NOT NULL,
  `tiaoma` varchar(255) DEFAULT NULL,
  `mingcheng` varchar(255) DEFAULT NULL,
  `danjia` decimal(10,0) DEFAULT NULL,
  `shuliang` int DEFAULT NULL,
  `shouyinyuan` varchar(255) DEFAULT NULL,
  `xiaoshoushijian` datetime DEFAULT NULL,
  PRIMARY KEY (`liushuihao`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
select * from t_shouyinmingxi;
-- ----------------------------
-- Records of t_shouyinmingxi
-- ----------------------------
 
-- ----------------------------
-- Table structure for t_yonghu
-- ----------------------------
DROP TABLE IF EXISTS `t_yonghu`;
CREATE TABLE `t_yonghu` (
  `yonghuming` varchar(255) NOT NULL,
  `mima` varchar(255) DEFAULT NULL,
  `xingming` varchar(255) DEFAULT NULL,
  `juese` varchar(255) DEFAULT NULL,
  PRIMARY KEY (`yonghuming`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_0900_ai_ci;
select * from t_yonghu;
-- ----------------------------
-- Records of t_yonghu
-- ----------------------------
INSERT INTO `t_yonghu` VALUES ('mk', 'mk123', '明空', '管理员');
INSERT INTO `t_yonghu` VALUES ('jx', 'jx123', '瑾熙', '收银员');

相关其他功能实现请参考前面的博客

Java超市收银系统（一、用户登录）_java商超收银系统-CSDN博客

Java超市收银系统（二、用户权限）-CSDN博客

Java超市收银系统（三、密码修改）-CSDN博客

Java超市收银系统（四、收银功能）_java超市系统-CSDN博客

Java超市收银系统（五、收银统计）-CSDN博客

Java超市收银系统（六、商品增加和修改）-CSDN博客

Java超市收银系统（七、商品修改和删除）-CSDN博客

标签：product,Java,String,System,Product,导入,收银,println,new
From： https://blog.csdn.net/m0_74325713/article/details/141270682

相关文章

  • idea JAVA_OPTS改不了
    哈喽，各位小伙伴们，你们好呀，我是喵手。运营社区：C站/掘金/腾讯云/阿里云/华为云/51CTO；欢迎大家常来逛逛  今天我要给大家分享一些自己日常学习到的一些知识点，并以文字的形式跟大家一起交流，互相学习，一个人虽可以走的更快，但一群人可以走的更远。  我是一名后端开发爱好者......
  • java String 去掉特殊字符之前的内容
    哈喽，各位小伙伴们，你们好呀，我是喵手。运营社区：C站/掘金/腾讯云/阿里云/华为云/51CTO；欢迎大家常来逛逛  今天我要给大家分享一些自己日常学习到的一些知识点，并以文字的形式跟大家一起交流，互相学习，一个人虽可以走的更快，但一群人可以走的更远。  我是一名后端开发爱好者......
  • JavaDoc生成文档两种方式
    JavaDoc生成文档方法一：通过命令行/***@authorzhang*@version1.0.0*@since1.8*/publicclasstest{Stringname;publicStringtest(Stringname)throwsException{returnname;}}在String下面输入/**，按Enter键在所建类中，......
  • Java 安全研究基础
    JavaEE搞过JavaWeb开发的多少会知道JavaEE。从字面上来看，它的意思是JavaPlatform,EnterpriseEdition，即Java平台企业版。实际上JavaEE包含了一系列标准，这些标准主要用来为企业级应用提供分布式计算、Web服务等的统一定义和接口。Servlet从实现上来说，Servlet是一......
  • JAVA执行流程
    基本流程Java程序的运行必须经过编写、编译和运行3个步骤：1、编写：是指在Java开发环境中进行程序代码的输入，最终形成后缀名为.java的Java源文件。2、编译：是指使用Java编译器对源文件进行错误排査的过程，编译后将生成后缀名为.class的字节码文件，不像C语言那样生成可执......
  • Java的Rmi
    什么是RmiRMI（RemoteMethodInvocation）的全称为远程方法调用。远程方法调用是分布式编程中的一个基本思想。实现远程方法调用的技术有很多，比如：CORBA、WebService，这两种都是独立于编程语言的。而JavaRMI（JavaRemoteMethodInvocation）是专为Java环境设计的远程方法调用机制，能够让......
  • Java的Io
    JavaIO基础IO，即in和out，也就是输入和输出，指应用程序和外部设备之间的数据传递，常见的外部设备包括文件、管道、网络连接。Java中是通过流处理IO的，那么什么是流？流（Stream），是一个抽象的概念，是指一连串的数据（字符或字节），是以先进先出的方式发送信息的通道。当程序需要读取数据的时......
  • Java的动态代理
    代理模式代理模式给某一个(目标)对象提供一个代理对象，并由代理对象持有目标对象的引用。所谓代理，就是一个对象代表另一个对象执行相应的动作程序。而代理对象可以在客户端和目标对象之间起到中介的作用。代理模式在实际的生活中场景很多，例如中介、律师、代购等行业，都是简单的代......
  • java+vue计算机毕设基于Web的在线考试管理信息系统【源码+开题+论文】
    本系统（程序+源码）带文档lw万字以上文末可获取一份本项目的java源码和数据库参考。系统程序文件列表开题报告内容研究背景随着信息技术的飞速发展和教育改革的不断深入，传统考试模式已难以满足现代教育的需求。在线考试作为一种新兴的教育评估方式，凭借其便捷性、高效性和灵......
  • 基于ssm的新生报到系统(有报告)。Javaee项目，ssm项目。
    演示视频：基于ssm的新生报到系统(有报告)。Javaee项目，ssm项目。资源下载：基于ssm的新生报到系统(有报告)。Javaee项目，ssm项目。项目介绍：采用M（model）V（view）C（controller）三层体系结构，通过Spring+SpringMvc+Mybatis+Jsp+Maven来实现。MySQL数据库作为系统数据储存......

赞助商

阅读排行

网站主页关于我们联系我们网站地图

本网站内容转载自其他媒体，侵权联系[admin##ips99.com]。

Copyright © 2020-2023 IPS99 版权所有 IPS99