queryenvironment.c File Reference

#include "postgres.h"
#include "access/table.h"
#include "utils/queryenvironment.h"
#include "utils/rel.h"

Include dependency graph for queryenvironment.c:

Go to the source code of this file.

Data Structures
struct	QueryEnvironment

Functions
QueryEnvironment *	create_queryEnv (void)
EphemeralNamedRelationMetadata	get_visible_ENR_metadata (QueryEnvironment *queryEnv, const char *refname)
void	register_ENR (QueryEnvironment *queryEnv, EphemeralNamedRelation enr)
void	unregister_ENR (QueryEnvironment *queryEnv, const char *name)
EphemeralNamedRelation	get_ENR (QueryEnvironment *queryEnv, const char *name)
TupleDesc	ENRMetadataGetTupDesc (EphemeralNamedRelationMetadata enrmd)

Function Documentation

create_queryEnv()

QueryEnvironment * create_queryEnv

(

void

)

Definition at line 39 of file queryenvironment.c.

{
    return palloc0_object(QueryEnvironment);
}

References palloc0_object.

Referenced by SPI_register_relation().

ENRMetadataGetTupDesc()

TupleDesc ENRMetadataGetTupDesc

(

EphemeralNamedRelationMetadata

enrmd

)

Definition at line 125 of file queryenvironment.c.

{
    TupleDesc   tupdesc;
 
    /* One, and only one, of these fields must be filled. */
    Assert((enrmd->reliddesc == InvalidOid) != (enrmd->tupdesc == NULL));
 
    if (enrmd->tupdesc != NULL)
        tupdesc = enrmd->tupdesc;
    else
    {
        Relation    relation;
 
        relation = table_open(enrmd->reliddesc, NoLock);
        tupdesc = relation->rd_att;
        table_close(relation, NoLock);
    }
 
    return tupdesc;
}

References Assert, fb(), InvalidOid, NoLock, RelationData::rd_att, table_close(), and table_open().

Referenced by addRangeTableEntryForENR(), and ExecInitNamedTuplestoreScan().

get_ENR()

EphemeralNamedRelation get_ENR	(	QueryEnvironment *	queryEnv,
		const char *	name
	)

Definition at line 96 of file queryenvironment.c.

{
    ListCell   *lc;
 
    Assert(name != NULL);
 
    if (queryEnv == NULL)
        return NULL;
 
    foreach(lc, queryEnv->namedRelList)
    {
        EphemeralNamedRelation enr = (EphemeralNamedRelation) lfirst(lc);
 
        if (strcmp(enr->md.name, name) == 0)
            return enr;
    }
 
    return NULL;
}

References Assert, fb(), lfirst, name, and QueryEnvironment::namedRelList.

Referenced by _SPI_find_ENR_by_name(), ExecInitNamedTuplestoreScan(), get_visible_ENR_metadata(), register_ENR(), and unregister_ENR().

get_visible_ENR_metadata()

EphemeralNamedRelationMetadata get_visible_ENR_metadata	(	QueryEnvironment *	queryEnv,
		const char *	refname
	)

Definition at line 45 of file queryenvironment.c.

{
    EphemeralNamedRelation enr;
 
    Assert(refname != NULL);
 
    if (queryEnv == NULL)
        return NULL;
 
    enr = get_ENR(queryEnv, refname);
 
    if (enr)
        return &(enr->md);
 
    return NULL;
}

References Assert, fb(), and get_ENR().

Referenced by get_visible_ENR(), and name_matches_visible_ENR().

register_ENR()

void register_ENR	(	QueryEnvironment *	queryEnv,
		EphemeralNamedRelation	enr
	)

Definition at line 69 of file queryenvironment.c.

{
    Assert(enr != NULL);
    Assert(get_ENR(queryEnv, enr->md.name) == NULL);
 
    queryEnv->namedRelList = lappend(queryEnv->namedRelList, enr);
}

References Assert, fb(), get_ENR(), lappend(), and QueryEnvironment::namedRelList.

Referenced by SPI_register_relation().

unregister_ENR()

void unregister_ENR	(	QueryEnvironment *	queryEnv,
		const char *	name
	)

Definition at line 82 of file queryenvironment.c.

{
    EphemeralNamedRelation match;
 
    match = get_ENR(queryEnv, name);
    if (match)
        queryEnv->namedRelList = list_delete(queryEnv->namedRelList, match);
}

References get_ENR(), list_delete(), name, and QueryEnvironment::namedRelList.

Referenced by SPI_unregister_relation().