Function act_set_generator

src/gpre/sql.cpp:4214–4255

//

static act* act_set_generator()
{
	gpre_req* request = MSC_request(REQ_set_generator);

	if (gpreGlob.isc_databases && !gpreGlob.isc_databases->dbb_next)
		request->req_database = gpreGlob.isc_databases;
	else
		PAR_error("Can SET GENERATOR in context of single database only");

	set_gen* setgen = (set_gen*) MSC_alloc(SGEN_LEN);
	setgen->sgen_name = (TEXT*) MSC_alloc(NAME_SIZE + 1);
	SQL_resolve_identifier("<identifier>", setgen->sgen_name, NAME_SIZE + 1);
	if (gpreGlob.token_global.tok_length >= NAME_SIZE)
		PAR_error("Generator name too long");

	if (!MET_generator(setgen->sgen_name, request->req_database))
	{
		SCHAR s[ERROR_LENGTH];
		fb_utils::snprintf(s, sizeof(s),
			"generator %s not found", gpreGlob.token_global.tok_string);
		PAR_error(s);
	}
	PAR_get_token();
	MSC_match(KW_TO);
	if ((gpreGlob.sw_sql_dialect == SQL_DIALECT_V5) || (gpreGlob.sw_server_version < 6))
	{
		setgen->sgen_value = EXP_SLONG_ordinal(true);
		setgen->sgen_dialect = SQL_DIALECT_V5;
	}
	else
	{
		// dialect is > 1. Server can handle int64

		setgen->sgen_int64value = EXP_SINT64_ordinal(true);
		setgen->sgen_dialect = SQL_DIALECT_V5 + 1;
	}

	act* action = (act*) MSC_action(request, ACT_s_start);
	action->act_whenever = gen_whenever();
	action->act_object = (ref*) setgen;
	return action;
}


//____________________________________________________________