Function act_open_blob

src/gpre/sql.cpp:3762–3938

//

static act* act_open_blob( act_t act_op, gpre_sym* symbol)
{
	if (!MSC_match(KW_BLOB))
		CPR_s_error("BLOB");

	// if the token isn't an identifier, complain

	tok* f_token = (tok*) MSC_alloc(TOK_LEN);
	f_token->tok_length = gpreGlob.token_global.tok_length;

	// Funny, as if we can have relation names up to MAX_SYM_SIZE.
	SQL_resolve_identifier("<column_name>", f_token->tok_string, f_token->tok_length + 1);
	if (gpreGlob.token_global.tok_length >= NAME_SIZE)
		PAR_error("Field name too long");

	CPR_token();

	if (act_op == ACT_blob_open)
	{
		if (!MSC_match(KW_FROM))
			CPR_s_error("FROM");
	}
	else if (!MSC_match(KW_INTO))
		CPR_s_error("INTO");

	gpre_req* request = MSC_request(REQ_cursor);
	request->req_flags = (act_op == ACT_blob_open) ? REQ_sql_blob_open : REQ_sql_blob_create;

	SCHAR r_name[NAME_SIZE], db_name[NAME_SIZE], owner_name[NAME_SIZE];
	SQL_relation_name(r_name, db_name, owner_name);


	SCHAR s[ERROR_LENGTH];
	gpre_rel* relation = SQL_relation(request, r_name, db_name, owner_name, true);
	gpre_fld* field = MET_field(relation, f_token->tok_string);
	if (!field)
	{
		fb_utils::snprintf(s, sizeof(s), "column \"%s\" not in context", f_token->tok_string);
		PAR_error(s);
	}

	if (!(field->fld_flags & FLD_blob))
	{
		fb_utils::snprintf(s, sizeof(s), "column %s is not a BLOB", field->fld_symbol->sym_string);
		PAR_error(s);
	}

	if (field->fld_array_info)
	{
		fb_utils::snprintf(s, sizeof(s), "column %s is an array and can not be opened as a BLOB",
			field->fld_symbol->sym_string);
		PAR_error(s);
	}

	ref* reference = MSC_reference(0);
	reference->ref_field = field;

	gpre_ctx* context = MSC_context(request);