设计并实现一个多线程图书馆管理系统，涉及数据库操作

没有实现全部功能，希望路过的大佬，可以实现全部功能，在评论区聊聊

在这里插入图片描述
创建数据库library-demo

CREATE DATABASE `library-demo`

创建图书表book

CREATE TABLE `book` (`bookId` int(11) NOT NULL AUTO_INCREMENT COMMENT '图书ID',`bookName` varchar(15) DEFAULT NULL COMMENT '书名',`author` varchar(10) DEFAULT NULL COMMENT '作者',`publish` varchar(100) DEFAULT NULL COMMENT '出版社',`isbn` varchar(30) DEFAULT NULL COMMENT 'ISBN',`introduction` varchar(50) DEFAULT NULL COMMENT '简介',`language` varchar(10) DEFAULT NULL COMMENT '语言',`price` varchar(10) DEFAULT NULL COMMENT '价格',`bookStatus` tinyint(4) DEFAULT NULL COMMENT '图书状态',`bookImage` varchar(30) DEFAULT NULL COMMENT '封面',`bookCount` int(11) DEFAULT NULL COMMENT '存有量',`borrowDate` date DEFAULT NULL COMMENT '借阅日期',`returnDate` date DEFAULT NULL COMMENT '返还日期',`borrowTime` int(11) DEFAULT NULL COMMENT '借阅时长',PRIMARY KEY (`bookId`)
) ENGINE=InnoDB AUTO_INCREMENT=33 DEFAULT CHARSET=utf8 COMMENT='图书表';

创建用户表user

CREATE TABLE `user` (`userId` int(11) NOT NULL AUTO_INCREMENT COMMENT '用户ID',`userName` varchar(10) DEFAULT NULL COMMENT '用户名字',`password` varchar(10) DEFAULT NULL COMMENT '密码',`email` varchar(10) DEFAULT NULL COMMENT '邮箱',`phone` varchar(15) DEFAULT NULL COMMENT '电话',`address` varchar(20) DEFAULT NULL COMMENT '地址',PRIMARY KEY (`userId`)
) ENGINE=InnoDB AUTO_INCREMENT=9 DEFAULT CHARSET=utf8 COMMENT='用户表';

创建用户图书关联表bookuser

