AI 助理
备案控制台
开发者社区 数据库 文章 正文

JDBC编程相关知识（实现图书管理系统进阶版）（下）

2024-05-27 41
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： JDBC编程相关知识（实现图书管理系统进阶版）

JDBC编程相关知识（实现图书管理系统进阶版）（上）：https://developer.aliyun.com/article/1520473

d、Administrator类

管理员的主要功能是对图书进行增加、删除、查看以及查找，管理员类继承User类，需要对父类定义的接口数组完善将自己特有的方法进行填充。对于重写身份验证方法，使用select name,password from administrator ，遍历结果集得到姓名和密码，若有对应的密码和密码则登录成功，否则登录失败。

import operate.*;
import util.DBUtil;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Scanner;
 
public class Administrator extends User{
    public Administrator(){
 
    }
    public Administrator(String name, String password) {
        super(name,password);
        this.operates=new Operate[]{
                new ExitOpe(),
                new AddBook(),
                new DelBook(),
                new DisplayBook(),
                new FindBook()
        };
    }
 
    @Override
    public int menu() {
        System.out.println("*******************************************");
        System.out.println("    1.添加图书                   2.删除图书   ");
        System.out.println("    3.显示图书                   4.查找图书   ");
        System.out.println("    0.退出系统                              ");
        System.out.println("*******************************************");
        System.out.println("请输入您的操作：");
        Scanner sc = new Scanner(System.in);
        int option = sc.nextInt();
        return option;
    }
 
    @Override
    public  boolean authentication(String name,String pwd) throws SQLException {
        Connection connection= DBUtil.getConnection();
        String sql="select name,password from administrator where name=?";
        PreparedStatement statement=connection.prepareStatement(sql);
        statement.setString(1,name);
        ResultSet resultSet=statement.executeQuery();
        if(resultSet.next()){
            String na=resultSet.getString("name");
            String pw=resultSet.getString("password");
            if(pw.equals(pwd)&&na.equals(name)){
                return true;
            }
        }
        return false;
    }
 
}

e、RegularUser类

普通用户类同样继承User类，内部实现与管理员类相似。

import operate.*;
import util.DBUtil;
 
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Scanner;
 
public class RegularUser extends User{
    public RegularUser(){
 
    }
    public RegularUser(String name, String password) {
        super(name,password);
        this.operates=new Operate[]{
                new ExitOpe(),
                new BorrowBook(),
                new ReturnBook(),
                new DisplayBook(),
                new FindBook(),
 
        };
    }
 
    @Override
    public int menu() {
        System.out.println("*******************************************");
        System.out.println("    1.借阅图书                   2.归还图书   ");
        System.out.println("    3.显示图书                   4.查找图书   ");
        System.out.println("    0.退出系统                              ");
        System.out.println("*******************************************");
        System.out.println("请输入您的操作：");
        Scanner sc = new Scanner(System.in);
        int option = sc.nextInt();
        return option;
    }
 
    @Override
    public boolean authentication(String name, String pwd) throws SQLException {
        Connection connection= DBUtil.getConnection();
        String sql="select name,password from regularuser where name=?";
        PreparedStatement statement=connection.prepareStatement(sql);
        statement.setString(1,name);
        ResultSet resultSet=statement.executeQuery();
        if(resultSet.next()){
            String na=resultSet.getString("name");
            String pw=resultSet.getString("password");
            if(pw.equals(pwd)&&na.equals(name)){
                return true;
            }
        }
        return false;
    }
}

4、实现操作类

a、Operate接口

创建一个接口，内部定义一个抽象的work方法，然后操作类都实现这个接口，并重写work方法。

import book.Bookshelf;
import java.sql.SQLException;
 
public interface Operate {
    void work(Bookshelf books) throws SQLException;
}

b、 添加图书方法

由于书架当时的初始容量为10000，但还是进行了判断，如果容量已满则无法添加，再进一步输入要添加图书的信息，利用图书类中的equals()方法对添加的图书与已经存放的图书，若有重复则无法添加，否则使用insert插入语句进行添加，完成对数据库的更新，并且要将该图书添加到书架类的数组中。

