/*
* This file is part of the AzerothCore Project. See AUTHORS file for Copyright information
*
* This program is free software; you can redistribute it and/or modify it
* under the terms of the GNU Affero General Public License as published by the
* Free Software Foundation; either version 3 of the License, or (at your
* option) any later version.
*
* This program is distributed in the hope that it will be useful, but WITHOUT
* ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
* FITNESS FOR A PARTICULAR PURPOSE. See the GNU Affero General Public License for
* more details.
*
* You should have received a copy of the GNU General Public License along
* with this program. If not, see .
*/
#ifndef _PREPAREDSTATEMENT_H
#define _PREPAREDSTATEMENT_H
#include "Define.h"
#include "Duration.h"
#include "SQLOperation.h"
#include
#include
#include
#include
namespace Acore::Types
{
template
using is_default = std::enable_if_t || std::is_same_v, T>>;
template
using is_enum_v = std::enable_if_t>;
template
using is_non_string_view_v = std::enable_if_t>;
}
struct PreparedStatementData
{
std::variant<
bool,
uint8,
uint16,
uint32,
uint64,
int8,
int16,
int32,
int64,
float,
double,
std::string,
std::vector,
std::nullptr_t
> data;
template
static std::string ToString(T value);
static std::string ToString(std::nullptr_t /*value*/);
};
//- Upper-level class that is used in code
class AC_DATABASE_API PreparedStatementBase
{
friend class PreparedStatementTask;
public:
explicit PreparedStatementBase(uint32 index, uint8 capacity);
virtual ~PreparedStatementBase();
// Set numerlic and default binary
template
inline Acore::Types::is_default SetData(const uint8 index, T value)
{
SetValidData(index, value);
}
// Set enums
template
inline Acore::Types::is_enum_v SetData(const uint8 index, T value)
{
SetValidData(index, std::underlying_type_t(value));
}
// Set string_view
inline void SetData(const uint8 index, std::string_view value)
{
SetValidData(index, value);
}
// Set nullptr
inline void SetData(const uint8 index, std::nullptr_t = nullptr)
{
SetValidData(index);
}
// Set non default binary
template
inline void SetData(const uint8 index, std::array const& value)
{
std::vector vec(value.begin(), value.end());
SetValidData(index, vec);
}
// Set duration
template
inline void SetData(const uint8 index, std::chrono::duration<_Rep, _Period> const& value, bool convertToUin32 = true)
{
SetValidData(index, convertToUin32 ? static_cast(value.count()) : value.count());
}
// Set all
template
inline void SetArguments(Args&&... args)
{
SetDataTuple(std::make_tuple(std::forward(args)...));
}
[[nodiscard]] uint32 GetIndex() const { return m_index; }
[[nodiscard]] std::vector const& GetParameters() const { return statement_data; }
protected:
template
Acore::Types::is_non_string_view_v SetValidData(const uint8 index, T const& value);
void SetValidData(const uint8 index);
void SetValidData(const uint8 index, std::string_view value);
template
inline void SetDataTuple(std::tuple const& argsList)
{
std::apply
(
[this](Ts const&... arguments)
{
uint8 index{ 0 };
((SetData(index, arguments), index++), ...);
}, argsList
);
}
uint32 m_index;
//- Buffer of parameters, not tied to MySQL in any way yet
std::vector statement_data;
PreparedStatementBase(PreparedStatementBase const& right) = delete;
PreparedStatementBase& operator=(PreparedStatementBase const& right) = delete;
};
template
class PreparedStatement : public PreparedStatementBase
{
public:
explicit PreparedStatement(uint32 index, uint8 capacity) : PreparedStatementBase(index, capacity)
{
}
private:
PreparedStatement(PreparedStatement const& right) = delete;
PreparedStatement& operator=(PreparedStatement const& right) = delete;
};
//- Lower-level class, enqueuable operation
class AC_DATABASE_API PreparedStatementTask : public SQLOperation
{
public:
PreparedStatementTask(PreparedStatementBase* stmt, bool async = false);
~PreparedStatementTask() override;
bool Execute() override;
PreparedQueryResultFuture GetFuture() { return m_result->get_future(); }
protected:
PreparedStatementBase* m_stmt;
bool m_has_result;
PreparedQueryResultPromise* m_result;
};
#endif