db = Database::connect(); } public function add($userId, $productId, $quantity): bool { $stmt = $this->db->prepare("INSERT INTO cart (user_id, product_id, quantity) VALUES (?, ?, ?) ON DUPLICATE KEY UPDATE quantity = quantity + VALUES(quantity)"); return $stmt->execute([$userId, $productId, $quantity]); } public function remove($userId, $itemId): bool { $stmt = $this->db->prepare("DELETE FROM cart WHERE user_id = ? AND id = ?"); return $stmt->execute([$userId, $itemId]); } public function getItems($userId): array { $stmt = $this->db->prepare("SELECT * FROM cart WHERE user_id = ?"); $stmt->execute([$userId]); return $stmt->fetchAll(\PDO::FETCH_ASSOC); } public function clear($userId): bool { $stmt = $this->db->prepare("DELETE FROM cart WHERE user_id = ?"); return $stmt->execute([$userId]); } }