public class AddBook implements Operate{
    @Override
    public void work(Bookshelf books) throws SQLException {
        if(books.getCurrentSize()>= books.getSize()){
            System.out.println("书架已满，无法继续添加");
        }else{
            Scanner sc=new Scanner(System.in);
            System.out.println("请输入图书信息：");
            System.out.println("图书编号：");
            int id=sc.nextInt();
            System.out.println("图书名称：");
            String name=sc.next();
            System.out.println("图书作者：");
            String author = sc.next();
            System.out.println("图书价格：");
            int price = sc.nextInt();
            System.out.println("图书主题：");
            sc.nextLine();
            String theme= sc.nextLine();
            Book book = new Book(id,name, author, price, theme);
            for (int i = 0; i < books.getCurrentSize(); i++) {
                if(book.equals(books.getBook(i))){
                    System.out.println("该图书已经存在，无法继续添加！");
                    return;
                }
            }
            String sql="insert into book(id,name,author,price,theme) values(?,?,?,?,?)";
            Connection connection= DBUtil.getConnection();
            PreparedStatement statement=connection.prepareStatement(sql);
            statement.setInt(1,id);
            statement.setString(2,name);
            statement.setString(3,author);
            statement.setDouble(4,price);
            statement.setString(5,theme);
            books.addBook(book);
            books.setCurrentSize(books.getCurrentSize()+1);
            int ret=statement.executeUpdate();
            if(ret>0){
                System.out.println("添加成功！");
            }
            statement.close();
            connection.close();
        }
    }
}

c、删除图书

输入要删除的图书名称，利用书架类的数组遍历，此处不使用select语句进行查找是后面对书架进行删除时需要得到图书在书架的位置，找到后使用delete语句删除图书，然后再使用循环覆盖删除书架中的该图书。

public class DelBook implements Operate{
    @Override
    public void work(Bookshelf books) throws SQLException {
        System.out.println("请输入要删除的图书名称");
        Scanner sc=new Scanner(System.in);
        String name=sc.nextLine();
        int pos=-1;
        for (int i = 0; i < books.getCurrentSize(); i++) {
            if(name.equals(books.getBook(i).getName())){
                pos=i;
                break;
            }
        }
        if(pos==-1){
            System.out.println("未找到您要删除的图书");
        }else{
            Connection connection= DBUtil.getConnection();
            String sql="delete from book where name=?";
            PreparedStatement statement=connection.prepareStatement(sql);
            statement.setString(1,name);
            int ret=statement.executeUpdate();
            if(ret>0){
                System.out.println("删除成功!");
            }
            for(int i= pos+1;i<books.getCurrentSize();i++){
                Book book=books.getBook(i);
                books.modify(i-1,book);
            }
            books.modify(books.getCurrentSize(),null);
            books.setCurrentSize(books.getCurrentSize()-1);
            statement.close();
            connection.close();
        }
    }
}

d、显示图书

显示所有的图书信息，此处使用select语句对book表进行全列查询，此处也可以遍历书架得到所有图书的信息。  

public class DisplayBook implements Operate{
    @Override
    public void work(Bookshelf books) throws SQLException {
        Connection connection= DBUtil.getConnection();
        String sql="select * from book";
        PreparedStatement statement=connection.prepareStatement(sql);
        ResultSet resultSet = statement.executeQuery();
        System.out.println("====================================================================================================================");
        while(resultSet.next()){
            int id=resultSet.getInt("id");
            String name=resultSet.getString("name");
            String author=resultSet.getString("author");
            Double price=resultSet.getDouble("price");
            String theme=resultSet.getString("theme");
            boolean isBorrowed=resultSet.getBoolean("statue");
            Date borrowTime=resultSet.getDate("borrow_time");
            Date returnTime=resultSet.getDate("return_time");
            System.out.println("Book{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    ", author='" + author + '\'' +
                    ", price=" + price +
                    ", theme='" + theme + '\'' +
                    ", isBorrowed=" + (isBorrowed?"已借出":"未借出") +
                    ", borrowTime=" + borrowTime +
                    ", returnTime=" + returnTime +
                    '}');
        }
 
        System.out.println("====================================================================================================================");
        resultSet.close();
        statement.close();
        connection.close();
    }
}

e、查找图书

此处使用的是select语句对图书名称进行精确查询，也使用循环遍历书架更为方便。

