aboutsummaryrefslogtreecommitdiff
path: root/src/server/database/Database/QueryHolder.cpp
diff options
context:
space:
mode:
authorShauren <shauren.trinity@gmail.com>2023-12-15 12:06:59 +0100
committerfunjoker <funjoker109@gmail.com>2023-12-19 14:14:23 +0100
commite0d45f6dff3afe5caa38c48646f23d966c8c03a1 (patch)
tree6d1b9fef794cec268fa86398d9bb8957cf99f5ba /src/server/database/Database/QueryHolder.cpp
parent575fc7fde329ab47e517357d74a47316c6413544 (diff)
Core/Database: Replace DatabaseWorker with asio io_context
(cherry picked from commit d958bfd0f32bfe798809b72c1b51c990edfe141c)
Diffstat (limited to 'src/server/database/Database/QueryHolder.cpp')
-rw-r--r--src/server/database/Database/QueryHolder.cpp11
1 files changed, 4 insertions, 7 deletions
diff --git a/src/server/database/Database/QueryHolder.cpp b/src/server/database/Database/QueryHolder.cpp
index 7908c2c0206..ee76a087cf0 100644
--- a/src/server/database/Database/QueryHolder.cpp
+++ b/src/server/database/Database/QueryHolder.cpp
@@ -72,16 +72,13 @@ void SQLQueryHolderBase::SetSize(size_t size)
m_queries.resize(size);
}
-SQLQueryHolderTask::~SQLQueryHolderTask() = default;
-
-bool SQLQueryHolderTask::Execute()
+bool SQLQueryHolderTask::Execute(MySQLConnection* conn, SQLQueryHolderBase* holder)
{
/// execute all queries in the holder and pass the results
- for (size_t i = 0; i < m_holder->m_queries.size(); ++i)
- if (PreparedStatementBase* stmt = m_holder->m_queries[i].first)
- m_holder->SetPreparedResult(i, m_conn->Query(stmt));
+ for (size_t i = 0; i < holder->m_queries.size(); ++i)
+ if (PreparedStatementBase* stmt = holder->m_queries[i].first)
+ holder->SetPreparedResult(i, conn->Query(stmt));
- m_result.set_value();
return true;
}