Method erase

src/dsql/StmtNodes.cpp:2660–2822

Perform erase operation.

// Perform erase operation.
const StmtNode* EraseNode::erase(thread_db* tdbb, Request* request, WhichTrigger whichTrig) const
{
	impure_state* impure = request->getImpure<impure_state>(impureOffset);

	jrd_tra* transaction = request->req_transaction;
	record_param* rpb = &request->req_rpb[stream];
	jrd_rel* relation = rpb->rpb_relation;

	switch (request->req_operation)
	{
		case Request::req_evaluate:
		{
			impure->sta_state = 0;

			if (!(marks & MARK_AVOID_COUNTERS))
				request->req_records_affected.bumpModified(false);

			if (!statement)
				break;

			const Format* format = MET_current(tdbb, rpb->rpb_relation);
			Record* record = VIO_record(tdbb, rpb, format, tdbb->getDefaultPool());

			rpb->rpb_address = record->getData();
			rpb->rpb_length = format->fmt_length;
			rpb->rpb_format_number = format->fmt_version;

			return statement;
		}

		case Request::req_return:
			if (impure->sta_state == 1)
			{
				impure->sta_state = 0;
				rpb->rpb_number.setValid(false);
				return parentStmt;
			}
			break;

		default:
			return parentStmt;
	}

	request->req_operation = Request::req_return;
	RLCK_reserve_relation(tdbb, transaction, relation, true);

	if (rpb->rpb_runtime_flags & RPB_just_deleted)
		return parentStmt;

	if (rpb->rpb_number.isBof() || (!relation->rel_view_rse && !rpb->rpb_number.isValid()))
		ERR_post(Arg::Gds(isc_no_cur_rec));

	if (forNode && forNode->isWriteLockMode(request))
	{
		forceWriteLock(tdbb, rpb, transaction);
		return parentStmt;
	}