ibpp_internals::StatementImpl Class Reference

#include <_ibpp.h>

Inheritance diagram for ibpp_internals::StatementImpl:

---

Detailed Description

Definition at line 1057 of file _ibpp.h.

Public Member Functions
IBPP::IStatement *	AddRef ()
int	AffectedRows ()
void	AttachDatabaseImpl (DatabaseImpl *)
void	AttachTransactionImpl (TransactionImpl *)
void	Close ()
const char *	ColumnAlias (int)
const char *	ColumnName (int)
int	ColumnNum (const std::string &)
int	ColumnNumAlias (const std::string &)
int	Columns ()
int	ColumnScale (int)
int	ColumnSize (int)
int	ColumnSubtype (int)
const char *	ColumnTable (int)
IBPP::SDT	ColumnType (int)
void	CursorExecute (const std::string &cursor)
void	CursorExecute (const std::string &cursor, const std::string &sql)
IBPP::Database	DatabasePtr () const
void	DetachDatabaseImpl ()
void	DetachTransactionImpl ()
void	Execute ()
void	Execute (const std::string &sql)
void	ExecuteImmediate (const std::string &)
bool	Fetch (IBPP::Row &)
bool	Fetch ()
bool	Get (const std::string &, IBPP::Array &)
bool	Get (const std::string &, IBPP::Blob &)
bool	Get (const std::string &, IBPP::DBKey &)
bool	Get (const std::string &, IBPP::Time &)
bool	Get (const std::string &, IBPP::Date &)
bool	Get (const std::string &, IBPP::Timestamp &)
bool	Get (const std::string &, double &)
bool	Get (const std::string &, double *)
bool	Get (const std::string &, float &)
bool	Get (const std::string &, float *)
bool	Get (const std::string &, int64_t &)
bool	Get (const std::string &, int64_t *)
bool	Get (const std::string &, int32_t &)
bool	Get (const std::string &, int32_t *)
bool	Get (const std::string &, int16_t &)
bool	Get (const std::string &, int16_t *)
bool	Get (const std::string &, std::string &)
bool	Get (const std::string &, void *, int &)
bool	Get (const std::string &, char *)
bool	Get (const std::string &, bool &)
bool	Get (const std::string &, bool *)
bool	Get (int, IBPP::Array &)
bool	Get (int, IBPP::Blob &)
bool	Get (int, IBPP::DBKey &)
bool	Get (int, IBPP::Time &)
bool	Get (int, IBPP::Date &)
bool	Get (int, IBPP::Timestamp &)
bool	Get (int, double &)
bool	Get (int, double *)
bool	Get (int, float &)
bool	Get (int, float *)
bool	Get (int, int64_t &)
bool	Get (int, int64_t *)
bool	Get (int, int32_t &)
bool	Get (int, int32_t *)
bool	Get (int, int16_t &)
bool	Get (int, int16_t *)
bool	Get (int, std::string &)
bool	Get (int, void *, int &)
bool	Get (int, char *)
bool	Get (int, bool &)
bool	Get (int, bool *)
isc_stmt_handle	GetHandle ()
bool	IsNull (const std::string &)
bool	IsNull (int)
int	Parameters ()
int	ParameterScale (int)
int	ParameterSize (int)
int	ParameterSubtype (int)
IBPP::SDT	ParameterType (int)
void	Plan (std::string &)
void	Prepare (const std::string &sql)
void	Release ()
void	Set (int, const IBPP::Array &)
void	Set (int, const IBPP::Blob &)
void	Set (int, const IBPP::DBKey &)
void	Set (int, const IBPP::Time &)
void	Set (int, const IBPP::Date &)
void	Set (int, const IBPP::Timestamp &)
void	Set (int, double)
void	Set (int, float)
void	Set (int, int64_t)
void	Set (int, int32_t)
void	Set (int, int16_t)
void	Set (int, const std::string &)
void	Set (int, const void *, int)
void	Set (int, const char *)
void	Set (int, bool)
void	SetNull (int)
std::string &	Sql ()
	StatementImpl (DatabaseImpl *, TransactionImpl *, const std::string &)
IBPP::Transaction	TransactionPtr () const
IBPP::STT	Type ()
	~StatementImpl ()
Private Member Functions
void	CursorFree ()
Private Attributes
bool	mCursorOpened
DatabaseImpl *	mDatabase
isc_stmt_handle	mHandle
RowImpl *	mInRow
RowImpl *	mOutRow
int	mRefCount
bool	mResultSetAvailable
std::string	mSql
TransactionImpl *	mTransaction
IBPP::STT	mType
Friends
class	TransactionImpl

---

Constructor & Destructor Documentation

StatementImpl::StatementImpl	(	DatabaseImpl *	database,
		TransactionImpl *	transaction,
		const std::string &	sql
	)

Definition at line 1282 of file statement.cpp.

References AttachDatabaseImpl(), AttachTransactionImpl(), and Prepare().

        : mRefCount(0), mHandle(0), mDatabase(0), mTransaction(0),
        mInRow(0), mOutRow(0),
        mResultSetAvailable(false), mCursorOpened(false), mType(IBPP::stUnknown)
{
        AttachDatabaseImpl(database);
        if (transaction != 0) AttachTransactionImpl(transaction);
        if (! sql.empty()) Prepare(sql);
}

StatementImpl::~StatementImpl

(

)

Definition at line 1293 of file statement.cpp.

References Close(), ibpp_internals::DatabaseImpl::DetachStatementImpl(), ibpp_internals::TransactionImpl::DetachStatementImpl(), mDatabase, and mTransaction.

{
        try { Close(); }
                catch (...) { }
        try { if (mTransaction != 0) mTransaction->DetachStatementImpl(this); }
                catch (...) { }
        try { if (mDatabase != 0) mDatabase->DetachStatementImpl(this); }
                catch (...) { }
}

---

Member Function Documentation

IBPP::IStatement * StatementImpl::AddRef

