git/metabuilder
1
0
Fork 0
mirror of https://github.com/johndoe6345789/metabuilder.git synced 2026-04-25 22:34:56 +00:00
Code Issues Packages Projects Releases Wiki Activity

code: sql,hpp,dbal (1 files)

Browse Source
This commit is contained in:
JohnDoe6345789
2025-12-26 05:04:54 +00:00
parent e2b85d945b
commit aaaeb72fb8
1 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

12
dbal/cpp/src/adapters/sql/sql_adapter.hpp
View File

@@ -2,6 +2,8 @@
#define DBAL_SQL_ADAPTER_HPP
#include <algorithm>
#include <cctype>
#include <chrono>
#include <map>
#include <sstream>
#include <string>
@@ -49,7 +51,7 @@ public:
Result<User> createUser(const CreateUserInput& input) override {
auto conn = pool_.acquire();
if (!conn) {
return Error::databaseError("Unable to acquire SQL connection");
return Error::internal("Unable to acquire SQL connection");
}
ConnectionGuard guard(pool_, conn);
@@ -76,7 +78,7 @@ public:
Result<User> getUser(const std::string& id) override {
auto conn = pool_.acquire();
if (!conn) {
return Error::databaseError("Unable to acquire SQL connection");
return Error::internal("Unable to acquire SQL connection");
}
ConnectionGuard guard(pool_, conn);
@@ -98,7 +100,7 @@ public:
Result<User> updateUser(const std::string& id, const UpdateUserInput& input) override {
auto conn = pool_.acquire();
if (!conn) {
return Error::databaseError("Unable to acquire SQL connection");
return Error::internal("Unable to acquire SQL connection");
}
ConnectionGuard guard(pool_, conn);
@@ -142,7 +144,7 @@ public:
Result<bool> deleteUser(const std::string& id) override {
auto conn = pool_.acquire();
if (!conn) {
return Error::databaseError("Unable to acquire SQL connection");
return Error::internal("Unable to acquire SQL connection");
}
ConnectionGuard guard(pool_, conn);
@@ -163,7 +165,7 @@ public:
Result<std::vector<User>> listUsers(const ListOptions& options) override {
auto conn = pool_.acquire();
if (!conn) {
return Error::databaseError("Unable to acquire SQL connection");
return Error::internal("Unable to acquire SQL connection");
}
ConnectionGuard guard(pool_, conn);