From b5701bdb75e288249f9a4a6699b402f3a45e231f Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Minh=20V=C6=B0=C6=A1ng?= Date: Thu, 9 Nov 2023 08:46:09 +0700 Subject: [PATCH] Revert "Add CartDAOMySQLImpl class, implement CartDAO interface" This reverts commit 3bb7705593c9c964340b2624af8a5c177048093a. --- .../r7/dao/impl/mysql/CartDAOMySQLImpl.java | 100 ++++++++++++++++++ .../hardingadonis/r7/services/Singleton.java | 4 - 2 files changed, 100 insertions(+), 4 deletions(-) create mode 100644 src/main/java/io/hardingadonis/r7/dao/impl/mysql/CartDAOMySQLImpl.java diff --git a/src/main/java/io/hardingadonis/r7/dao/impl/mysql/CartDAOMySQLImpl.java b/src/main/java/io/hardingadonis/r7/dao/impl/mysql/CartDAOMySQLImpl.java new file mode 100644 index 0000000..43a3f95 --- /dev/null +++ b/src/main/java/io/hardingadonis/r7/dao/impl/mysql/CartDAOMySQLImpl.java @@ -0,0 +1,100 @@ +package io.hardingadonis.r7.dao.impl.mysql; + +import io.hardingadonis.r7.dao.*; +import io.hardingadonis.r7.model.*; +import io.hardingadonis.r7.services.*; +import java.sql.*; +import java.util.*; + +public class CartDAOMySQLImpl implements CartDAO { + + @Override + public List getAll(int userID) { + List list = new ArrayList<>(); + + try { + Connection conn = Singleton.dbContext.getConnection(); + + PreparedStatement smt = conn.prepareStatement("SELECT * FROM cart WHERE user_id = ?"); + smt.setInt(1, userID); + + ResultSet rs = smt.executeQuery(); + + while (rs.next()) { + int productID = rs.getInt("product_id"); + int amount = rs.getInt("amount"); + + list.add(new Cart(userID, productID, amount)); + } + + Singleton.dbContext.closeConnection(conn); + } catch (SQLException ex) { + System.err.println(ex.getMessage()); + } + + return list; + } + + @Override + public void insert(Cart obj) { + try { + Connection conn = Singleton.dbContext.getConnection(); + + PreparedStatement smt = conn.prepareStatement("INSERT INTO cart(user_id, product_id, amount) VALUES (?, ?, ?)"); + smt.setInt(1, obj.getUserID()); + smt.setInt(2, obj.getProductID()); + smt.setInt(3, obj.getAmount()); + + smt.executeUpdate(); + + Singleton.dbContext.closeConnection(conn); + } catch (SQLException ex) { + System.err.println(ex.getMessage()); + } + } + + @Override + public void update(Cart obj) { + try { + Connection conn = Singleton.dbContext.getConnection(); + + PreparedStatement smt = conn.prepareStatement("UPDATE cart SET amount WHERE user_id = ? AND product_id = ?"); + smt.setInt(1, obj.getAmount()); + smt.setInt(2, obj.getUserID()); + smt.setInt(3, obj.getProductID()); + + Singleton.dbContext.closeConnection(conn); + } catch (SQLException ex) { + System.err.println(ex.getMessage()); + } + } + + @Override + public void delete(int userID, int productID) { + try { + Connection conn = Singleton.dbContext.getConnection(); + + PreparedStatement smt = conn.prepareStatement("DELETE FROM cart WHERE user_id = ? AND product_id = ?"); + smt.setInt(1, userID); + smt.setInt(2, productID); + + Singleton.dbContext.closeConnection(conn); + } catch (SQLException ex) { + System.err.println(ex.getMessage()); + } + } + + @Override + public void deleteAll(int userID) { + try { + Connection conn = Singleton.dbContext.getConnection(); + + PreparedStatement smt = conn.prepareStatement("DELETE FROM cart WHERE user_id = ?"); + smt.setInt(1, userID); + + Singleton.dbContext.closeConnection(conn); + } catch (SQLException ex) { + System.err.println(ex.getMessage()); + } + } +} diff --git a/src/main/java/io/hardingadonis/r7/services/Singleton.java b/src/main/java/io/hardingadonis/r7/services/Singleton.java index 9dca176..72c521b 100644 --- a/src/main/java/io/hardingadonis/r7/services/Singleton.java +++ b/src/main/java/io/hardingadonis/r7/services/Singleton.java @@ -9,8 +9,6 @@ public class Singleton { public static DBContext dbContext; public static AdminDAO adminDAO; - - public static CartDAO cartDAO; public static CategoryDAO categoryDAO; @@ -22,8 +20,6 @@ public class Singleton { dbContext = new DBContextMySQLImpl(); adminDAO = new AdminDAOMySQLImpl(); - - cartDAO = new CartDAOMySQLImpl(); categoryDAO = new CategoryDAOMySQLImpl();