#include <QueryHolder.h>

Public Member Functions
	SQLQueryHolderTask (SQLQueryHolder *holder)

	~SQLQueryHolderTask ()

bool	Execute () override

QueryResultHolderFuture	GetFuture ()

Public Member Functions inherited from SQLOperation
	SQLOperation ()

virtual	~SQLOperation ()

virtual int	call ()

virtual void	SetConnection (MySQLConnection *con)

Private Attributes
SQLQueryHolder *	m_holder

QueryResultHolderPromise	m_result

bool	m_executed

Additional Inherited Members
Public Attributes inherited from SQLOperation
MySQLConnection *	m_conn

Constructor & Destructor Documentation

SQLQueryHolderTask::SQLQueryHolderTask ( SQLQueryHolder * holder )

inline

58 : m_holder(holder), m_executed(false) { }

SQLQueryHolderTask::m_executed

bool m_executed

Definition: QueryHolder.h:54

SQLQueryHolderTask::m_holder

SQLQueryHolder * m_holder

Definition: QueryHolder.h:52

SQLQueryHolderTask::~SQLQueryHolderTask ( )

 {
  if (!m_executed)
  delete m_holder;
 }

Member Function Documentation

bool SQLQueryHolderTask::Execute ( )

overridevirtual

we can do this, we are friends

execute all queries in the holder and pass the results

Implements SQLOperation.

 {
  m_executed = true;
 
  if (!m_holder)
  return false;
 
  std::vector<SQLQueryHolder::SQLResultPair> &queries = m_holder->m_queries;
 
  for (size_t i = 0; i < queries.size(); i++)
  {
  if (SQLElementData* data = &queries[i].first)
  {
  switch (data->type)
  {
  case SQL_ELEMENT_RAW:
  {
  char const* sql = data->element.query;
  if (sql)
  m_holder->SetResult(i, m_conn->Query(sql));
  break;
  }
  case SQL_ELEMENT_PREPARED:
  {
  PreparedStatement* stmt = data->element.stmt;
  if (stmt)
  m_holder->SetPreparedResult(i, m_conn->Query(stmt));
  break;
  }
  }
  }
  }
 
  m_result.set_value(m_holder);
  return true;
 }