(

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1207 of file statement.cpp.

References ASSERTION, and mRefCount.

{
        ASSERTION(mRefCount >= 0);
        ++mRefCount;

        return this;
}

int StatementImpl::AffectedRows

(

)

[virtual]

Implements IBPP::IStatement.

Definition at line 384 of file statement.cpp.

References _, ibpp_internals::GDS::Call(), ibpp_internals::IBS::Errors(), ibpp_internals::gds, ibpp_internals::DatabaseImpl::GetHandle(), ibpp_internals::RB::GetValue(), isc_info_req_delete_count, isc_info_req_insert_count, isc_info_req_select_count, isc_info_req_update_count, isc_info_sql_records, ibpp_internals::GDS::m_dsql_sql_info, mDatabase, mHandle, mType, ibpp_internals::RB::Self(), ibpp_internals::IBS::Self(), ibpp_internals::RB::Size(), IBPP::stDelete, IBPP::stInsert, IBPP::stSelect, and IBPP::stUpdate.

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::AffectedRows", _("No statement has been prepared."));
        if (mDatabase == 0)
                throw LogicExceptionImpl("Statement::AffectedRows", _("A Database must be attached."));
        if (mDatabase->GetHandle() == 0)
                throw LogicExceptionImpl("Statement::AffectedRows", _("Database must be connected."));

        int count;
        IBS status;
        RB result;
        char itemsReq[] = {isc_info_sql_records};

        (*gds.Call()->m_dsql_sql_info)(status.Self(), &mHandle, 1, itemsReq,
                result.Size(), result.Self());
        if (status.Errors()) throw SQLExceptionImpl(status,
                        "Statement::AffectedRows", _("isc_dsql_sql_info failed."));

        if (mType == IBPP::stInsert)
                        count = result.GetValue(isc_info_sql_records, isc_info_req_insert_count);
        else if (mType == IBPP::stUpdate)
                        count = result.GetValue(isc_info_sql_records, isc_info_req_update_count);
        else if (mType == IBPP::stDelete)
                        count = result.GetValue(isc_info_sql_records, isc_info_req_delete_count);
        else if (mType == IBPP::stSelect)
                        count = result.GetValue(isc_info_sql_records, isc_info_req_select_count);
        else    count = 0;      // Returns zero count for unknown cases

        return count;
}

void StatementImpl::AttachDatabaseImpl

(

DatabaseImpl *

database

)

Definition at line 1226 of file statement.cpp.

References _, ibpp_internals::DatabaseImpl::AttachStatementImpl(), ibpp_internals::DatabaseImpl::DetachStatementImpl(), and mDatabase.

Referenced by StatementImpl().

{
        if (database == 0)
                throw LogicExceptionImpl("Statement::AttachDatabase",
                        _("Can't attach a 0 IDatabase object."));

        if (mDatabase != 0) mDatabase->DetachStatementImpl(this);
        mDatabase = database;
        mDatabase->AttachStatementImpl(this);
}

void StatementImpl::AttachTransactionImpl

(

TransactionImpl *

transaction

)

Definition at line 1246 of file statement.cpp.

References _, ibpp_internals::TransactionImpl::AttachStatementImpl(), ibpp_internals::TransactionImpl::DetachStatementImpl(), and mTransaction.

Referenced by StatementImpl().

{
        if (transaction == 0)
                throw LogicExceptionImpl("Statement::AttachTransaction",
                        _("Can't attach a 0 ITransaction object."));

        if (mTransaction != 0) mTransaction->DetachStatementImpl(this);
        mTransaction = transaction;
        mTransaction->AttachStatementImpl(this);
}

void StatementImpl::Close

(

)

[virtual]

Implements IBPP::IStatement.

Definition at line 476 of file statement.cpp.

References _, ibpp_internals::GDS::Call(), DSQL_drop, ibpp_internals::IBS::Errors(), ibpp_internals::gds, ibpp_internals::GDS::m_dsql_free_statement, mCursorOpened, mHandle, mInRow, mOutRow, mResultSetAvailable, mType, ibpp_internals::RowImpl::Release(), ibpp_internals::IBS::Self(), and IBPP::stUnknown.

Referenced by DetachDatabaseImpl(), DetachTransactionImpl(), ExecuteImmediate(), Fetch(), Prepare(), and ~StatementImpl().

{
        // Free all statement resources.
        // Used before preparing a new statement or from destructor.

        if (mInRow != 0) { mInRow->Release(); mInRow = 0; }
        if (mOutRow != 0) { mOutRow->Release(); mOutRow = 0; }

        mResultSetAvailable = false;
        mCursorOpened = false;
        mType = IBPP::stUnknown;

        if (mHandle != 0)
        {
                IBS status;
                (*gds.Call()->m_dsql_free_statement)(status.Self(), &mHandle, DSQL_drop);
                mHandle = 0;
                if (status.Errors())
                        throw SQLExceptionImpl(status, "Statement::Close(DSQL_drop)",
                                _("isc_dsql_free_statement failed."));
        }
}

const char * StatementImpl::ColumnAlias

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1091 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnAlias(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Columns", _("The row is not initialized."));

        return mOutRow->ColumnAlias(varnum);
}

const char * StatementImpl::ColumnName

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1083 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnName(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Columns", _("The row is not initialized."));

        return mOutRow->ColumnName(varnum);
}

int StatementImpl::ColumnNum

(

const std::string &

name

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1075 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnNum(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::ColumnNum", _("The row is not initialized."));

        return mOutRow->ColumnNum(name);
}

int ibpp_internals::StatementImpl::ColumnNumAlias

(

const std::string &

)

int StatementImpl::Columns

(

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1067 of file statement.cpp.

References _, ibpp_internals::RowImpl::Columns(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Columns", _("The row is not initialized."));

        return mOutRow->Columns();
}

int StatementImpl::ColumnScale

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1137 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnScale(), mHandle, and mOutRow.

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::ColumnScale", _("No statement has been prepared."));
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::ColumnScale", _("The row is not initialized."));

        return mOutRow->ColumnScale(varnum);
}

int StatementImpl::ColumnSize

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1127 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnSize(), mHandle, and mOutRow.

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::ColumnSize", _("No statement has been prepared."));
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::ColumnSize", _("The row is not initialized."));

        return mOutRow->ColumnSize(varnum);
}

int StatementImpl::ColumnSubtype

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1117 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnSubtype(), mHandle, and mOutRow.

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::ColumnSubtype", _("No statement has been prepared."));
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::ColumnSubtype", _("The statement does not return results."));

    return mOutRow->ColumnSubtype(varnum);
}

