diff --git a/init.sql b/init.sql index c682f07..47d0a99 100644 --- a/init.sql +++ b/init.sql @@ -17,8 +17,7 @@ CREATE TABLE IF NOT EXISTS publisher VARCHAR(255), oldprice DECIMAL(10, 2), newprice DECIMAL(10, 2), - href VARCHAR(255), - created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP + href VARCHAR(255) ); INSERT INTO diff --git a/src/client/Client.java b/src/client/Client.java index a5ee76a..8d3ec80 100644 --- a/src/client/Client.java +++ b/src/client/Client.java @@ -48,7 +48,7 @@ public class Client { OutputStream os = socket.getOutputStream(); write = new PrintWriter(new OutputStreamWriter(os, "utf-8")); if (!login()) { - System.out.println("登录失败，欢迎下次访问"); + System.out.println("Login failed, welcome to visit next time!"); System.exit(0); } int choose = menu(); @@ -81,14 +81,14 @@ public class Client { choose = menu(); } close(); - System.out.println("您已退出程序，欢迎下次使用！"); + System.out.println("You have exited the program. Welcome to use it next time!"); } public static void close() throws Exception { Map map = new HashMap<>(); map.put("code", 8); String sendData = new Gson().toJson(map); - System.out.println("发送给服务器：" + sendData); + System.out.println("Send to server: " + sendData); write.println(sendData); write.flush(); if (write != null) @@ -101,9 +101,9 @@ public class Client { public static boolean login() throws Exception { for (int i = 1; i <= 3; i++) { - System.out.println("请输入用户名:"); + System.out.println("Please enter your user name:"); String userName = scan.nextLine(); - System.out.println("请输入密码:"); + System.out.println("Please enter your password:"); String passsord = scan.nextLine(); Map map = new HashMap<>(); map.put("code", 0); @@ -113,15 +113,15 @@ public class Client { Gson gson = new Gson(); map.put("data", gson.toJson(user)); String sendData = gson.toJson(map); - System.out.println("发送给服务器：" + sendData); + System.out.println("Send to server: " + sendData); String responseData = send(sendData); - System.out.println("接收到服务器端的响应：" + responseData); + System.out.println("Received the response from the server: " + responseData); JsonElement element = JsonParser.parseString(responseData); JsonObject obj = element.getAsJsonObject(); int returnCode = obj.get("code").getAsInt(); String returnData = obj.get("data").getAsString(); if (returnCode == 0) - System.out.println("登录失败：" + returnData); + System.out.println("Login failed: " + returnData); else { currentUser = gson.fromJson(returnData, User.class); return true; @@ -131,18 +131,19 @@ public class Client { } public static int menu() { - System.out.println("======图书数据助理系统======="); - System.out.println("当前用户：" + currentUser.getName()); - System.out.println("1.图书信息显示"); - System.out.println("2.当当网站爬取"); - System.out.println("3.查询"); - System.out.println("4.删除"); - System.out.println("5.修改"); - System.out.println("6.导出到csv文件"); - System.out.println("7.导出到xls文件"); - System.out.println("8.退出"); - System.out.println("请输入选项(1-8):"); + System.out.println("======== Library Data Assistant ========"); + System.out.println("Current user: " + currentUser.getName()); + System.out.println("1. Display library data;"); + System.out.println("2. Crawling library data;"); + System.out.println("3. Querying library data;"); + System.out.println("4. Deleting library data;"); + System.out.println("5. Modifying library data;"); + System.out.println("6. Exporting library data to a CSV file;"); + System.out.println("7. Exporting library data to an XLS file;"); + System.out.println("8. Exiting Assistant."); + System.out.println("Please enter options (1-8):"); int choose = scan.nextInt(); + scan.nextLine(); return choose; } @@ -189,34 +190,35 @@ public class Client { public static void query() { String sql = null; - System.out.println("======查询图书======="); - System.out.println("1.按名称查询"); - System.out.println("2.按作者查询"); - System.out.println("3.按出版社查询"); - System.out.println("4.按价格查询"); - System.out.println("5.退出"); - System.out.println("请输入选项(1-5):"); + System.out.println("====== Querying library data ======="); + System.out.println("1. Querying by title;"); + System.out.println("2. Querying by author;"); + System.out.println("3. Querying by publisher;"); + System.out.println("4. Querying by price;"); + System.out.println("5. Return to previous menu."); + System.out.println("Please enter options (1-5):"); int n = 0; n = scan.nextInt(); + scan.nextLine(); switch (n) { case 1: - sql = "select * from book where title like ?"; - System.out.println("请输入名称:"); + sql = "select * from book where title = ?"; + System.out.println("Please enter the title:"); outputQuery(sql); break; case 2: - sql = "select * from book where author like ?"; - System.out.println("请输入作者:"); + sql = "select * from book where author = ?"; + System.out.println("Please enter the author:"); outputQuery(sql); break; case 3: - sql = "select * from book where publisher like ?"; - System.out.println("请输入出版社:"); + sql = "select * from book where publisher = ?"; + System.out.println("Please enter the publisher:"); outputQuery(sql); break; case 4: - sql = "select * from book where newprice like ?"; - System.out.println("请输入价格:"); + sql = "select * from book where newprice = ?"; + System.out.println("Please enter the price:"); outputQuery(sql); break; default: @@ -227,10 +229,10 @@ public class Client { public static void outputQuery(String sql) { con = DBConnection.getConnection(); String title, author, pubilsher, oldprice, newprice, url; - String inquire = scan.next(); + String inquire = scan.nextLine(); try { ps = con.prepareStatement(sql); - ps.setString(1, '%' + inquire + '%'); + ps.setString(1, inquire); rs = ps.executeQuery(); while (rs.next()) { title = rs.getString(1); @@ -239,12 +241,8 @@ public class Client { oldprice = rs.getString(4); newprice = rs.getString(5); url = rs.getString(6); - System.out.println("书名:" + title); - System.out.println("作者:" + author); - System.out.println("出版社:" + pubilsher); - System.out.println("原价格:" + oldprice); - System.out.println("折后价格:" + newprice); - System.out.println("详情地址:" + url); + System.out.println("Title: " + title + ", Author: " + author + ", Publisher: " + pubilsher + + ", Original Price: " + oldprice + ", Discounted Price: " + newprice + ", URL: " + url); } rs.close(); } catch (Exception e) { @@ -255,16 +253,16 @@ public class Client { public static void delete() { con = DBConnection.getConnection(); - System.out.println("请输入书名"); - String bookname = scan.next(); - String sql = "delete from book where title like ?"; + System.out.println("Please enter the title:"); + String title = scan.nextLine(); + String sql = "delete from book where title = ?"; try { ps = con.prepareStatement(sql); - ps.setString(1, '%' + bookname + '%'); + ps.setString(1, title); ps.executeUpdate(); - System.out.println("删除成功"); + System.out.println("Delete successfully!"); } catch (Exception e) { - System.err.println("删除失败"); + System.err.println("Delete failed!"); } DBConnection.close(con, ps); } @@ -272,25 +270,26 @@ public class Client { public static void update() { con = DBConnection.getConnection(); String sql = null; - System.out.println("======修改图书======="); - System.out.println("1.修改作者姓名"); - System.out.println("2.修改出版社"); - System.out.println("3.修改价格"); - System.out.println("4.退出"); - System.out.println("请输入需要修改的图书的名称"); - String title = scan.next(); - System.out.println("请输入选项(1-4):"); + System.out.println("Please enter the title:"); + String title = scan.nextLine(); + System.out.println("====== Modifying library data ======="); + System.out.println("1. Modifying author;"); + System.out.println("2. Modifying publisher;"); + System.out.println("3. Modifying price;"); + System.out.println("4. Return to previous menu."); + System.out.println("Please enter options (1-4):"); int n = 0; n = scan.nextInt(); - String name = null; + scan.nextLine(); + String inquery = null; switch (n) { case 1: - System.out.println("请输入修改后的作责姓名"); - name = scan.next(); + System.out.println("Please enter the modified author:"); + inquery = scan.nextLine(); sql = "update book set author = ? where title = ?"; try { ps = con.prepareStatement(sql); - ps.setString(1, name); + ps.setString(1, inquery); ps.setString(2, title); ps.executeUpdate(); } catch (Exception e) { @@ -298,12 +297,12 @@ public class Client { } break; case 2: - System.out.println("请输入修改后的出版社名"); - name = scan.next(); + System.out.println("Please enter the modified publisher:"); + inquery = scan.nextLine(); sql = "update book set publisher = ? where title = ?"; try { ps = con.prepareStatement(sql); - ps.setString(1, name); + ps.setString(1, inquery); ps.setString(2, title); ps.executeUpdate(); } catch (Exception e) { @@ -311,8 +310,8 @@ public class Client { } break; case 3: - System.out.println("请输入修改后的价格"); - name = scan.next(); + System.out.println("Please enter the modified price:"); + inquery = scan.nextLine(); sql = "update book set oldprice = newprice where title = ?"; String sql2 = "update book set newprice = ? where title = ?"; try { @@ -320,7 +319,7 @@ public class Client { ps.setString(1, title); ps.executeUpdate(); ps = con.prepareStatement(sql2); - ps.setString(1, name); + ps.setString(1, inquery); ps.setString(2, title); ps.executeUpdate(); } catch (Exception e) { diff --git a/src/server/Server.java b/src/server/Server.java index 101837d..ad5af49 100644 --- a/src/server/Server.java +++ b/src/server/Server.java @@ -9,10 +9,10 @@ public class Server { public static void main(String[] args) throws Exception { int port = 9999; ServerSocket server = new ServerSocket(port); - System.out.println("服务器正在 9999 端口侦听客户端请求"); + System.out.println("The server is listening for client connection requests on port " + port + "."); while (true) { Socket socket = server.accept(); - System.out.println("客户端" + socket.getInetAddress().getHostAddress() + "成功连接"); + System.out.println("Client " + socket.getInetAddress().getHostAddress() + " successfully connected!"); new HandleThread(socket).start(); } } diff --git a/src/server/thread/HandleThread.java b/src/server/thread/HandleThread.java index 60ec2e3..fe12d0e 100644 --- a/src/server/thread/HandleThread.java +++ b/src/server/thread/HandleThread.java @@ -41,7 +41,7 @@ public class HandleThread extends Thread { while (true) { try { String receiveStr = buf.readLine(); - System.out.println("接收到客户端的请求数据:" + receiveStr); + System.out.println("Receive the client's request data: " + receiveStr); JsonElement element = JsonParser.parseString(receiveStr); JsonObject obj = element.getAsJsonObject(); int code = obj.get("code").getAsInt(); @@ -61,7 +61,7 @@ public class HandleThread extends Thread { case 2: break; default: - System.out.println("命令无效！"); + System.out.println("Invalid command!"); break; } write.println(response); @@ -70,7 +70,7 @@ public class HandleThread extends Thread { e.printStackTrace(); } } - System.out.println("客户端退出！"); + System.out.println("Client exited!"); } public void close() throws Exception { @@ -89,7 +89,7 @@ public class HandleThread extends Thread { if (user == null) { Map map = new HashMap<>(); map.put("code", 0); - map.put("data", "用户名不存在"); + map.put("data", "Username does not exist!"); responseData = new Gson().toJson(map); } else { if (loginUser.getPassword().equals(user.getPassword())) { @@ -100,7 +100,7 @@ public class HandleThread extends Thread { } else { Map map = new HashMap<>(); map.put("code", 0); - map.put("data", "密码错误"); + map.put("data", "Wrong password!"); responseData = new Gson().toJson(map); } } diff --git a/src/server/tools/DBConnection.java b/src/server/tools/DBConnection.java index 183cd76..4daf327 100644 --- a/src/server/tools/DBConnection.java +++ b/src/server/tools/DBConnection.java @@ -7,7 +7,7 @@ import java.sql.SQLException; public class DBConnection { private final static String driverName = "com.mysql.cj.jdbc.Driver"; - private final static String url = "jdbc:mysql://localhost:3306/lda?useUnicode=true&characterEncoding=utf-8&useSSL=false&serverTimezone=GMT"; + private final static String url = "jdbc:mysql://localhost:3306/lda?allowPublicKeyRetrieval=true&useSSL=false"; private final static String user = "root"; private final static String password = "516849"; static { diff --git a/src/server/tools/crawling/Book.java b/src/server/tools/crawling/Book.java index 0599752..73208bd 100644 --- a/src/server/tools/crawling/Book.java +++ b/src/server/tools/crawling/Book.java @@ -69,7 +69,6 @@ public class Book { } public String toString() { - return "Book{title = " + title + ", author = " + author + ", publisher = " + publisher + ", oldprice = " - + oldprice + ", newprice = " + newprice + ", href = " + href + "}"; + return "Title: " + this.title + ", Author: " + this.author + ", Publisher: " + this.publisher + ", Original Price: " + this.oldprice + ", Discounted Price: " + this.newprice + ", URL: " + this.href; } } diff --git a/src/server/tools/crawling/CrawlerTools.java b/src/server/tools/crawling/CrawlerTools.java index e5232cd..f815501 100644 --- a/src/server/tools/crawling/CrawlerTools.java +++ b/src/server/tools/crawling/CrawlerTools.java @@ -30,7 +30,7 @@ public class CrawlerTools { while ((info = read.readLine()) != null) buf.append(info); } else - System.out.println("出错：" + code); + System.out.println("Error! Response code: " + code + "."); } catch (Exception e) { e.printStackTrace(); } finally {