From d18ace59a913577971f3bc9a924b34366872fce2 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=D0=90=D0=BD=D1=82=D0=BE=D0=BD?= <a.sysoev@b2b-center.ru>
Date: Sun, 31 Aug 2025 09:49:57 +0300
Subject: [PATCH] =?UTF-8?q?DAO=20-=20=D0=B4=D0=BE=D0=B2=D0=B5=D0=B4=D0=B5?=
 =?UTF-8?q?=D0=BD=D0=B8=D0=B5=20=D0=B4=D0=BE=20=D0=BA=D0=BE=D0=BD=D1=86?=
 =?UTF-8?q?=D0=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/DAO/IUserDAO.h       |  2 +-
 src/DAO/MySQLUserDAO.cpp | 44 +++++++++++++++++++++++++++++++++++++---
 src/DAO/MySQLUserDAO.h   |  2 +-
 3 files changed, 43 insertions(+), 5 deletions(-)

diff --git a/src/DAO/IUserDAO.h b/src/DAO/IUserDAO.h
index 5779866..fa8d4ab 100644
--- a/src/DAO/IUserDAO.h
+++ b/src/DAO/IUserDAO.h
@@ -16,7 +16,7 @@ public:
 
   virtual std::optional<User> GetByLogin(std::string login) = 0;
 
-  virtual std::vector<User> GetAll(size_t limit, size_t offset) = 0;
+  virtual std::pair<bool, std::vector<User>> GetAll(size_t limit, size_t offset) = 0;
 
   virtual bool Update(const User& u) = 0;
 
diff --git a/src/DAO/MySQLUserDAO.cpp b/src/DAO/MySQLUserDAO.cpp
index 1485c14..4704724 100644
--- a/src/DAO/MySQLUserDAO.cpp
+++ b/src/DAO/MySQLUserDAO.cpp
@@ -47,11 +47,49 @@ optional<User> MySQLUserDAO::GetByLogin(string login)
   return GetSingleUserBySQLResult(std::move(sql_result));
 }
 
-vector<User> MySQLUserDAO::GetAll(size_t limit, size_t offset)
+pair<bool, vector<User>> MySQLUserDAO::GetAll(size_t limit, size_t offset)
 {
-  vector<User> users{};
+  mysqlx::SqlResult sql_result = session_
+                                 .sql("SELECT * FROM `up_and_down`.`users` LIMIT ? OFFSET ?;"s)
+                                 .bind(limit, offset)
+                                 .execute();
+  list<mysqlx::Row> rows = sql_result.fetchAll();
+  pair<bool, vector<User>> ret;
 
-  return {};
+  if (!rows.size())
+  {
+    ret.first = true
+    ;
+    ret.second = vector<User>{};
+
+    return ret;
+  }
+
+  ret.first = rows.size() < limit + 1;
+  ret.second = vector<User>{};
+
+  ret.second.reserve(limit);
+
+  for (const auto& row : rows)
+  {
+    if (!limit)
+    {
+      break;
+    }
+
+    User user;
+
+    string user_uuid = row[0].get<string>();
+    string user_login = row[1].get<string>();
+
+    user.SetLogin(user_login);
+    user.SetUUID(user_uuid);
+
+    ret.second.push_back(std::move(user));
+    --limit;
+  }
+
+  return ret;
 }
 
 bool MySQLUserDAO::Update(const User& u)
diff --git a/src/DAO/MySQLUserDAO.h b/src/DAO/MySQLUserDAO.h
index 84c4652..6cbea20 100644
--- a/src/DAO/MySQLUserDAO.h
+++ b/src/DAO/MySQLUserDAO.h
@@ -16,7 +16,7 @@ public:
 
   std::optional<User> GetByLogin(std::string login) override;
 
-  std::vector<User> GetAll(size_t limit, size_t offset) override;
+  std::pair<bool, std::vector<User>> GetAll(size_t limit, size_t offset) override;
 
   bool Update(const User& u) override;