#include "AdhocStatement.h"

Inheritance diagram for BasicStatementTask:

Public Member Functions
	BasicStatementTask (std::string_view sql, bool async=false)

	~BasicStatementTask ()

bool	Execute () override

QueryResultFuture	GetFuture () const

Public Member Functions inherited from SQLOperation
	SQLOperation ()=default

virtual	~SQLOperation ()=default

virtual int	call ()

virtual bool	Execute ()=0

virtual void	SetConnection (MySQLConnection *con)

Private Attributes
std::string	m_sql

bool	m_has_result

QueryResultPromise *	m_result

Additional Inherited Members
Public Attributes inherited from SQLOperation
MySQLConnection *	m_conn {nullptr}

Detailed Description

Raw, ad-hoc query.

Constructor & Destructor Documentation

◆ BasicStatementTask()

BasicStatementTask::BasicStatementTask	(	std::string_view	sql,
		bool	async = `false`
	)

Basic, ad-hoc queries.

                                                                     : m_result(nullptr)
{
    m_sql = std::string(sql);
    m_has_result = async; // If the operation is async, then there's a result
 
    if (async)
        m_result = new QueryResultPromise();
}

References m_has_result, m_result, and m_sql.

◆ ~BasicStatementTask()

BasicStatementTask::~BasicStatementTask ( )

{
    m_sql.clear();
    if (m_has_result && m_result)
        delete m_result;
}

References m_has_result, m_result, and m_sql.

Member Function Documentation

◆ Execute()

bool BasicStatementTask::Execute ( )

overridevirtual

Implements SQLOperation.

{
    if (m_has_result)
    {
        ResultSet* result = m_conn->Query(m_sql);
        if (!result || !result->GetRowCount() || !result->NextRow())
        {
            delete result;
            m_result->set_value(QueryResult(nullptr));
            return false;
        }
 
        m_result->set_value(QueryResult(result));
        return true;
    }
 
    return m_conn->Execute(m_sql);
}