Function into

src/gpre/sql.cpp:5413–5465

//

static void into( gpre_req* request, gpre_nod* field_list, gpre_nod* var_list)
{
	if (!var_list)
		PAR_error("INTO list is required");

	if (!field_list || field_list->nod_count != var_list->nod_count)
		PAR_error("column count and number of INTO list host-variables unequal");

	gpre_nod** var_ptr = var_list->nod_arg;
	gpre_nod** fld_ptr = field_list->nod_arg;

	for (gpre_nod** const end = fld_ptr + var_list->nod_count; fld_ptr < end;fld_ptr++, var_ptr++)
	{
		ref* var_ref = (ref*) *var_ptr;
		ref* field_ref = NULL;
		gpre_req* slice_req = NULL;
		if (((*fld_ptr)->nod_type == nod_field) || ((*fld_ptr)->nod_type == nod_array))
		{
			field_ref = (ref*) (*fld_ptr)->nod_arg[0];
			if ((*fld_ptr)->nod_count > 2)
				slice_req = (gpre_req*) (*fld_ptr)->nod_arg[2];
		}

		ref* reference = NULL;
		gpre_fld* field;
		if (field_ref && slice_req && (field = field_ref->ref_field) && field->fld_array)
		{
			EXP_post_array(field_ref);

			// If field ref not posted yet, post it

			bool found = false;
			for (reference = request->req_references; reference; reference = reference->ref_next)
			{
				if (reference == field_ref)
				{
					found = true;
					break;
				}
			}
			if (!found)
			{
				field_ref->ref_next = request->req_references;
				request->req_references = field_ref;
			}
			reference = field_ref;
		}
		else
			reference = SQE_post_reference(request, 0, 0, *fld_ptr);
		var_ref->ref_friend = reference;
		reference->ref_null_value = var_ref->ref_null_value;
	}
}


//____________________________________________________________