Function act_openclose

src/gpre/sql.cpp:3678–3753

//

static act* act_openclose(act_t type)
{
	const TEXT* transaction = 0;

	if (type == ACT_open)
		par_options(&transaction);

	// 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;
		act* action = (act*) MSC_alloc(ACT_LEN);
		action->act_object = (ref*) statement;
		action->act_whenever = gen_whenever();
		if (type == ACT_open)
		{
			action->act_type = ACT_dyn_open;
			statement->dyn_trans = transaction;
			par_using(statement);
			if (statement->dyn_using)
				PAR_error("Using host-variable list not supported.");
			par_into(statement);
		}
		else
			action->act_type = ACT_dyn_close;
		return action;
	}

	// Statement is static SQL

	gpre_sym* symbol = NULL;
	gpre_req* request = par_cursor(&symbol);

	act* action = MSC_action(request, type);
	if (type == ACT_open)
	{
		open_cursor* open = (open_cursor*) MSC_alloc(OPN_LEN);
		open->opn_trans = transaction;
		open->opn_cursor = symbol;
		action->act_object = (ref*) open;
		if (transaction != NULL)
			request->req_trans = transaction;
		if (request->req_flags & (REQ_sql_blob_open | REQ_sql_blob_create))
		{
			if (request->req_flags & REQ_sql_blob_open)
			{
				if (!MSC_match(KW_USING))
					CPR_s_error("USING");
			}
			else if (!MSC_match(KW_INTO))
				CPR_s_error("INTO");
			ref* opn_using = (ref*) SQE_variable(NULL, false, NULL, NULL);
			open->opn_using = opn_using;
			opn_using->ref_next = request->req_blobs->blb_reference;