Method getInfo

src/dsql/DsqlCursor.cpp:215–288

}

void DsqlCursor::getInfo(thread_db* tdbb,
						 unsigned int itemsLength, const unsigned char* items,
						 unsigned int bufferLength, unsigned char* buffer)
{
	if (bufferLength < 7) // isc_info_error + 2-byte length + 4-byte error code
	{
		if (bufferLength)
			*buffer = isc_info_truncated;
		return;
	}

	const bool isScrollable = (m_flags & IStatement::CURSOR_TYPE_SCROLLABLE);

	ClumpletWriter response(ClumpletReader::InfoResponse, bufferLength - 1); // isc_info_end
	ISC_STATUS errorCode = 0;
	bool needLength = false, completed = false;

	try
	{
		ClumpletReader infoItems(ClumpletReader::InfoItems, items, itemsLength);
		for (infoItems.rewind(); !errorCode && !infoItems.isEof(); infoItems.moveNext())
		{
			const auto tag = infoItems.getClumpTag();

			switch (tag)
			{
			case isc_info_end:
				break;

			case isc_info_length:
				needLength = true;
				break;

			case IResultSet::INF_RECORD_COUNT:
				if (isScrollable && !m_eof)
				{
					cacheInput(tdbb);
					fb_assert(m_eof);
				}
				response.insertInt(tag, isScrollable ? m_cachedCount : -1);
				break;

			default:
				errorCode = isc_infunk;
				break;
			}
		}

		completed = infoItems.isEof();

		if (needLength && completed)
		{
			response.rewind();
			response.insertInt(isc_info_length, response.getBufferLength() + 1); // isc_info_end
		}
	}
	catch (const Exception&)
	{