Function DSQL_prepare

src/dsql/dsql.cpp:250–295

DSQL_prepare @brief Prepare a statement for execution. @param user_status @param trans_handle @param req_handle @param length @param string @param dialect @param item_length @param items @param buffer_length @param buffer **/

 **/
DsqlRequest* DSQL_prepare(thread_db* tdbb,
					   Attachment* attachment, jrd_tra* transaction,
					   ULONG length, const TEXT* string, USHORT dialect, unsigned prepareFlags,
					   Array<UCHAR>* items, Array<UCHAR>* buffer,
					   bool isInternalRequest)
{
	SET_TDBB(tdbb);

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

	try
	{
		// Allocate a new request block and then prepare the request.

		dsqlRequest = safePrepareRequest(tdbb, database, transaction, length, string, dialect,
			isInternalRequest);

		// Can not prepare a CREATE DATABASE/SCHEMA statement

		const auto statement = dsqlRequest->getDsqlStatement();
		if (statement->getType() == DsqlStatement::TYPE_CREATE_DB)
		{
			ERRD_post(Arg::Gds(isc_sqlerr) << Arg::Num(-530) <<
					  Arg::Gds(isc_dsql_crdb_prepare_err));
		}

		if (items && buffer)
		{
			Jrd::ContextPoolHolder context(tdbb, &dsqlRequest->getPool());
			sql_info(tdbb, dsqlRequest, items->getCount(), items->begin(),
				buffer->getCount(), buffer->begin());
		}

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


/**