const char * StatementImpl::ColumnTable

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1099 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnTable(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Columns", _("The row is not initialized."));

        return mOutRow->ColumnTable(varnum);
}

IBPP::SDT StatementImpl::ColumnType

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1107 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnType(), mHandle, and mOutRow.

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::ColumnType", _("No statement has been prepared."));
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::ColumnType", _("The statement does not return results."));

    return mOutRow->ColumnType(varnum);
}

void ibpp_internals::StatementImpl::CursorExecute

(

const std::string &

cursor

)

[inline, virtual]

Implements IBPP::IStatement.

Definition at line 1100 of file _ibpp.h.

{ CursorExecute(cursor, std::string()); }

void StatementImpl::CursorExecute	(	const std::string &	cursor,
		const std::string &	sql
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 311 of file statement.cpp.

References _, ibpp_internals::GDS::Call(), CursorFree(), ibpp_internals::IBS::Errors(), ibpp_internals::gds, ibpp_internals::TransactionImpl::GetHandlePtr(), ibpp_internals::GDS::m_dsql_execute, ibpp_internals::GDS::m_dsql_set_cursor_name, mCursorOpened, mHandle, mInRow, ibpp_internals::RowImpl::MissingValues(), mOutRow, mResultSetAvailable, mSql, mTransaction, mType, Prepare(), ibpp_internals::IBS::Reset(), ibpp_internals::RowImpl::Self(), ibpp_internals::IBS::Self(), and IBPP::stSelectUpdate.

{
        if (cursor.empty())
                throw LogicExceptionImpl("Statement::CursorExecute", _("Cursor name can't be 0."));

        if (! sql.empty()) Prepare(sql);

        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::CursorExecute", _("No statement has been prepared."));
        if (mType != IBPP::stSelectUpdate)
                throw LogicExceptionImpl("Statement::CursorExecute", _("Statement must be a SELECT FOR UPDATE."));
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::CursorExecute", _("Statement would return no rows."));

        // Check that a value has been set for each input parameter
        if (mInRow != 0 && mInRow->MissingValues())
                throw LogicExceptionImpl("Statement::CursorExecute",
                        _("All parameters must be specified."));

        CursorFree();   // Free a previous 'cursor' if any

        IBS status;
        (*gds.Call()->m_dsql_execute)(status.Self(), mTransaction->GetHandlePtr(),
                &mHandle, 1, mInRow == 0 ? 0 : mInRow->Self());
        if (status.Errors())
        {
                //Close();      Commented because Execute error should not free the statement
                std::string context = "Statement::CursorExecute( ";
                context.append(mSql).append(" )");
                throw SQLExceptionImpl(status, context.c_str(),
                        _("isc_dsql_execute failed"));
        }

        status.Reset();
        (*gds.Call()->m_dsql_set_cursor_name)(status.Self(), &mHandle, const_cast<char*>(cursor.c_str()), 0);
        if (status.Errors())
        {
                //Close();      Commented because Execute error should not free the statement
                throw SQLExceptionImpl(status, "Statement::CursorExecute",
                        _("isc_dsql_set_cursor_name failed"));
        }

        mResultSetAvailable = true;
        mCursorOpened = true;
}

void StatementImpl::CursorFree

(

)

[private]

Definition at line 1266 of file statement.cpp.

References _, ibpp_internals::GDS::Call(), DSQL_close, ibpp_internals::IBS::Errors(), ibpp_internals::gds, ibpp_internals::GDS::m_dsql_free_statement, mCursorOpened, mHandle, and ibpp_internals::IBS::Self().

Referenced by CursorExecute(), Execute(), and Fetch().

{
        if (mCursorOpened)
        {
                mCursorOpened = false;
                if (mHandle != 0)
                {
                        IBS status;
                        (*gds.Call()->m_dsql_free_statement)(status.Self(), &mHandle, DSQL_close);
                        if (status.Errors())
                                throw SQLExceptionImpl(status, "StatementImpl::CursorFree(DSQL_close)",
                                        _("isc_dsql_free_statement failed."));
                }
        }
}

IBPP::Database StatementImpl::DatabasePtr

(

)

const [virtual]

Implements IBPP::IStatement.

Definition at line 1197 of file statement.cpp.

References mDatabase.

{
        return mDatabase;
}

void StatementImpl::DetachDatabaseImpl

(

)

Definition at line 1237 of file statement.cpp.

References Close(), ibpp_internals::DatabaseImpl::DetachStatementImpl(), and mDatabase.

{
        if (mDatabase == 0) return;

        Close();
        mDatabase->DetachStatementImpl(this);
        mDatabase = 0;
}

void StatementImpl::DetachTransactionImpl

(

)

Definition at line 1257 of file statement.cpp.

References Close(), ibpp_internals::TransactionImpl::DetachStatementImpl(), and mTransaction.

{
        if (mTransaction == 0) return;

        Close();
        mTransaction->DetachStatementImpl(this);
        mTransaction = 0;
}

void ibpp_internals::StatementImpl::Execute

(

)

[inline, virtual]

Implements IBPP::IStatement.

Definition at line 1097 of file _ibpp.h.

{ Execute(std::string()); }

void StatementImpl::Execute

(

const std::string &

sql

)

[virtual]

Implements IBPP::IStatement.

Definition at line 259 of file statement.cpp.

References _, ibpp_internals::GDS::Call(), CursorFree(), ibpp_internals::IBS::Errors(), ibpp_internals::gds, ibpp_internals::TransactionImpl::GetHandlePtr(), ibpp_internals::GDS::m_dsql_execute, ibpp_internals::GDS::m_dsql_execute2, mCursorOpened, mHandle, mInRow, ibpp_internals::RowImpl::MissingValues(), mOutRow, mResultSetAvailable, mSql, mTransaction, mType, Prepare(), ibpp_internals::RowImpl::Self(), ibpp_internals::IBS::Self(), and IBPP::stSelect.

{
        if (! sql.empty()) Prepare(sql);

        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Execute",
                        _("No statement has been prepared."));

        // Check that a value has been set for each input parameter
        if (mInRow != 0 && mInRow->MissingValues())
                throw LogicExceptionImpl("Statement::Execute",
                        _("All parameters must be specified."));

        CursorFree();   // Free a previous 'cursor' if any

        IBS status;
        if (mType == IBPP::stSelect)
        {
                // Could return a result set (none, single or multi rows)
                (*gds.Call()->m_dsql_execute)(status.Self(), mTransaction->GetHandlePtr(),
                        &mHandle, 1, mInRow == 0 ? 0 : mInRow->Self());
                if (status.Errors())
                {
                        //Close();      Commented because Execute error should not free the statement
                        std::string context = "Statement::Execute( ";
                        context.append(mSql).append(" )");
                        throw SQLExceptionImpl(status, context.c_str(),
                                _("isc_dsql_execute failed"));
                }
                if (mOutRow != 0)
                {
                        mResultSetAvailable = true;
                        mCursorOpened = true;
                }
        }
        else
        {
                // Should return at most a single row
                (*gds.Call()->m_dsql_execute2)(status.Self(), mTransaction->GetHandlePtr(),
                        &mHandle, 1, mInRow == 0 ? 0 : mInRow->Self(),
                        mOutRow == 0 ? 0 : mOutRow->Self());
                if (status.Errors())
                {
                        //Close();      Commented because Execute error should not free the statement
                        std::string context = "Statement::Execute( ";
                        context.append(mSql).append(" )");
                        throw SQLExceptionImpl(status, context.c_str(),
                                _("isc_dsql_execute2 failed"));
                }
        }
}

