Function act_insert_blob

src/gpre/sql.cpp:3617–3657

//

static act* act_insert_blob()
{
	// 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;
		par_using(statement);
		if (statement->dyn_using)
			PAR_error("Using host-variable list not supported.");

		act* action = (act*) MSC_alloc(ACT_LEN);
		action->act_type = ACT_dyn_insert;
		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_open)
		PAR_error("Inserting into a blob being opened is not allowed.");

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

	if (!MSC_match(KW_VALUES))
		CPR_s_error("VALUES");

	EXP_left_paren(0);
	action->act_object = (ref*) SQE_variable(NULL, false, NULL, NULL);
	if (!action->act_object->ref_null_value)
		PAR_error("A segment length is required.");
	EXP_match_paren();

	return action;
}


//____________________________________________________________