public class FindBook implements Operate{
    @Override
    public void work(Bookshelf books) throws SQLException {
        System.out.println("请输入要查找的图书名称");
        Scanner sc=new Scanner(System.in);
        String str=sc.nextLine();
        int pos=-1;
        Connection connection= DBUtil.getConnection();
        String sql="select * from book where name=?";
        PreparedStatement statement=connection.prepareStatement(sql);
        statement.setString(1,str);
        ResultSet resultSet = statement.executeQuery();
        if(resultSet==null){
            System.out.println("未找到您要找的书籍");
            return;
        }
        System.out.println("====================================================================================================================");
        while(resultSet.next()){
            int id=resultSet.getInt("id");
            String name=resultSet.getString("name");
            String author=resultSet.getString("author");
            Double price=resultSet.getDouble("price");
            String theme=resultSet.getString("theme");
            boolean isBorrowed=resultSet.getBoolean("statue");
            Date borrowTime=resultSet.getTime("borrow_time");
            Date returnTime=resultSet.getTime("return_time");
            System.out.println("Book{" +
                    "id=" + id +
                    ", name='" + name + '\'' +
                    ", author='" + author + '\'' +
                    ", price=" + price +
                    ", theme='" + theme + '\'' +
                    ", isBorrowed=" + (isBorrowed?"已借出":"未借出") +
                    ", borrowTime=" + borrowTime +
                    ", returnTime=" + returnTime +
                    '}');
        }
        System.out.println("====================================================================================================================");
        resultSet.close();
        statement.close();
        connection.close();
    }
}

f、借阅图书

在借阅图书时，首先对输入的图书进行查找，若有才能进行借阅，使用update语句对图书的是否借出还有借阅时间进行修改，在创建图书类的日期是使用的是util包的Date类，但是在book表中的datetime是sql包的Date类，需要进行转换，对数据库中的book表完成更新后，同时也要修改书架上的图书信息。

public class BorrowBook implements Operate{
    @Override
    public void work(Bookshelf books) throws SQLException {
        System.out.println("请输入要借阅的图书名称");
        Scanner sc=new Scanner(System.in);
        String name=sc.nextLine();
        int pos=-1;
        for (int i = 0; i < books.getCurrentSize(); i++) {
            if(name.equals(books.getBook(i).getName())){
                pos=i;
                break;
            }
        }
        if(pos==-1){
            System.out.println("未找到您需要的图书");
        }else{
            if(books.getBook(pos).isBorrowed()==true){
                System.out.println("该图书已经借出");
                return;
            }
            Date date=new Date(System.currentTimeMillis());
            java.sql.Date sd=new java.sql.Date(date.getTime());
            Connection connection= DBUtil.getConnection();
            String sql1="update book set borrow_time=? where name=?";
            PreparedStatement statement1=connection.prepareStatement(sql1);
            statement1.setDate(1,sd);
            statement1.setString(2,name);
            String sql2="update book set statue=? where name=?";
            PreparedStatement statement2=connection.prepareStatement(sql2);
            Boolean flag=true;
            statement2.setBoolean(1,flag);
            statement2.setString(2,name);
            statement1.executeUpdate();
            statement1.close();
            statement2.executeUpdate();
            statement2.close();
            connection.close();
            books.getBook(pos).setBorrowed(true);
            books.getBook(pos).setBorrowTime(date);
            System.out.println("借阅成功！");
        }
    }
}

g、归还图书

在归还图书时，也要对图书的借阅状态和归还时间进行修改，操作与借阅图书类似。

public class ReturnBook implements Operate {
    @Override
    public void work(Bookshelf books) throws SQLException {
        System.out.println("请输入要归还的图书名称");
        Scanner sc=new Scanner(System.in);
        String name=sc.nextLine();
        int pos=-1;
        for (int i = 0; i < books.getCurrentSize(); i++) {
            if(name.equals(books.getBook(i).getName())){
                pos=i;
                break;
            }
        }
        if(pos==-1){
            System.out.println("未找到您需要的图书");
        }else{
            Date date=new Date(System.currentTimeMillis());
            java.sql.Date sd=new java.sql.Date(date.getTime());
            Connection connection= DBUtil.getConnection();
            String sql1="update book set return_time=? where name=?";
            PreparedStatement statement1=connection.prepareStatement(sql1);
            statement1.setDate(1,sd);
            statement1.setString(2,name);
            String sql2="update book set statue=? where name=?";
            PreparedStatement statement2=connection.prepareStatement(sql2);
            Boolean flag=false;
            statement2.setBoolean(1,flag);
            statement2.setString(2,name);
            statement1.executeUpdate();
            statement1.close();
            statement2.executeUpdate();
            statement2.close();
            connection.close();
            books.getBook(pos).setBorrowed(false);
            books.getBook(pos).setReturnTime(date);
            System.out.println("归还成功！");
        }
    }
}