void StatementImpl::ExecuteImmediate

(

const std::string &

sql

)

[virtual]

Implements IBPP::IStatement.

Definition at line 357 of file statement.cpp.

References _, ibpp_internals::GDS::Call(), Close(), ibpp_internals::DatabaseImpl::Dialect(), ibpp_internals::IBS::Errors(), ibpp_internals::gds, ibpp_internals::TransactionImpl::GetHandle(), ibpp_internals::DatabaseImpl::GetHandle(), ibpp_internals::TransactionImpl::GetHandlePtr(), ibpp_internals::DatabaseImpl::GetHandlePtr(), ibpp_internals::GDS::m_dsql_execute_immediate, mDatabase, mTransaction, and ibpp_internals::IBS::Self().

{
        if (mDatabase == 0)
                throw LogicExceptionImpl("Statement::ExecuteImmediate", _("An IDatabase must be attached."));
        if (mDatabase->GetHandle() == 0)
                throw LogicExceptionImpl("Statement::ExecuteImmediate", _("IDatabase must be connected."));
        if (mTransaction == 0)
                throw LogicExceptionImpl("Statement::ExecuteImmediate", _("An ITransaction must be attached."));
        if (mTransaction->GetHandle() == 0)
                throw LogicExceptionImpl("Statement::ExecuteImmediate", _("ITransaction must be started."));
        if (sql.empty())
                throw LogicExceptionImpl("Statement::ExecuteImmediate", _("SQL statement can't be 0."));

        IBS status;
        Close();
    (*gds.Call()->m_dsql_execute_immediate)(status.Self(), mDatabase->GetHandlePtr(),
        mTransaction->GetHandlePtr(), 0, const_cast<char*>(sql.c_str()),
                short(mDatabase->Dialect()), 0);
    if (status.Errors())
        {
                std::string context = "Statement::ExecuteImmediate( ";
                context.append(sql).append(" )");
                throw SQLExceptionImpl(status, context.c_str(),
                        _("isc_dsql_execute_immediate failed"));
        }
}

bool StatementImpl::Fetch

(

IBPP::Row &

row

)

[virtual]

Implements IBPP::IStatement.

Definition at line 443 of file statement.cpp.

References _, ibpp_internals::GDS::Call(), IBPP::Ptr< T >::clear(), Close(), CursorFree(), ibpp_internals::IBS::Errors(), ibpp_internals::gds, ibpp_internals::GDS::m_dsql_fetch, mCursorOpened, mHandle, mOutRow, mResultSetAvailable, ibpp_internals::RowImpl::Self(), and ibpp_internals::IBS::Self().

{
        if (! mResultSetAvailable)
                throw LogicExceptionImpl("Statement::Fetch(row)",
                        _("No statement has been executed or no result set available."));

        RowImpl* rowimpl = new RowImpl(*mOutRow);
        row = rowimpl;

        IBS status;
        int code = (*gds.Call()->m_dsql_fetch)(status.Self(), &mHandle, 1,
                                        rowimpl->Self());
        if (code == 100)        // This special code means "no more rows"
        {
                mResultSetAvailable = false;
                // Oddly enough, fetching rows up to the last one seems to open
                // an 'implicit' cursor that needs to be closed.
                mCursorOpened = true;
                CursorFree();   // Free the explicit or implicit cursor/result-set
                row.clear();
                return false;
        }
        if (status.Errors())
        {
                Close();
                row.clear();
                throw SQLExceptionImpl(status, "Statement::Fetch(row)",
                        _("isc_dsql_fetch failed."));
        }

        return true;
}

bool StatementImpl::Fetch

(

)

[virtual]

Implements IBPP::IStatement.

Definition at line 416 of file statement.cpp.

References _, ibpp_internals::GDS::Call(), Close(), CursorFree(), ibpp_internals::IBS::Errors(), ibpp_internals::gds, ibpp_internals::GDS::m_dsql_fetch, mCursorOpened, mHandle, mOutRow, mResultSetAvailable, ibpp_internals::RowImpl::Self(), and ibpp_internals::IBS::Self().

{
        if (! mResultSetAvailable)
                throw LogicExceptionImpl("Statement::Fetch",
                        _("No statement has been executed or no result set available."));

        IBS status;
        int code = (*gds.Call()->m_dsql_fetch)(status.Self(), &mHandle, 1, mOutRow->Self());
        if (code == 100)        // This special code means "no more rows"
        {
                mResultSetAvailable = false;
                // Oddly enough, fetching rows up to the last one seems to open
                // an 'implicit' cursor that needs to be closed.
                mCursorOpened = true;
                CursorFree();   // Free the explicit or implicit cursor/result-set
                return false;
        }
        if (status.Errors())
        {
                Close();
                throw SQLExceptionImpl(status, "Statement::Fetch",
                        _("isc_dsql_fetch failed."));
        }

        return true;
}

