Function ResultSet_AddRecord

src/resultset/resultset.c:131–157

add a new row to resultset

// add a new row to resultset
int ResultSet_AddRecord
(
	ResultSet *set,  // resultset to extend
	Record r         // record containing projected data
) {
	ASSERT(r   != NULL);
	ASSERT(set != NULL);

	// copy projected values from record to resultset
	for(int i = 0; i < set->column_count; i++) {
		int idx = set->columns_record_map[i];
		SIValue *cell = DataBlock_AllocateItem(set->cells, NULL);
		*cell = Record_Get(r, idx);
		SIValue_Persist(cell);
		set->cells_allocation |= SI_ALLOCATION(cell);
	}

	// remove entry from record in a second pass
	// this will ensure duplicated projections are not removed
	// too early, consider: MATCH (a) RETURN max(a.val), max(a.val)
	for(int i = 0; i < set->column_count; i++) {
		int idx = set->columns_record_map[i];
		Record_Remove(r, idx);
	}

	return RESULTSET_OK;
}

// update resultset index creation statistics
void ResultSet_IndexCreated