mirror of
https://github.com/pocoproject/poco.git
synced 2026-01-12 00:50:13 +01:00
7313ccfb27
* TypeHandler for std::tuple, used to implement TypeHandler for Poco::Tuple * Removed obsolete using declarations in Data.cppm * TypeHander: added missing typename * Explicitly delete constructors of AbstractTypeHandler * TypeHandler specialization for std::optional * Data/MySQL: modernize loops and usage of virtual/override * Poco::Tuple: formatting fix * Poco::Data: more consistent usage of virtual/override and = delete * Added test cases for std::tuple and std::optional (for MySQL and PostgreSQL) * Poco::Data: more override annotations * Added testcases for st::tuple and std::optional to SQLite. * chore(Data): Improvements suggested by clang-tidy --------- Co-authored-by: Matej Kenda <matejken@gmail.com>
176 lines
2.8 KiB
C++
176 lines
2.8 KiB
C++
//
|
|
// MySQLException.cpp
|
|
//
|
|
// Library: Data/MySQL
|
|
// Package: MySQL
|
|
// Module: MySQLStatementImpl
|
|
//
|
|
// Copyright (c) 2008, Applied Informatics Software Engineering GmbH.
|
|
// and Contributors.
|
|
//
|
|
// SPDX-License-Identifier: BSL-1.0
|
|
//
|
|
|
|
|
|
#include "Poco/Data/MySQL/MySQLStatementImpl.h"
|
|
|
|
|
|
namespace Poco {
|
|
namespace Data {
|
|
namespace MySQL {
|
|
|
|
|
|
MySQLStatementImpl::MySQLStatementImpl(SessionImpl& h) :
|
|
Poco::Data::StatementImpl(h),
|
|
_stmt(h.handle()),
|
|
_pBinder(new Binder),
|
|
_pExtractor(new Extractor(_stmt, _metadata)),
|
|
_hasNext(NEXT_DONTKNOW)
|
|
{
|
|
}
|
|
|
|
|
|
MySQLStatementImpl::~MySQLStatementImpl()
|
|
{
|
|
}
|
|
|
|
|
|
std::size_t MySQLStatementImpl::columnsReturned() const
|
|
{
|
|
return _metadata.columnsReturned();
|
|
}
|
|
|
|
|
|
int MySQLStatementImpl::affectedRowCount() const
|
|
{
|
|
return _stmt.getAffectedRowCount();
|
|
}
|
|
|
|
|
|
const MetaColumn& MySQLStatementImpl::metaColumn(std::size_t pos) const
|
|
{
|
|
return _metadata.metaColumn(pos);
|
|
}
|
|
|
|
|
|
bool MySQLStatementImpl::hasNext()
|
|
{
|
|
if (_hasNext == NEXT_DONTKNOW)
|
|
{
|
|
if (_metadata.columnsReturned() == 0)
|
|
{
|
|
return false;
|
|
}
|
|
|
|
if (_stmt.fetch())
|
|
{
|
|
_hasNext = NEXT_TRUE;
|
|
return true;
|
|
}
|
|
|
|
_hasNext = NEXT_FALSE;
|
|
return false;
|
|
}
|
|
else if (_hasNext == NEXT_TRUE)
|
|
{
|
|
return true;
|
|
}
|
|
|
|
return false;
|
|
}
|
|
|
|
|
|
std::size_t MySQLStatementImpl::next()
|
|
{
|
|
if (!hasNext())
|
|
throw StatementException("No data received");
|
|
|
|
std::size_t pos = 0;
|
|
|
|
for (auto& ex: extractions())
|
|
{
|
|
ex->extract(pos);
|
|
pos += ex->numOfColumnsHandled();
|
|
}
|
|
|
|
_hasNext = NEXT_DONTKNOW;
|
|
return 1;
|
|
}
|
|
|
|
|
|
bool MySQLStatementImpl::canBind() const
|
|
{
|
|
bool ret = false;
|
|
|
|
if ((_stmt.state() >= StatementExecutor::STMT_COMPILED) && !bindings().empty())
|
|
ret = (*bindings().begin())->canBind();
|
|
|
|
return ret;
|
|
}
|
|
|
|
|
|
bool MySQLStatementImpl::canCompile() const
|
|
{
|
|
return (_stmt.state() < StatementExecutor::STMT_COMPILED);
|
|
}
|
|
|
|
|
|
void MySQLStatementImpl::compileImpl()
|
|
{
|
|
try
|
|
{
|
|
_metadata.reset();
|
|
_stmt.prepare(toString());
|
|
_metadata.init(_stmt);
|
|
|
|
if (_metadata.columnsReturned() > 0)
|
|
_stmt.bindResult(_metadata.row());
|
|
}
|
|
catch (MySQLException& exc)
|
|
{
|
|
static_cast<SessionImpl&>(session()).setLastError(exc.code());
|
|
throw;
|
|
}
|
|
static_cast<SessionImpl&>(session()).setLastError(0);
|
|
}
|
|
|
|
|
|
void MySQLStatementImpl::bindImpl()
|
|
{
|
|
std::size_t pos = 0;
|
|
for (auto& b: bindings())
|
|
{
|
|
if (!b->canBind())
|
|
break;
|
|
b->bind(pos);
|
|
pos += b->numOfColumnsHandled();
|
|
}
|
|
_stmt.bindParams(_pBinder->getBindArray(), _pBinder->size());
|
|
try
|
|
{
|
|
_stmt.execute();
|
|
}
|
|
catch (MySQLException& exc)
|
|
{
|
|
static_cast<SessionImpl&>(session()).setLastError(exc.code());
|
|
throw;
|
|
}
|
|
_hasNext = NEXT_DONTKNOW;
|
|
static_cast<SessionImpl&>(session()).setLastError(0);
|
|
}
|
|
|
|
|
|
Poco::Data::AbstractExtractor::Ptr MySQLStatementImpl::extractor()
|
|
{
|
|
return _pExtractor;
|
|
}
|
|
|
|
|
|
Poco::Data::AbstractBinder::Ptr MySQLStatementImpl::binder()
|
|
{
|
|
return _pBinder;
|
|
}
|
|
|
|
|
|
} } } // namespace Poco::Data::MySQL
|