bool ibpp_internals::StatementImpl::Get	(	const std::string &	,
		IBPP::Array &
	)			[virtual]

Implements IBPP::IStatement.

bool StatementImpl::Get	(	const std::string &	name,
		IBPP::Blob &	retblob
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 1033 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retblob);
}

bool StatementImpl::Get	(	const std::string &	name,
		IBPP::DBKey &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 1041 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		IBPP::Time &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 1025 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		IBPP::Date &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 1017 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		IBPP::Timestamp &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 1009 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		double &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 1001 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		double *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 991 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(name, *retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		float &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 983 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		float *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 973 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(name, *retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		int64_t &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 965 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		int64_t *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 955 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(name, *retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		int32_t &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 947 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		int32_t *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 937 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(name, *retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		int16_t &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 929 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		int16_t *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 919 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(name, *retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		std::string &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 911 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::GetString", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		void *	retvalue,
		int &	count
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 903 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get[void*,int]", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue, count);
}

bool StatementImpl::Get	(	const std::string &	name,
		char *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 895 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get[char*]", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		bool &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 887 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(name, retvalue);
}

bool StatementImpl::Get	(	const std::string &	name,
		bool *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 877 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(name, *retvalue);
}

bool ibpp_internals::StatementImpl::Get	(	int	,
		IBPP::Array &
	)			[virtual]

Implements IBPP::IStatement.

bool StatementImpl::Get	(	int	column,
		IBPP::Blob &	blob
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 835 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, blob);
}

bool StatementImpl::Get	(	int	column,
		IBPP::DBKey &	key
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 843 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, key);
}

bool StatementImpl::Get	(	int	column,
		IBPP::Time &	time
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 827 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, time);
}

bool StatementImpl::Get	(	int	column,
		IBPP::Date &	date
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 819 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, date);
}

bool StatementImpl::Get	(	int	column,
		IBPP::Timestamp &	timestamp
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 811 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, timestamp);
}

bool StatementImpl::Get	(	int	column,
		double &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 803 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, retvalue);
}

bool StatementImpl::Get	(	int	column,
		double *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 793 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(column, *retvalue);
}

bool StatementImpl::Get	(	int	column,
		float &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 785 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, retvalue);
}

bool StatementImpl::Get	(	int	column,
		float *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 775 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(column, *retvalue);
}

bool StatementImpl::Get	(	int	column,
		int64_t &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 767 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, retvalue);
}

bool StatementImpl::Get	(	int	column,
		int64_t *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 757 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(column, *retvalue);
}

bool StatementImpl::Get	(	int	column,
		int32_t &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 749 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, retvalue);
}

bool StatementImpl::Get	(	int	column,
		int32_t *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 739 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(column, *retvalue);
}

bool StatementImpl::Get	(	int	column,
		int16_t &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 731 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, retvalue);
}

bool StatementImpl::Get	(	int	column,
		int16_t *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 721 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(column, *retvalue);
}

bool StatementImpl::Get	(	int	column,
		std::string &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 713 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, retvalue);
}

bool StatementImpl::Get	(	int	column,
		void *	bindata,
		int &	userlen
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 705 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, bindata, userlen);
}

bool StatementImpl::Get	(	int	column,
		char *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 697 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, retvalue);
}

bool StatementImpl::Get	(	int	column,
		bool &	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 689 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));

        return mOutRow->Get(column, retvalue);
}

bool StatementImpl::Get	(	int	column,
		bool *	retvalue
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 679 of file statement.cpp.

References _, ibpp_internals::RowImpl::Get(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::Get", _("The row is not initialized."));
        if (retvalue == 0)
                throw LogicExceptionImpl("Statement::Get", _("Null pointer detected"));

        return mOutRow->Get(column, *retvalue);
}

isc_stmt_handle ibpp_internals::StatementImpl::GetHandle

(

)

[inline]

Definition at line 1082 of file _ibpp.h.

{ return mHandle; }

bool StatementImpl::IsNull

(

const std::string &

name

)

[virtual]

Implements IBPP::IStatement.

Definition at line 869 of file statement.cpp.

References _, ibpp_internals::RowImpl::IsNull(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::IsNull", _("The row is not initialized."));

        return mOutRow->IsNull(name);
}

bool StatementImpl::IsNull

(

int

column

)

[virtual]

Implements IBPP::IStatement.

Definition at line 671 of file statement.cpp.

References _, ibpp_internals::RowImpl::IsNull(), and mOutRow.

{
        if (mOutRow == 0)
                throw LogicExceptionImpl("Statement::IsNull", _("The row is not initialized."));

        return mOutRow->IsNull(column);
}

int StatementImpl::Parameters

(

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1147 of file statement.cpp.

References _, ibpp_internals::RowImpl::Columns(), mHandle, and mInRow.

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Parameters", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Parameters", _("The statement uses no parameters."));

        return mInRow->Columns();
}

int StatementImpl::ParameterScale

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1187 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnScale(), mHandle, and mInRow.

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::ParameterScale", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::ParameterScale", _("The statement uses no parameters."));

        return mInRow->ColumnScale(varnum);
}

int StatementImpl::ParameterSize

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1177 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnSize(), mHandle, and mInRow.

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::ParameterSize", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::ParameterSize", _("The statement uses no parameters."));

        return mInRow->ColumnSize(varnum);
}

int StatementImpl::ParameterSubtype

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1167 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnSubtype(), mHandle, and mInRow.

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::ParameterSubtype", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::ParameterSubtype", _("The statement uses no parameters."));

    return mInRow->ColumnSubtype(varnum);
}

IBPP::SDT StatementImpl::ParameterType

(

int

varnum

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1157 of file statement.cpp.

References _, ibpp_internals::RowImpl::ColumnType(), mHandle, and mInRow.

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::ParameterType", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::ParameterType", _("The statement uses no parameters."));

    return mInRow->ColumnType(varnum);
}

void StatementImpl::Plan

(

std::string &

plan

)

[virtual]

Implements IBPP::IStatement.

Definition at line 237 of file statement.cpp.

