Class IscStatement

src/yvalve/why.cpp:1223–1286

	};

	class IscStatement : public RefCounted, public GlobalStorage, public YObject
	{
	public:
		static const ISC_STATUS ERROR_CODE = isc_bad_stmt_handle;

		explicit IscStatement(YAttachment* aAttachment)
			: attachment(aAttachment),
			  cursorName(getPool()),
			  statement(NULL),
			  userHandle(NULL),
			  pseudoOpened(false),
			  delayedFormat(false)
		{ }

		~IscStatement() override;

		isc_stmt_handle& getHandle();
		void destroy(unsigned);

		void openCursor(CheckStatusWrapper* status, isc_tr_handle* traHandle,
			IMessageMetadata* inMetadata, UCHAR* buffer, IMessageMetadata* outMetadata);

		void closeCursor(CheckStatusWrapper* status, bool raise);
		void closeStatement(CheckStatusWrapper* status);

		void execute(CheckStatusWrapper* status, isc_tr_handle* traHandle,
			IMessageMetadata* inMetadata, UCHAR* inBuffer, IMessageMetadata* outMetadata, UCHAR* outBuffer);

		FB_BOOLEAN fetch(CheckStatusWrapper* status, IMessageMetadata* outMetadata, UCHAR* outBuffer);

		void checkPrepared(ISC_STATUS code = isc_unprepared_stmt) const
		{
			if (!statement)
				Arg::Gds(code).raise();
		}

		void checkCursorOpened() const
		{
			if (!statement || !statement->cursor)
				(Arg::Gds(isc_sqlerr) << Arg::Num(-504) <<
					Arg::Gds(isc_dsql_cursor_err) <<
					Arg::Gds(isc_dsql_cursor_not_open)).raise();
		}

		void checkCursorClosed() const
		{
			if (statement && statement->cursor)
				(Arg::Gds(isc_sqlerr) << Arg::Num(-502) <<
					Arg::Gds(isc_dsql_cursor_open_err)).raise();
		}

		IStatement* getInterface()
		{
			fb_assert(statement);
			statement->addRef();
			return statement;
		}