BasicStatementTask Class Reference

#include <AdhocStatement.h>

Public Member Functions
	BasicStatementTask (const char *sql, bool async=false)
	~BasicStatementTask ()
bool	Execute () override
QueryResultFuture	GetFuture () const
Public Member Functions inherited from SQLOperation
	SQLOperation ()
virtual	~SQLOperation ()
virtual int	call ()
virtual void	SetConnection (MySQLConnection *con)

Private Attributes
const char *	m_sql
bool	m_has_result
QueryResultPromise *	m_result

Additional Inherited Members
Public Attributes inherited from SQLOperation
MySQLConnection *	m_conn

Detailed Description

Raw, ad-hoc query.

Constructor & Destructor Documentation

BasicStatementTask::BasicStatementTask	(	const char *	sql,
		bool	async = false
	)

Basic, ad-hoc queries.

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

BasicStatementTask::~BasicStatementTask

(

)

{
 free((void*)m_sql);
 if (m_has_result && m_result != nullptr)
 delete m_result;
}

Member Function Documentation

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(NULL));
 return false;
 }

 m_result->set_value(QueryResult(result));
 return true;
 }

 return m_conn->Execute(m_sql);
}

Here is the call graph for this function:

QueryResultFuture BasicStatementTask::GetFuture ( ) const

inline

{ return m_result->get_future(); }

Here is the caller graph for this function:

Member Data Documentation

bool BasicStatementTask::m_has_result

private

QueryResultPromise* BasicStatementTask::m_result

private

const char* BasicStatementTask::m_sql

private

---

The documentation for this class was generated from the following files:

• src/server/database/Database/AdhocStatement.h
• src/server/database/Database/AdhocStatement.cpp