References _, ibpp_internals::GDS::Call(), ibpp_internals::IBS::Errors(), ibpp_internals::gds, ibpp_internals::DatabaseImpl::GetHandle(), ibpp_internals::RB::GetString(), isc_info_sql_get_plan, ibpp_internals::GDS::m_dsql_sql_info, mDatabase, mHandle, ibpp_internals::RB::Self(), ibpp_internals::IBS::Self(), and ibpp_internals::RB::Size().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Plan", _("No statement has been prepared."));
        if (mDatabase == 0)
                throw LogicExceptionImpl("Statement::Plan", _("A Database must be attached."));
        if (mDatabase->GetHandle() == 0)
                throw LogicExceptionImpl("Statement::Plan", _("Database must be connected."));

        IBS status;
        RB result(4096);
        char itemsReq[] = {isc_info_sql_get_plan};

        (*gds.Call()->m_dsql_sql_info)(status.Self(), &mHandle, 1, itemsReq,
                                                                   result.Size(), result.Self());
        if (status.Errors()) throw SQLExceptionImpl(status,
                                                                "Statement::Plan", _("isc_dsql_sql_info failed."));

        result.GetString(isc_info_sql_get_plan, plan);
        if (plan[0] == '\n') plan.erase(0, 1);
}

void StatementImpl::Prepare

(

const std::string &

sql

)

[virtual]

Implements IBPP::IStatement.

Definition at line 44 of file statement.cpp.

References _, ibpp_internals::RowImpl::AddRef(), ibpp_internals::RowImpl::AllocatedSize(), ibpp_internals::RowImpl::AllocVariables(), ibpp_internals::GDS::Call(), Close(), ibpp_internals::RowImpl::Columns(), ibpp_internals::DatabaseImpl::Dialect(), ibpp_internals::IBS::Errors(), ibpp_internals::gds, ibpp_internals::TransactionImpl::GetHandle(), ibpp_internals::DatabaseImpl::GetHandle(), ibpp_internals::TransactionImpl::GetHandlePtr(), ibpp_internals::DatabaseImpl::GetHandlePtr(), isc_info_sql_stmt_ddl, isc_info_sql_stmt_delete, isc_info_sql_stmt_exec_procedure, isc_info_sql_stmt_insert, isc_info_sql_stmt_savepoint, isc_info_sql_stmt_select, isc_info_sql_stmt_select_for_upd, isc_info_sql_stmt_set_generator, isc_info_sql_stmt_type, isc_info_sql_stmt_update, ibpp_internals::GDS::m_dsql_allocate_statement, ibpp_internals::GDS::m_dsql_describe, ibpp_internals::GDS::m_dsql_describe_bind, ibpp_internals::GDS::m_dsql_prepare, ibpp_internals::GDS::m_dsql_sql_info, mDatabase, mHandle, mInRow, mOutRow, mSql, mTransaction, mType, ibpp_internals::RowImpl::Release(), ibpp_internals::IBS::Reset(), ibpp_internals::RowImpl::Resize(), ibpp_internals::RowImpl::Self(), ibpp_internals::IBS::Self(), XSQLVAR::sqltype, XSQLDA::sqlvar, IBPP::stDDL, IBPP::stDelete, IBPP::stExecProcedure, IBPP::stInsert, IBPP::stSavePoint, IBPP::stSelect, IBPP::stSelectUpdate, IBPP::stSetGenerator, IBPP::stUnknown, IBPP::stUnsupported, and IBPP::stUpdate.

Referenced by CursorExecute(), Execute(), and StatementImpl().

