Function DSQL_execute_immediate

src/dsql/dsql.cpp:327–380

Common part of prepare and execute a statement.

// Common part of prepare and execute a statement.
void DSQL_execute_immediate(thread_db* tdbb, Jrd::Attachment* attachment, jrd_tra** tra_handle,
	ULONG length, const TEXT* string, USHORT dialect,
	IMessageMetadata* in_meta, const UCHAR* in_msg,
	IMessageMetadata* out_meta, UCHAR* out_msg,
	bool isInternalRequest)
{
	SET_TDBB(tdbb);

	dsql_dbb* const database = init(tdbb, attachment);
	DsqlRequest* dsqlRequest = NULL;

	try
	{
		dsqlRequest = safePrepareRequest(tdbb, database, *tra_handle, length, string, dialect,
			isInternalRequest);

		const auto dsqlStatement = dsqlRequest->getDsqlStatement();

		// Only allow NULL trans_handle if we're starting a transaction or set session properties

		if (!*tra_handle &&
			dsqlStatement->getType() != DsqlStatement::TYPE_START_TRANS &&
			dsqlStatement->getType() != DsqlStatement::TYPE_SESSION_MANAGEMENT)
		{
			ERRD_post(Arg::Gds(isc_sqlerr) << Arg::Num(-901) <<
					  Arg::Gds(isc_bad_trans_handle));
		}

		Jrd::ContextPoolHolder context(tdbb, &dsqlRequest->getPool());

		// A select having cursor is a singleton select when executed immediate
		const bool singleton = dsqlStatement->isCursorBased();
		if (singleton && !(out_msg && out_meta))
		{
			ERRD_post(Arg::Gds(isc_dsql_sqlda_err) <<
					  Arg::Gds(isc_dsql_no_output_sqlda));
		}

		dsqlRequest->req_transaction = *tra_handle;

		dsqlRequest->execute(tdbb, tra_handle, in_meta, in_msg, out_meta, out_msg, singleton);

		DsqlRequest::destroy(tdbb, dsqlRequest);
	}
	catch (const Exception&)
	{
		if (dsqlRequest)
		{
			Jrd::ContextPoolHolder context(tdbb, &dsqlRequest->getPool());
			DsqlRequest::destroy(tdbb, dsqlRequest);
		}
		throw;
	}
}


/**