h、退出系统

使用System.exit(0）方法退出系统，虽然该方法没有任何异常，但因为重写了Operate中的work方法，work方法抛出了sql异常，那么该方法也需要抛出异常。  

public class ExitOpe implements Operate{
    @Override
    public void work(Bookshelf books) throws SQLException {
        System.out.println("退出成功，欢迎下次使用!");
        System.exit(0);
    }
}

5、Main

在测试类中需要实现登录函数，由于在登录时才知道用户身份，所以使用User类为返回值进行向上转型，在登录函数中首先选择身份，然后对身份进行验证，验证成功后，即登录成功。

public class Main {
 
    public static User login() throws SQLException {
        System.out.println("请选择登录身份：1）管理员 2）普通用户");
        Scanner sc=new Scanner(System.in);
        int option=sc.nextInt();
        System.out.println("请输入姓名：");
        String name=sc.next();
        System.out.println("请输入密码：");
        String pwd=sc.next();
        if(option==1){
            boolean flag=new Administrator().authentication(name,pwd);
            if(flag){
                System.out.println("登陆成功！");
               return new Administrator(name,pwd);
            }else{
                System.out.println("姓名或密码输入有误");
            }
        }else if(option==2){
            boolean flag=new RegularUser().authentication(name,pwd);
            if(flag){
                System.out.println("登陆成功！");
                return new RegularUser(name,pwd);
            }else{
                System.out.println("姓名或密码输入有误");
            }
        }else{
            System.out.println("输入有误");
        }
        return null;
    }
    public static void main(String[] args) throws SQLException {
        Bookshelf books=new Bookshelf();
            User user=login();
            while(true){
                int ret=user.menu();
                user.doWork(ret,books);
            }
    }
}

6、效果演示

管理员和普通用户表如下所示：

运行效果演示：

管理员：

普通用户：

文章标签：
Java
数据库连接
数据安全/隐私保护
SQL
数据库
关键词：
jdbc编程
jdbc编程图书管理系统
jdbc图书管理系统
jdbc进阶
过。
目录
相关文章
热爱技术的小郑
|
3月前
|
Java 数据库连接 网络安全
JDBC数据库编程(java实训报告)
这篇文章是关于JDBC数据库编程的实训报告，涵盖了实验要求、实验环境、实验内容和总结。文中详细介绍了如何使用Java JDBC技术连接数据库，并进行增删改查等基本操作。实验内容包括建立数据库连接、查询、添加、删除和修改数据，每个部分都提供了相应的Java代码示例和操作测试结果截图。作者在总结中分享了在实验过程中遇到的问题和解决方案，以及对Java与数据库连接操作的掌握情况。
热爱技术的小郑
94 1
JDBC数据库编程(java实训报告)
weixin_836869520
|
4月前
|
SQL Java 关系型数据库
Java中的JDBC编程详解
Java中的JDBC编程详解
weixin_836869520
50 3
泥腿子架构师
|
4月前
|
SQL Java 关系型数据库
Java中的JDBC编程详解
Java中的JDBC编程详解
泥腿子架构师
28 1
多多!
|
5月前
|
SQL XML Java
后端数据库开发JDBC编程Mybatis之用基于XML文件的方式映射SQL语句实操
后端数据库开发JDBC编程Mybatis之用基于XML文件的方式映射SQL语句实操
多多!
71 3
不摸鱼的程序员
|
6月前
|
SQL Java 数据库连接
从零开启 JDBC 编程
从零开启 JDBC 编程
不摸鱼的程序员
54 0
过。
|
6月前
|
Java 关系型数据库 MySQL
JDBC编程相关知识（实现图书管理系统进阶版）（上）
JDBC编程相关知识（实现图书管理系统进阶版）
过。
62 0
叶落闲庭
|
6月前
|
SQL Java 关系型数据库
JavaWeb（JDBC编程）看这一篇就够了 —— 如何使用Java操作mysql数据库
JavaWeb（JDBC编程）看这一篇就够了 —— 如何使用Java操作mysql数据库
叶落闲庭
216 0
蓝易云
|
28天前
|
Java 关系型数据库 MySQL
mysql5.7 jdbc驱动
遵循上述步骤，即可在Java项目中高效地集成MySQL 5.7 JDBC驱动，实现数据库的访问与管理。
蓝易云
106 1
武子康
|
1月前
|
SQL 分布式计算 关系型数据库
Hadoop-24 Sqoop迁移 MySQL到Hive 与 Hive到MySQL SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
Hadoop-24 Sqoop迁移 MySQL到Hive 与 Hive到MySQL SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
武子康
84 0
武子康
|
1月前
|
SQL 分布式计算 关系型数据库
Hadoop-23 Sqoop 数据MySQL到HDFS(部分) SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
Hadoop-23 Sqoop 数据MySQL到HDFS(部分) SQL生成数据 HDFS集群 Sqoop import jdbc ETL MapReduce
武子康
37 0

热门文章

最新文章

  • 1
    Java -- JDBC 学习--通过 ResultSet 执行查询操作
  • 2
    JDBC操作MySQL5日期类型字段的问题解决方法
  • 3
    报错：java.lang.ClassNotFoundException: com.mysql.cj.jdbc.Driver at java.base/jdk.internal.loader.Bui
  • 4
    JDK6笔记（6）----JDBC4.0高级应用(2)
  • 5
    使用JDBC获取各数据库的Meta信息——表以及对应的列
  • 6
    logstash-input-jdbc实现mysql 与elasticsearch实时同步深入详解
  • 7
    利用JDBC-ODBC驱动访问SQL SERVER2008
  • 8
    JDBC 驱动升级到 Version 8.0.28 连接 MySQL 的踩坑记录
  • 9
    OAF_JDBC系列2 - 通过JDBC连接SQLSERVER数据库DriverManager.getConnection
  • 10
    JDBC调用MySQL5存储过程
  • 1
    Java面试题：什么是JDBC以及如何在Java中使用它进行数据库操作？
    52
  • 2
    Java面试题：描述JDBC的工作原理，包括连接数据库、执行SQL语句等步骤。
    66
  • 3
    【Java】已解决com.mysql.cj.jdbc.exceptions.CommunicationsException异常
    1099
  • 4
    【Java】已解决Java中的com.mysql.jdbc.exceptions.jdbc4.MySQLSyntaxErrorException异常
    226
  • 5
    【Java】已解决com.mysql.jdbc.exceptions.jdbc4.MySQLIntegrityConstraintViolationException异常
    370
  • 6
    [已解决]com.mysql.cj.jdbc.exceptions. PacketTooBigException: Packet for query is too large (3,456,888
    59
  • 7
    Java中的JDBC编程详解
    50
  • 8
    使用MySQL JDBC连接数据库
    439
  • 9
    JDBC的路径讲解？
    95
  • 10
    使用MySQL JDBC连接数据库
    80

    • 相关课程

    更多
  • JDBC数据库开发入门
  • JDBC数据库开发进阶
  • 「大师课」搞定 Java 开发基础
  • PHP进阶教程 - 由浅入深掌握面向对象开发 - 第二阶段
  • Java面试疑难点解析 - 系统架构及项目设计
  • Java Web开发系列课程 - Spring框架入门

    • 相关电子书

    更多
  • Java工程师必读手册
  • Java基础入门(三)-阿里巴巴Java开发手册介绍
  • Java8简明教程

    • 相关实验场景

    更多
  • MySQL基础-学生管理系统数据库设计
  • 语言入门-1：环境构建
  • 阿里云平台上进行Java程序的编译与运行
  • 使用Java面向对象编写网络通信程序应用
  • Arthas 进阶教程
  • 搭建Java Web开发环境
    • 下一篇
    阿里云OSS设置跨域访问