{
        if (mDatabase == 0)
                throw LogicExceptionImpl("Statement::Prepare", _("An IDatabase must be attached."));
        if (mDatabase->GetHandle() == 0)
                throw LogicExceptionImpl("Statement::Prepare", _("IDatabase must be connected."));
        if (mTransaction == 0)
                throw LogicExceptionImpl("Statement::Prepare", _("An ITransaction must be attached."));
        if (mTransaction->GetHandle() == 0)
                throw LogicExceptionImpl("Statement::Prepare", _("ITransaction must be started."));
        if (sql.empty())
                throw LogicExceptionImpl("Statement::Prepare", _("SQL statement can't be 0."));

        // Saves the SQL sentence, only for reporting reasons in case of errors
        mSql = sql;

        IBS status;

        // Free all resources currently attached to this Statement, then allocate
        // a new statement descriptor.
        Close();
        (*gds.Call()->m_dsql_allocate_statement)(status.Self(), mDatabase->GetHandlePtr(), &mHandle);
        if (status.Errors())
                throw SQLExceptionImpl(status, "Statement::Prepare",
                        _("isc_dsql_allocate_statement failed"));

        // Empirical estimate of parameters count and output columns count.
        // This is by far not an exact estimation, which would require parsing the
        // SQL statement. If the SQL statement contains '?' and ',' in string
        // constants, this count will obviously be wrong, but it will be exagerated.
        // It won't hurt. We just try to not have to re-allocate those descriptors later.
        // So we prefer to get them a little bit larger than needed than the other way.
        int16_t inEstimate = 0;
        int16_t outEstimate = 1;
        for (size_t i = 0; i < strlen(sql.c_str()); i++)
        {
                if (sql[i] == '?') ++inEstimate;
                if (sql[i] == ',') ++outEstimate;
        }

        /*
        DebugStream()<< "Prepare(\""<< sql<< "\")"<< fds;
        DebugStream()<< _("Estimation: ")<< inEstimate<< _(" IN parameters and ")
                        << outEstimate<< _(" OUT columns")<< fds;
        */

        // Allocates output descriptor and prepares the statement
        mOutRow = new RowImpl(mDatabase->Dialect(), outEstimate, mDatabase, mTransaction);
        mOutRow->AddRef();

        status.Reset();
        (*gds.Call()->m_dsql_prepare)(status.Self(), mTransaction->GetHandlePtr(),
                &mHandle, (short)sql.length(), const_cast<char*>(sql.c_str()),
                        short(mDatabase->Dialect()), mOutRow->Self());
        if (status.Errors())
        {
                Close();
                std::string context = "Statement::Prepare( ";
                context.append(mSql).append(" )");
                throw SQLExceptionImpl(status, context.c_str(),
                        _("isc_dsql_prepare failed"));
        }

        // Read what kind of statement was prepared
        status.Reset();
        char itemsReq[] = {isc_info_sql_stmt_type};
        char itemsRes[8];
        (*gds.Call()->m_dsql_sql_info)(status.Self(), &mHandle, 1, itemsReq,
                sizeof(itemsRes), itemsRes);
        if (status.Errors())
        {
                Close();
                throw SQLExceptionImpl(status, "Statement::Prepare",
                        _("isc_dsql_sql_info failed"));
        }
        if (itemsRes[0] == isc_info_sql_stmt_type)
        {
                switch (itemsRes[3])
                {
                        case isc_info_sql_stmt_select :         mType = IBPP::stSelect; break;
                        case isc_info_sql_stmt_insert :         mType = IBPP::stInsert; break;
                        case isc_info_sql_stmt_update :         mType = IBPP::stUpdate; break;
                        case isc_info_sql_stmt_delete :         mType = IBPP::stDelete; break;
                        case isc_info_sql_stmt_ddl :            mType = IBPP::stDDL; break;
                        case isc_info_sql_stmt_exec_procedure : mType = IBPP::stExecProcedure; break;
                        case isc_info_sql_stmt_select_for_upd : mType = IBPP::stSelectUpdate; break;
                        case isc_info_sql_stmt_set_generator :  mType = IBPP::stSetGenerator; break;
                        case isc_info_sql_stmt_savepoint :      mType = IBPP::stSavePoint; break;
                        default : mType = IBPP::stUnsupported;
                }
        }
        if (mType == IBPP::stUnknown || mType == IBPP::stUnsupported)
        {
                Close();
                throw LogicExceptionImpl("Statement::Prepare",
                        _("Unknown or unsupported statement type"));
        }

        if (mOutRow->Columns() == 0)
        {
                // Get rid of the output descriptor, if it wasn't required (no output)
                mOutRow->Release();
                mOutRow = 0;
                /*
                DebugStream()<< _("Dropped output descriptor which was not required")<< fds;
                */
        }
        else if (mOutRow->Columns() > mOutRow->AllocatedSize())
        {
                // Resize the output descriptor (which is too small).
                // The statement does not need to be prepared again, though the
                // output columns must be described again.

                /*
                DebugStream()<< _("Resize output descriptor from ")
                        << mOutRow->AllocatedSize()<< _(" to ")<< mOutRow->Columns()<< fds;
                */

                mOutRow->Resize(mOutRow->Columns());
                status.Reset();
                (*gds.Call()->m_dsql_describe)(status.Self(), &mHandle, 1, mOutRow->Self());
                if (status.Errors())
                {
                        Close();
                        throw SQLExceptionImpl(status, "Statement::Prepare",
                                _("isc_dsql_describe failed"));
                }
        }

        if (inEstimate > 0)
        {
                // Ready an input descriptor
                mInRow = new RowImpl(mDatabase->Dialect(), inEstimate, mDatabase, mTransaction);
                mInRow->AddRef();

                status.Reset();
                (*gds.Call()->m_dsql_describe_bind)(status.Self(), &mHandle, 1, mInRow->Self());
                if (status.Errors())
                {
                        Close();
                        throw SQLExceptionImpl(status, "Statement::Prepare",
                                _("isc_dsql_describe_bind failed"));
                }

                if (mInRow->Columns() == 0)
                {
                        // Get rid of the input descriptor, if it wasn't required (no parameters)
                        mInRow->Release();
                        mInRow = 0;
                        /*
                        DebugStream()<< _("Dropped input descriptor which was not required")<< fds;
                        */
                }
                else if (mInRow->Columns() > mInRow->AllocatedSize())
                {
                        // Resize the input descriptor (which is too small).
                        // The statement does not need to be prepared again, though the
                        // parameters must be described again.

                        /*
                        DebugStream()<< _("Resize input descriptor from ")
                                        << mInRow->AllocatedSize()<< _(" to ")
                                        << mInRow->Columns()<< fds;
                        */

                        mInRow->Resize(mInRow->Columns());
                        status.Reset();
                        (*gds.Call()->m_dsql_describe_bind)(status.Self(), &mHandle, 1, mInRow->Self());
                        if (status.Errors())
                        {
                                Close();
                                throw SQLExceptionImpl(status, "Statement::Prepare",
                                        _("isc_dsql_describe_bind failed"));
                        }
                }
        }

        // Allocates variables of the input descriptor
        if (mInRow != 0)
        {
                // Turn on 'can be NULL' on each input parameter
                for (int i = 0; i < mInRow->Columns(); i++)
                {
                        XSQLVAR* var = &(mInRow->Self()->sqlvar[i]);
                        if (! (var->sqltype & 1)) var->sqltype += short(1);
                }
                mInRow->AllocVariables();
        }

        // Allocates variables of the output descriptor
        if (mOutRow != 0) mOutRow->AllocVariables();
}

void StatementImpl::Release

(

)

[virtual]

Implements IBPP::IStatement.

Definition at line 1215 of file statement.cpp.

References ASSERTION, and mRefCount.

{
        // Release cannot throw, except in DEBUG builds on assertion
        ASSERTION(mRefCount >= 0);
        --mRefCount;
        try { if (mRefCount <= 0) delete this; }
                catch (...) { }
}

void ibpp_internals::StatementImpl::Set	(	int	,
		const IBPP::Array &
	)			[virtual]

Implements IBPP::IStatement.

void StatementImpl::Set	(	int	param,
		const IBPP::Blob &	blob
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 629 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[Blob]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[Blob]", _("The statement does not take parameters."));

        mInRow->Set(param, blob);
}

void StatementImpl::Set	(	int	param,
		const IBPP::DBKey &	key
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 649 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[DBKey]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[DBKey]", _("The statement does not take parameters."));

        mInRow->Set(param, key);
}

void StatementImpl::Set	(	int	param,
		const IBPP::Time &	value
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 619 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[Time]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[Time]", _("The statement does not take parameters."));

        mInRow->Set(param, value);
}

