Function act_fetch

src/gpre/sql.cpp:3079–3132

//

static act* act_fetch()
{
	// Handle dynamic SQL statement, if appropriate

	dyn* cursor = par_dynamic_cursor();
	if (cursor)
	{
		dyn* statement = (dyn*) MSC_alloc(DYN_LEN);
		statement->dyn_statement_name = cursor->dyn_statement_name;
		statement->dyn_cursor_name = cursor->dyn_cursor_name;
		if (MSC_match(KW_USING) || MSC_match(KW_INTO))
		{
			MSC_match(KW_SQL);		// optional for backward compatibility

			if (MSC_match(KW_DESCRIPTOR))
				statement->dyn_sqlda = PAR_native_value(false, false);
			else
				statement->dyn_using = (gpre_nod*) SQE_list(SQE_variable, NULL, false);
			if (statement->dyn_using)
				PAR_error("Using host-variable list not supported.");
		}
		act* action = (act*) MSC_alloc(ACT_LEN);
		action->act_type = ACT_dyn_fetch;
		action->act_object = (ref*) statement;
		action->act_whenever = gen_whenever();
		return action;
	}

	// Statement is static SQL

	gpre_req* request = par_cursor(NULL);

	if (request->req_flags & REQ_sql_blob_create)
		PAR_error("Fetching from a blob being created is not allowed.");

	act* action = MSC_action(request, ACT_fetch);
	action->act_whenever = gen_whenever();

	if (request->req_flags & REQ_sql_blob_open)
	{
		if (!MSC_match(KW_INTO))
			CPR_s_error("INTO");
		action->act_object = (ref*) SQE_variable(NULL, false, NULL, NULL);
		action->act_type = ACT_get_segment;
	}
	else if (MSC_match(KW_INTO))
	{
		action->act_object = (ref*) SQE_list(SQE_variable, request, false);
		gpre_rse* select = request->req_rse;
		into(request, select->rse_fields, (gpre_nod*) action->act_object);
	}

	return action;
}


//____________________________________________________________