Method store

src/dsql/StmtNodes.cpp:8153–8298

Execute a STORE statement.

// Execute a STORE statement.
const StmtNode* StoreNode::store(thread_db* tdbb, Request* request, WhichTrigger whichTrig) const
{
	jrd_tra* transaction = request->req_transaction;
	impure_state* impure = request->getImpure<impure_state>(impureOffset);

	const StreamType stream = target->getStream();
	record_param* rpb = &request->req_rpb[stream];
	jrd_rel* relation = rpb->rpb_relation;

	if ((marks & MARK_BULK_INSERT) || request->req_batch_mode)
		rpb->rpb_stream_flags |= RPB_s_bulk;

	const auto localTableSource = nodeAs<LocalTableSourceNode>(target);
	const auto localTable = localTableSource ?
		request->getStatement()->localTables[localTableSource->tableNumber] :
		nullptr;
	const auto localTableImpure = localTable ? localTable->getImpure(tdbb, request) : nullptr;

	switch (request->req_operation)
	{
		case Request::req_evaluate:
			if (!(marks & MARK_AVOID_COUNTERS))
			{
				if (!nodeIs<ForNode>(parentStmt))
					request->req_records_affected.clear();

				request->req_records_affected.bumpModified(false);
			}

			impure->sta_state = 0;
			if (relation)
				RLCK_reserve_relation(tdbb, transaction, relation, true);
			break;

		case Request::req_return:
			if (!impure->sta_state)
			{
				SavepointChangeMarker scMarker(transaction);

				if (relation && relation->rel_pre_store && whichTrig != POST_TRIG)
				{
					EXE_execute_triggers(tdbb, &relation->rel_pre_store, NULL, rpb,
						TRIGGER_INSERT, PRE_TRIG);
				}

				if (validations.hasData())
					validateExpressions(tdbb, validations);

				// For optimum on-disk record compression, zero all unassigned
				// fields. In addition, zero the tail of assigned varying fields
				// so that previous remnants don't defeat compression efficiency.

				// CVC: The code that was here was moved to its own routine: cleanupRpb()
				// and replaced by the call shown below.

				cleanupRpb(tdbb, rpb);

				if (localTableSource)