void StatementImpl::Set	(	int	param,
		const IBPP::Date &	value
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 609 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[Date]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[Date]", _("The statement does not take parameters."));

        mInRow->Set(param, value);
}

void StatementImpl::Set	(	int	param,
		const IBPP::Timestamp &	value
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 599 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[Timestamp]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[Timestamp]", _("The statement does not take parameters."));

        mInRow->Set(param, value);
}

void StatementImpl::Set	(	int	param,
		double	value
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 589 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[double]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[double]", _("The statement does not take parameters."));

        mInRow->Set(param, value);
}

void StatementImpl::Set	(	int	param,
		float	value
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 579 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[float]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[float]", _("The statement does not take parameters."));

        mInRow->Set(param, value);
}

void StatementImpl::Set	(	int	param,
		int64_t	value
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 569 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[int64_t]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[int64_t]", _("The statement does not take parameters."));

        mInRow->Set(param, value);
}

void StatementImpl::Set	(	int	param,
		int32_t	value
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 559 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[int32_t]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[int32_t]", _("The statement does not take parameters."));

        mInRow->Set(param, value);
}

void StatementImpl::Set	(	int	param,
		int16_t	value
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 549 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[int16_t]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[int16_t]", _("The statement does not take parameters."));

        mInRow->Set(param, value);
}

void StatementImpl::Set	(	int	param,
		const std::string &	s
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 539 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[string]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[string]", _("The statement does not take parameters."));

        mInRow->Set(param, s);
}

void StatementImpl::Set	(	int	param,
		const void *	bindata,
		int	len
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 529 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[void*]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[void*]", _("The statement does not take parameters."));

        mInRow->Set(param, bindata, len);
}

void StatementImpl::Set	(	int	param,
		const char *	cstring
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 519 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[char*]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[char*]", _("The statement does not take parameters."));

        mInRow->Set(param, cstring);
}

void StatementImpl::Set	(	int	param,
		bool	value
	)			[virtual]

Implements IBPP::IStatement.

Definition at line 509 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::Set().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::Set[bool]", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::Set[bool]", _("The statement does not take parameters."));

        mInRow->Set(param, value);
}

void StatementImpl::SetNull

(

int

param

)

[virtual]

Implements IBPP::IStatement.

Definition at line 499 of file statement.cpp.

References _, mHandle, mInRow, and ibpp_internals::RowImpl::SetNull().

{
        if (mHandle == 0)
                throw LogicExceptionImpl("Statement::SetNull", _("No statement has been prepared."));
        if (mInRow == 0)
                throw LogicExceptionImpl("Statement::SetNull", _("The statement does not take parameters."));

        mInRow->SetNull(param);
}

std::string& ibpp_internals::StatementImpl::Sql

(

)

[inline, virtual]

Implements IBPP::IStatement.

Definition at line 1105 of file _ibpp.h.

{ return mSql; }

IBPP::Transaction StatementImpl::TransactionPtr

(

)

const [virtual]

Implements IBPP::IStatement.

Definition at line 1202 of file statement.cpp.

References mTransaction.

{
        return mTransaction;
}

IBPP::STT ibpp_internals::StatementImpl::Type

(

)

[inline, virtual]

Implements IBPP::IStatement.

Definition at line 1106 of file _ibpp.h.

{ return mType; }

---

Friends And Related Function Documentation

friend class TransactionImpl [friend]

Definition at line 1062 of file _ibpp.h.

---

Field Documentation

bool ibpp_internals::StatementImpl::mCursorOpened [private]

Definition at line 1073 of file _ibpp.h.

Referenced by Close(), CursorExecute(), CursorFree(), Execute(), and Fetch().

DatabaseImpl* ibpp_internals::StatementImpl::mDatabase [private]

Definition at line 1067 of file _ibpp.h.

Referenced by AffectedRows(), AttachDatabaseImpl(), DatabasePtr(), DetachDatabaseImpl(), ExecuteImmediate(), Plan(), Prepare(), and ~StatementImpl().

isc_stmt_handle ibpp_internals::StatementImpl::mHandle [private]

Definition at line 1065 of file _ibpp.h.

Referenced by AffectedRows(), Close(), ColumnScale(), ColumnSize(), ColumnSubtype(), ColumnType(), CursorExecute(), CursorFree(), Execute(), Fetch(), Parameters(), ParameterScale(), ParameterSize(), ParameterSubtype(), ParameterType(), Plan(), Prepare(), Set(), and SetNull().

RowImpl* ibpp_internals::StatementImpl::mInRow [private]

Definition at line 1069 of file _ibpp.h.

Referenced by Close(), CursorExecute(), Execute(), Parameters(), ParameterScale(), ParameterSize(), ParameterSubtype(), ParameterType(), Prepare(), Set(), and SetNull().

RowImpl* ibpp_internals::StatementImpl::mOutRow [private]

Definition at line 1071 of file _ibpp.h.

Referenced by Close(), ColumnAlias(), ColumnName(), ColumnNum(), Columns(), ColumnScale(), ColumnSize(), ColumnSubtype(), ColumnTable(), ColumnType(), CursorExecute(), Execute(), Fetch(), Get(), IsNull(), and Prepare().

int ibpp_internals::StatementImpl::mRefCount [private]

Definition at line 1064 of file _ibpp.h.

Referenced by AddRef(), and Release().

bool ibpp_internals::StatementImpl::mResultSetAvailable [private]

Definition at line 1072 of file _ibpp.h.

Referenced by Close(), CursorExecute(), Execute(), and Fetch().

std::string ibpp_internals::StatementImpl::mSql [private]

Definition at line 1075 of file _ibpp.h.

Referenced by CursorExecute(), Execute(), and Prepare().

TransactionImpl* ibpp_internals::StatementImpl::mTransaction [private]

Definition at line 1068 of file _ibpp.h.

Referenced by AttachTransactionImpl(), CursorExecute(), DetachTransactionImpl(), Execute(), ExecuteImmediate(), Prepare(), TransactionPtr(), and ~StatementImpl().

IBPP::STT ibpp_internals::StatementImpl::mType [private]

Definition at line 1074 of file _ibpp.h.

Referenced by AffectedRows(), Close(), CursorExecute(), Execute(), and Prepare().

---

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

• _ibpp.h
• statement.cpp

---