CREATE TABLE `bookuser` (`id` int(11) NOT NULL AUTO_INCREMENT COMMENT '关系id',`book_id` int(11) DEFAULT NULL COMMENT '图书id',`user_id` int(11) DEFAULT NULL COMMENT '用户id',PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='用户图书关系表';

创建借阅记录表borrowslog

CREATE TABLE `borrowslog` (`logId` int(11) NOT NULL AUTO_INCREMENT COMMENT '日志id',`borrowsFlag` varchar(10) DEFAULT NULL COMMENT '借阅标志',`bookId` varchar(10) DEFAULT NULL COMMENT '书籍Id',`userId` varchar(10) DEFAULT NULL COMMENT '用户Id',`borrowsDate` date DEFAULT NULL COMMENT '借阅日期',`returnFlag` varchar(10) DEFAULT NULL COMMENT '归还标志',`returnDate` date DEFAULT NULL COMMENT '归还日期',`borrowsTime` int(11) DEFAULT NULL COMMENT '借阅时长',`realityBorrowsTime` int(11) DEFAULT NULL COMMENT '实际借阅时长',`borrowNumber` varchar(20) DEFAULT NULL COMMENT '借阅单号',PRIMARY KEY (`logId`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8 COMMENT='借阅记录表';

到此数据库创建完成
下边是Demo的结构
在这里插入图片描述
book.java

package com.domain;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;import java.util.Date;/*** @program: LibraryDemo* @description: 图书实体* @author: Casey Hu* @create: 2023-12-06 11:52**/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class Book {private Integer BookId;private String BookName;private String Author;private String Publish;private String ISBN;private String Introduction;private String Language;private String Price;private Integer bookStatus;private String bookImage;private Integer bookCount;private Date borrowDate;private Date returnDate;private Integer borrowTime;
}

BorrowsLog.java

package com.domain;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;import java.util.Date;/*** @program: LibraryDemo* @description:* @author: Casey Hu* @create: 2023-12-07 14:15**/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class BorrowsLog {private Integer logId;private String borrowsFlag;private String bookId;private String userId;private Date borrowsDate;private String returnFlag;private Date returnDate;private String borrowsTime;private String realityBorrowsTime;private String borrowNumber;}

User.java

package com.domain;import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;/*** @program: LibraryDemo* @description: 用户* @author: Casey Hu* @create: 2023-12-06 14:17**/
@Data
@AllArgsConstructor
@NoArgsConstructor
public class User {private Integer UserId;private String UserName;private String Password;private String Email;private String Phone;private String Address;}

LibraryService.java

package com.service;import com.domain.Book;
import com.domain.BorrowsLog;
import com.domain.User;
import com.util.JDBCUtil;import java.sql.ResultSet;
import java.time.Instant;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.TimeUnit;/*** @program: LibraryDemo* @description:* @author: Casey Hu* @create: 2023-12-06 16:25**/public class LibraryService {//添加图书public synchronized void addBook(Book book) {JDBCUtil jdbcUtil = new JDBCUtil();int i = jdbcUtil.executeUpdate("INSERT INTO book (bookName, author, publish, isbn, introduction, `language`, price, bookStatus, bookImage, bookCount)" +" VALUES('" + book.getBookName() + "', '" + book.getAuthor() + "', '" + book.getPublish() + "', '" + book.getISBN() + "', '" + book.getIntroduction() + "', '" + book.getLanguage() + "', '" + book.getPrice() + "', " + book.getBookStatus() + ", '" + book.getBookImage() + "', " + book.getBookCount() + ");");if (i==1) {System.out.println("插入成功");}else {System.out.println("插入失败");}jdbcUtil.closeConnection();}//删除图书public synchronized void deleteBook(Book book) {JDBCUtil jdbcUtil = new JDBCUtil();jdbcUtil.executeUpdate("update book set bookStatus = 0 where bookName = " + book.getBookName() + ";");jdbcUtil.closeConnection();}//搜索图书public synchronized List<Book> queryBookList(Book book) {List<Book> bookList =new ArrayList<>();JDBCUtil jdbcUtil = new JDBCUtil();ResultSet resultSet=jdbcUtil.executeQuery("select * from book where bookName = " + book.getBookName() + " and bookStatus = 1;");try {while (resultSet.next()) {Book bookRes=new Book();bookRes.setBookName(resultSet.getString("bookName"));bookRes.setAuthor(resultSet.getString("author"));bookRes.setPublish(resultSet.getString("publish"));bookRes.setISBN(resultSet.getString("isbn"));bookRes.setIntroduction(resultSet.getString("introduction"));bookRes.setLanguage(resultSet.getString("language"));bookRes.setPrice(resultSet.getString("price"));bookRes.setBookStatus(resultSet.getInt("bookStatus"));bookRes.setBookImage(resultSet.getString("bookImage"));bookRes.setBookCount(resultSet.getInt("bookCount"));bookRes.setBorrowDate(resultSet.getDate("borrowDate"));bookRes.setReturnDate(resultSet.getDate("returnDate"));bookRes.setBorrowTime(resultSet.getInt("borrowTime"));bookList.add(bookRes);}}catch (Exception e){e.printStackTrace();}jdbcUtil.closeConnection();return bookList;}public synchronized Book queryBook(Book book) {JDBCUtil jdbcUtil = new JDBCUtil();Book bookRes=new Book();ResultSet resultSet=jdbcUtil.executeQuery("select * from book where isbn = '" + book.getISBN() + "' and bookStatus = 1;");try {while (resultSet.next()) {bookRes.setBookName(resultSet.getString("bookName"));bookRes.setAuthor(resultSet.getString("author"));bookRes.setPublish(resultSet.getString("publish"));bookRes.setISBN(resultSet.getString("isbn"));bookRes.setIntroduction(resultSet.getString("introduction"));bookRes.setLanguage(resultSet.getString("language"));bookRes.setPrice(resultSet.getString("price"));bookRes.setBookStatus(resultSet.getInt("bookStatus"));bookRes.setBookImage(resultSet.getString("bookImage"));bookRes.setBookCount(resultSet.getInt("bookCount"));bookRes.setBorrowDate(resultSet.getDate("borrowDate"));bookRes.setReturnDate(resultSet.getDate("returnDate"));bookRes.setBorrowTime(resultSet.getInt("borrowTime"));}}catch (Exception e){e.printStackTrace();}jdbcUtil.closeConnection();return bookRes;}//借阅图书public synchronized void borrowBook(Book book, User user,Integer days) {//根据图书ISBN查询 图书是否可以借阅，且查看库存量是否有，JDBCUtil jdbcUtil = new JDBCUtil();ResultSet resultSet = jdbcUtil.executeQuery("select bookStatus,bookCount,bookName,bookId from book where isbn='"+book.getISBN()+"' ;");Instant instant = Instant.now();long timestamp = instant.toEpochMilli();try {while (resultSet.next()) {Integer bookStatus = resultSet.getInt("bookStatus");if(bookStatus==1){Integer bookCount = resultSet.getInt("bookCount");if(bookCount>0){//借阅 减少库存int i = jdbcUtil.executeUpdate("update book set bookCount = bookCount - 1 where isbn='" + book.getISBN() + "' ;");if(i==1){//新增借阅日志i = jdbcUtil.executeUpdate("INSERT INTO borrowslog (borrowsFlag, bookId, userId, borrowsDate,  borrowsTime, borrowNumber) " +"VALUES('1', '" + resultSet.getInt("bookId") + "', '" + user.getUserId() + "', NOW(), '" + days + "', '" + timestamp + "');");if(i==1){System.out.println("借阅成功！借阅单号："+timestamp);}else {System.out.println("借阅异常，请联系管理员");}}}else {System.out.println("此书 "+resultSet.getInt("bookName")+"库存不足");}}else {System.out.println("此书 "+resultSet.getInt("bookName")+"已下架");}}}catch (Exception e){System.out.println("查不到此书");e.printStackTrace();}jdbcUtil.closeConnection();}public synchronized void returnBook(String borrowNumber) {JDBCUtil jdbcUtil = new JDBCUtil();//通过借阅单号， 更新借阅标志和时间ResultSet resultSet = jdbcUtil.executeQuery("SELECT logId, borrowsFlag, bookId, userId, borrowsDate, returnFlag, returnDate, \n" +"borrowsTime, realityBorrowsTime, borrowNumber FROM borrowslog where borrowNumber='"+borrowNumber+"';");BorrowsLog borrowsLog = new BorrowsLog();try {while (resultSet.next()) {borrowsLog.setLogId(resultSet.getInt("logId"));borrowsLog.setUserId(resultSet.getString("userId"));borrowsLog.setBookId(resultSet.getString("bookId"));//计算实际时间Date  borrowsDate= resultSet.getDate("borrowsDate");long differenceInMilliseconds = new Date().getTime() - borrowsDate.getTime();// 转换毫秒差值为天数Integer differenceInDays = (int) TimeUnit.MILLISECONDS.toDays(differenceInMilliseconds);//更新jdbcUtil.executeUpdate("UPDATE borrowslog SET  returnFlag='1', returnDate=NOW(), realityBorrowsTime="+differenceInDays+" WHERE logId="+borrowsLog.getLogId()+" and borrowNumber='"+borrowNumber+"';");int i = jdbcUtil.executeUpdate("update book set bookCount = bookCount + 1 where bookId=" + borrowsLog.getBookId() + " ;");if(i==1){System.out.println("此书归还成功");}}}catch (Exception e){e.printStackTrace();}jdbcUtil.closeConnection();}}

UserService.java(没有实现)

package com.service;/*** @program: LibraryDemo* @description:* @author: Casey Hu* @create: 2023-12-06 16:49**/public class UserService {
}

JDBCUtil.java

package com.util;import javax.sql.DataSource;
import java.sql.*;/*** @program: LibraryDemo* @description: JDBC工具类* @author: Casey Hu* @create: 2023-12-06 14:31**/public class JDBCUtil {public static Connection connection;public static String url="jdbc:mysql://localhost:3306/library-demo?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai";public static String user="root";public static String password="123456";public static Connection getConnection(){try {connection = DriverManager.getConnection(url,user,password);} catch (Exception e) {e.printStackTrace();}return connection;}//执行查询public static ResultSet executeQuery(String sql) {System.out.println("执行SQL："+sql);Connection conn=getConnection();ResultSet resultSet=null;try {Statement stmt=conn.createStatement();resultSet=stmt.executeQuery(sql);}catch (Exception e){e.printStackTrace();}return resultSet;}// 执行更新操作（插入、更新、删除）public static int executeUpdate(String sql) {System.out.println("执行SQL："+sql);Connection conn = getConnection();int result = 0;try {// 开始事务conn.setAutoCommit(false);Statement statement = conn.createStatement();result = statement.executeUpdate(sql);conn.commit();} catch (SQLException e) {// 回滚事务if (conn != null) {try {conn.rollback();} catch (SQLException ex) {ex.printStackTrace();}}e.printStackTrace();}return result;}// 关闭数据库连接public static void closeConnection() {if (connection != null) {try {connection.close();} catch (SQLException e) {e.printStackTrace();}}}}

StatementTest.java

package com.util;import com.service.LibraryService;import java.sql.*;/*** @program: LibraryDemo* @description:* @author: Casey Hu* @create: 2023-12-06 14:45**/public class StatementTest {public static void main(String[] args) throws ClassNotFoundException, SQLException {
//        //加载驱动
//        Class.forName("com.mysql.cj.jdbc.Driver");
//        //输入url、用户名、密码创建连接
//        //jdbc:mysql:是固定的写法，后面跟主机名localhost，3306是默认的MySQL端口号demo是数据库名称
//        //useUnicode=true是指是否使用Unicode字符集，赋值为true
//        //serverTimezone=UTC是指定时区时间为世界统一时间
//        //characterEncoding=utf-8是指定字符编码格式为UTF8
//        Connection connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/library-demo?useUnicode=true&characterEncoding=UTF-8&serverTimezone=Asia/Shanghai", "root", "123456");
//        //sql查询语句
//        String sql = "select * from user";
//        Statement statement = connection.createStatement();
//        //执行查询语句
//        ResultSet resultSet = statement.executeQuery(sql);
//        //结果遍历
//        while (resultSet.next()) {
//            Object id = resultSet.getObject("userId");
//            Object name = resultSet.getObject("userName");
//            Object password = resultSet.getObject("password");
//            Object phone = resultSet.getObject("phone");
//            System.out.println(id + "-" + name + "-" + password + "-" + phone);
//        }
//        //关闭资源
//        resultSet.close();
//        statement.close();
//        connection.close();
//        JDBCUtil jdbcUtil = new JDBCUtil();
//        User user=new User();
//        user.setUserName("李四");
//        user.setPassword("123456");
//        user.setEmail("XXXXXXXXXX");
//        user.setPhone("1235586865");
//        jdbcUtil.executeUpdate("INSERT INTO `user` (userName, password, email, phone, address) " +
//                "VALUES('"+user.getUserName()+"', '"+user.getPassword()+"', '"+user.getEmail()+"', '"+user.getPhone()+"', '"+user.getAddress()+"');");
//        ResultSet resultSet = jdbcUtil.executeQuery("select * from user");
//        //结果遍历
//        while (resultSet.next()) {
//            Object id = resultSet.getObject("userId");
//            Object name = resultSet.getObject("userName");
//            Object password = resultSet.getObject("password");
//            Object phone = resultSet.getObject("phone");
//            System.out.println(id + "-" + name + "-" + password + "-" + phone);
//        }
//        jdbcUtil.closeConnection();
//        Book book=new Book();
//        book.setBookName("晚熟的人");
//        book.setAuthor("莫言");
//        book.setPrice("100");
//        book.setBookImage("1111111");
//        book.setIntroduction("《晚熟的人》是中国当代作家莫言创作的中短篇小说集");
//        book.setISBN("978-7020-164-776");
//        book.setBookStatus(1);
//        book.setBookCount(10);LibraryService libraryService=new LibraryService();
//        libraryService.addBook(book);
//        Book book1 = libraryService.queryBook(book);
//        System.out.println(book1.toString());
//        User user=new User();
//        user.setUserId(1);//借阅图书
//        libraryService.borrowBook(book1,user,30);//归还libraryService.returnBook("1701968793273");}
}

结束

写个总结吧，有的功能，比如登录，多线程的那部分没有实现，因为不会啊。我整体做完最后特别大的感受就是，对于持久层的框架是非常有必要的，如果没有mybatis，这样一点一点的封装是非常麻烦的

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.hqwc.cn/news/258912.html

如若内容造成侵权/违法违规/事实不符，请联系编程知识网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

Leetcode—213.打家劫舍II【中等】

Leetcode—213.打家劫舍II【中等】

2023每日刷题&#xff08;五十二&#xff09; Leetcode—213.打家劫舍II 算法思路 实现代码 class Solution { public:// 左闭右开int rob1(vector<int>& nums, int start, int end) {int n nums.size();int f0 0, f1 0, new_f 0;for(int i start; i < end…
阅读更多...
挡墙边界提取

挡墙边界提取

基于点云对挡墙边界进行提取 算法思路 将点转到极坐标系下&#xff0c;并得到极坐标系下的索引值&#xff0c;并输出距离信息。 double getCellIndexFromPoints(double x, double y, int& chI) {// 计算点到原点的欧几里得距离double distance sqrt(x * x y * y);// 将…
阅读更多...
vue中组件传值方法

vue中组件传值方法

父组件给子组件传值 一、 1.在子组件标签中写入父组件传递数据 向下传递prop 2.在子组件内声明props选项接收父组件传递的数据 props:[,,] 父组件&#xff1a; <Header :msgmsg ></Header> 子组件&#xff1a; props:[msg], 二、 provide i…
阅读更多...
vue3 vue-router编程式导航（二）

vue3 vue-router编程式导航（二）

文章目录 一、跳转到指定路径1. query传参2. Params传参 二、前进/后退三、替换当前页 Vue Router提供了强大且灵活的编程式导航功能&#xff0c;能够通过代码来控制路由的切换和跳转。本篇博客将介绍如何在Vue 3应用程序中使用Vue Router进行编程式导航。 一、跳转到指定路径…
阅读更多...
markdown记录

markdown记录

文章目录 基础操作使用一级列表、二级列表 博文链接 基础操作 使用一级列表、二级列表 博文链接 CSDN-Markdown语法集锦 CSDN-markdown语法之如何使用LaTeX语法编写数学公式 CSDN Markdown简明教程1-关于Markdown CSDN Markdown简明教程2-基本使用 CSDN Markdown简明教程3-表…
阅读更多...
uni-app 微信小程序之好看的ui登录页面（五）

uni-app 微信小程序之好看的ui登录页面（五）

文章目录 1. 页面效果2. 页面样式代码 更多登录ui页面 uni-app 微信小程序之好看的ui登录页面&#xff08;一&#xff09; uni-app 微信小程序之好看的ui登录页面&#xff08;二&#xff09; uni-app 微信小程序之好看的ui登录页面&#xff08;三&#xff09; uni-app 微信小程…
阅读更多...
【教学类-35-05】17号的学号字帖（A4竖版1份）

【教学类-35-05】17号的学号字帖（A4竖版1份）

作品展示&#xff1a; 背景需求&#xff1a; 大四班17号男孩目前无法自主数学数字。他表示自己能够认识数字&#xff0c;但不会写。 保育老师说&#xff1a;我曾经教过他&#xff0c;抓着手示范的。但是他记不住。家里估计也不练习的。年龄还没到&#xff0c;下学期再看看能不…
阅读更多...
营收增速持续放缓,博通CEO期待AI崛起救场 | 百能云芯

营收增速持续放缓,博通CEO期待AI崛起救场 | 百能云芯

博通作为苹果等大型科技公司的芯片供应商&#xff0c;于周四发布了财报。尽管截至10月29日的第四季度营收增长了4%至93亿美元&#xff0c;符合市场预期&#xff0c;但增速已经降至2020年以来的最低水平。 由于企业客户和电信供应商在控制支出方面的谨慎态度&#xff0c;博通的销…
阅读更多...
tomcat配置管理员And配置访问静态资源

tomcat配置管理员And配置访问静态资源

配置管理员 打开 tomcat\conf\tomcat-users.xml <tomcat-users xmlns"http://tomcat.apache.org/xml"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation"http://tomcat.apache.org/xml tomcat-users.xsd"version&qu…
阅读更多...
Zabbix结合Grafana打造高逼格监控系统

Zabbix结合Grafana打造高逼格监控系统

&#x1f4e2;&#x1f4e2;&#x1f4e2;&#x1f4e3;&#x1f4e3;&#x1f4e3; 哈喽&#xff01;大家好&#xff0c;我是【IT邦德】&#xff0c;江湖人称jeames007&#xff0c;10余年DBA及大数据工作经验 一位上进心十足的【大数据领域博主】&#xff01;&#x1f61c;&am…
阅读更多...
总线（什么是南北桥？您都用过哪些总线？）

总线（什么是南北桥？您都用过哪些总线？）

什么是总线&#xff1f; 计算机系统中的总线&#xff08;Bus&#xff09;是指计算机设备和设备之间传输信息的公共数据通道&#xff0c;是连接计算机硬件系统内多种设备的通信线路&#xff0c;它的一个重要特征是由总线上的所有设备共享&#xff0c;因此可以将计算机系统内的多…
阅读更多...
Spingboot3详解（全网最详细，新建springboot项目并详解各种组件的用法）

Spingboot3详解（全网最详细，新建springboot项目并详解各种组件的用法）

一.Spring Initializr创建向导 1.新建一个空项目 2.在新创建的空项目里&#xff0c;新建Module 3. 选择Spring Initializr 4.选择Spring Boot的版本3以上 5.创建好的一个项目结构 controller包是自己创建的 6.项目结构分析 spingboot主程序 package com.example.boot;impor…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023