propgraphcmds.h File Reference

#include "catalog/objectaddress.h"
#include "parser/parse_node.h"

Include dependency graph for propgraphcmds.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Functions
ObjectAddress	CreatePropGraph (ParseState *pstate, const CreatePropGraphStmt *stmt)
ObjectAddress	AlterPropGraph (ParseState *pstate, const AlterPropGraphStmt *stmt)

Function Documentation

AlterPropGraph()

ObjectAddress AlterPropGraph ( ParseState *  pstate, const AlterPropGraphStmt *  stmt  )

extern

Definition at line 1291 of file propgraphcmds.c.

{
    Oid         pgrelid;
    ListCell   *lc;
    ObjectAddress pgaddress;
 
    /*
     * ShareRowExclusiveLock is required because this command runs some
     * graph-wide consistency checks that wouldn't work if more than one ALTER
     * PROPERTY GRAPH could operate on the same graph at once.
     */
    pgrelid = RangeVarGetRelidExtended(stmt->pgname,
                                       ShareRowExclusiveLock,
                                       stmt->missing_ok ? RVR_MISSING_OK : 0,
                                       RangeVarCallbackOwnsRelation,
                                       NULL);
    if (pgrelid == InvalidOid)
    {
        ereport(NOTICE,
                (errmsg("relation \"%s\" does not exist, skipping",
                        stmt->pgname->relname)));
        return InvalidObjectAddress;
    }
 
    ObjectAddressSet(pgaddress, RelationRelationId, pgrelid);
 
    foreach(lc, stmt->add_vertex_tables)
    {
        PropGraphVertex *vertex = lfirst_node(PropGraphVertex, lc);
        struct element_info *vinfo;
        Relation    rel;
        Oid         peoid;
 
        vinfo = palloc0_object(struct element_info);
        vinfo->kind = PGEKIND_VERTEX;
 
        vinfo->relid = RangeVarGetRelidExtended(vertex->vtable, AccessShareLock, 0, RangeVarCallbackOwnsRelation, NULL);
 
        rel = table_open(vinfo->relid, NoLock);
 
        if (rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP && get_rel_persistence(pgrelid) != RELPERSISTENCE_TEMP)
            ereport(ERROR,
                    (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
                     errmsg("cannot add temporary element table to non-temporary property graph"),
                     errdetail("Table \"%s\" is a temporary table.", get_rel_name(vinfo->relid)),
                     parser_errposition(pstate, vertex->vtable->location)));
 
        if (vertex->vtable->alias)
            vinfo->aliasname = vertex->vtable->alias->aliasname;
        else
            vinfo->aliasname = vertex->vtable->relname;
 
        vinfo->key = propgraph_element_get_key(pstate, vertex->vkey, rel, vinfo->aliasname, vertex->location);
 
        vinfo->labels = vertex->labels;
 
        table_close(rel, NoLock);
 
        if (SearchSysCacheExists2(PROPGRAPHELALIAS,
                                  ObjectIdGetDatum(pgrelid),
                                  CStringGetDatum(vinfo->aliasname)))
            ereport(ERROR,
                    errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
                    errmsg("alias \"%s\" already exists in property graph \"%s\"",
                           vinfo->aliasname, stmt->pgname->relname),
                    parser_errposition(pstate, vertex->vtable->location));
 
        peoid = insert_element_record(pgaddress, vinfo);
 
        CommandCounterIncrement();
        check_element_properties(peoid);
        check_all_labels_properties(pgrelid);
    }
 
    foreach(lc, stmt->add_edge_tables)
    {
        PropGraphEdge *edge = lfirst_node(PropGraphEdge, lc);
        struct element_info *einfo;
        Relation    rel;
        Relation    srcrel;
        Relation    destrel;
        Oid         peoid;
 
        einfo = palloc0_object(struct element_info);
        einfo->kind = PGEKIND_EDGE;
 
        einfo->relid = RangeVarGetRelidExtended(edge->etable, AccessShareLock, 0, RangeVarCallbackOwnsRelation, NULL);
 
        rel = table_open(einfo->relid, NoLock);
 
        if (rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP && get_rel_persistence(pgrelid) != RELPERSISTENCE_TEMP)
            ereport(ERROR,
                    (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
                     errmsg("cannot add temporary element table to non-temporary property graph"),
                     errdetail("Table \"%s\" is a temporary table.", get_rel_name(einfo->relid)),
                     parser_errposition(pstate, edge->etable->location)));
 
        if (edge->etable->alias)
            einfo->aliasname = edge->etable->alias->aliasname;
        else
            einfo->aliasname = edge->etable->relname;
 
        einfo->key = propgraph_element_get_key(pstate, edge->ekey, rel, einfo->aliasname, edge->location);
 
        einfo->srcvertexid = get_vertex_oid(pstate, pgrelid, edge->esrcvertex, edge->location);
        einfo->destvertexid = get_vertex_oid(pstate, pgrelid, edge->edestvertex, edge->location);
 
        einfo->srcrelid = get_element_relid(einfo->srcvertexid);
        einfo->destrelid = get_element_relid(einfo->destvertexid);
 
        srcrel = table_open(einfo->srcrelid, AccessShareLock);
        destrel = table_open(einfo->destrelid, AccessShareLock);
 
        propgraph_edge_get_ref_keys(pstate, edge->esrckey, edge->esrcvertexcols, rel, srcrel,
                                    einfo->aliasname, edge->location, "SOURCE",
                                    &einfo->srckey, &einfo->srcref, &einfo->srceqop);
        propgraph_edge_get_ref_keys(pstate, edge->edestkey, edge->edestvertexcols, rel, destrel,
                                    einfo->aliasname, edge->location, "DESTINATION",
                                    &einfo->destkey, &einfo->destref, &einfo->desteqop);
 
        einfo->labels = edge->labels;
 
        table_close(destrel, NoLock);
        table_close(srcrel, NoLock);
 
        table_close(rel, NoLock);
 
        if (SearchSysCacheExists2(PROPGRAPHELALIAS,
                                  ObjectIdGetDatum(pgrelid),
                                  CStringGetDatum(einfo->aliasname)))
            ereport(ERROR,
                    errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
                    errmsg("alias \"%s\" already exists in property graph \"%s\"",
                           einfo->aliasname, stmt->pgname->relname),
                    parser_errposition(pstate, edge->etable->location));
 
        peoid = insert_element_record(pgaddress, einfo);
 
        CommandCounterIncrement();
        check_element_properties(peoid);
        check_all_labels_properties(pgrelid);
    }
 
    foreach(lc, stmt->drop_vertex_tables)
    {
        char       *alias = strVal(lfirst(lc));
        Oid         peoid;
        ObjectAddress obj;
 
        peoid = get_vertex_oid(pstate, pgrelid, alias, -1);
        ObjectAddressSet(obj, PropgraphElementRelationId, peoid);
        performDeletion(&obj, stmt->drop_behavior, 0);
    }
 
    foreach(lc, stmt->drop_edge_tables)
    {
        char       *alias = strVal(lfirst(lc));
        Oid         peoid;
        ObjectAddress obj;
 
        peoid = get_edge_oid(pstate, pgrelid, alias, -1);
        ObjectAddressSet(obj, PropgraphElementRelationId, peoid);
        performDeletion(&obj, stmt->drop_behavior, 0);
    }
 
    /* Remove any orphaned pg_propgraph_label entries */
    if (stmt->drop_vertex_tables || stmt->drop_edge_tables)
    {
        foreach_oid(labeloid, get_graph_label_ids(pgrelid))
        {
            if (!get_label_element_label_ids(labeloid))
            {
                ObjectAddress obj;
 
                ObjectAddressSet(obj, PropgraphLabelRelationId, labeloid);
                performDeletion(&obj, stmt->drop_behavior, 0);
            }
        }
    }
 
    foreach(lc, stmt->add_labels)
    {
        PropGraphLabelAndProperties *lp = lfirst_node(PropGraphLabelAndProperties, lc);
        Oid         peoid;
        Oid         pgerelid;
        Oid         ellabeloid;
 
        Assert(lp->label);
 
        if (stmt->element_kind == PROPGRAPH_ELEMENT_KIND_VERTEX)
            peoid = get_vertex_oid(pstate, pgrelid, stmt->element_alias, -1);
        else
            peoid = get_edge_oid(pstate, pgrelid, stmt->element_alias, -1);
 
        pgerelid = get_element_relid(peoid);
 
        ellabeloid = insert_label_record(pgrelid, peoid, lp->label);
        insert_property_records(pgrelid, ellabeloid, pgerelid, lp->properties);
 
        CommandCounterIncrement();
        check_element_properties(peoid);
        check_element_label_properties(ellabeloid);
    }
 
    if (stmt->drop_label)
    {
        Oid         peoid;
        Oid         labeloid;
        Oid         ellabeloid = InvalidOid;
        ObjectAddress obj;
        Relation    ellabelrel;
        SysScanDesc ellabelscan;
        ScanKeyData ellabelkey[1];
        int         nlabels;
        HeapTuple   tuple;
 
        if (stmt->element_kind == PROPGRAPH_ELEMENT_KIND_VERTEX)
            peoid = get_vertex_oid(pstate, pgrelid, stmt->element_alias, -1);
        else
            peoid = get_edge_oid(pstate, pgrelid, stmt->element_alias, -1);
 
        labeloid = GetSysCacheOid2(PROPGRAPHLABELNAME,
                                   Anum_pg_propgraph_label_oid,
                                   ObjectIdGetDatum(pgrelid),
                                   CStringGetDatum(stmt->drop_label));
        if (!labeloid)
            ereport(ERROR,
                    errcode(ERRCODE_UNDEFINED_OBJECT),
                    errmsg("property graph \"%s\" element \"%s\" has no label \"%s\"",
                           get_rel_name(pgrelid), stmt->element_alias, stmt->drop_label),
                    parser_errposition(pstate, -1));
 
        /*
         * Is the given label associated with the element?  Is this the only
         * label associated with the element?  Scan the
         * pg_propgraph_element_label table to find answers to these
         * questions.  Stop scanning when we know both answers.
         */
        ellabelrel = table_open(PropgraphElementLabelRelationId, AccessShareLock);
        ScanKeyInit(&ellabelkey[0],
                    Anum_pg_propgraph_element_label_pgelelid,
                    BTEqualStrategyNumber, F_OIDEQ,
                    ObjectIdGetDatum(peoid));
        ellabelscan = systable_beginscan(ellabelrel, PropgraphElementLabelElementLabelIndexId,
                                         true, NULL, 1, ellabelkey);
        nlabels = 0;
        while (HeapTupleIsValid(tuple = systable_getnext(ellabelscan)))
        {
            Form_pg_propgraph_element_label ellabelform = (Form_pg_propgraph_element_label) GETSTRUCT(tuple);
 
            nlabels++;
 
            if (ellabelform->pgellabelid == labeloid)
                ellabeloid = ellabelform->oid;
 
            if (nlabels > 1 && ellabeloid)
                break;
        }
        systable_endscan(ellabelscan);
        table_close(ellabelrel, AccessShareLock);
 
        if (!ellabeloid)
            ereport(ERROR,
                    errcode(ERRCODE_UNDEFINED_OBJECT),
                    errmsg("property graph \"%s\" element \"%s\" has no label \"%s\"",
                           get_rel_name(pgrelid), stmt->element_alias, stmt->drop_label),
                    parser_errposition(pstate, -1));
 
        /*
         * Prevent dropping the last label from an element. Every element must
         * have at least one label associated with it.
         */
        if (nlabels == 1)
            ereport(ERROR,
                    (errcode(ERRCODE_OBJECT_NOT_IN_PREREQUISITE_STATE),
                     errmsg("cannot drop the last label from element \"%s\"",
                            stmt->element_alias),
                     errhint("Every element must have at least one label.")));
 
        ObjectAddressSet(obj, PropgraphElementLabelRelationId, ellabeloid);
        performDeletion(&obj, stmt->drop_behavior, 0);
 
        /* Remove any orphaned pg_propgraph_label entries */
        if (!get_label_element_label_ids(labeloid))
        {
            ObjectAddressSet(obj, PropgraphLabelRelationId, labeloid);
            performDeletion(&obj, stmt->drop_behavior, 0);
        }
    }
 
    if (stmt->add_properties)
    {
        Oid         peoid;
        Oid         pgerelid;
        Oid         labeloid;
        Oid         ellabeloid = InvalidOid;
 
        if (stmt->element_kind == PROPGRAPH_ELEMENT_KIND_VERTEX)
            peoid = get_vertex_oid(pstate, pgrelid, stmt->element_alias, -1);
        else
            peoid = get_edge_oid(pstate, pgrelid, stmt->element_alias, -1);
 
        labeloid = GetSysCacheOid2(PROPGRAPHLABELNAME,
                                   Anum_pg_propgraph_label_oid,
                                   ObjectIdGetDatum(pgrelid),
                                   CStringGetDatum(stmt->alter_label));
        if (labeloid)
            ellabeloid = GetSysCacheOid2(PROPGRAPHELEMENTLABELELEMENTLABEL,
                                         Anum_pg_propgraph_element_label_oid,
                                         ObjectIdGetDatum(peoid),
                                         ObjectIdGetDatum(labeloid));
        if (!ellabeloid)
            ereport(ERROR,
                    errcode(ERRCODE_UNDEFINED_OBJECT),
                    errmsg("property graph \"%s\" element \"%s\" has no label \"%s\"",
                           get_rel_name(pgrelid), stmt->element_alias, stmt->alter_label),
                    parser_errposition(pstate, -1));
 
        pgerelid = get_element_relid(peoid);
 
        insert_property_records(pgrelid, ellabeloid, pgerelid, stmt->add_properties);
 
        CommandCounterIncrement();
        check_element_properties(peoid);
        check_element_label_properties(ellabeloid);
    }
 
    if (stmt->drop_properties)
    {
        Oid         peoid;
        Oid         labeloid;
        Oid         ellabeloid = InvalidOid;
        ObjectAddress obj;
 
        if (stmt->element_kind == PROPGRAPH_ELEMENT_KIND_VERTEX)
            peoid = get_vertex_oid(pstate, pgrelid, stmt->element_alias, -1);
        else
            peoid = get_edge_oid(pstate, pgrelid, stmt->element_alias, -1);
 
        labeloid = GetSysCacheOid2(PROPGRAPHLABELNAME,
                                   Anum_pg_propgraph_label_oid,
                                   ObjectIdGetDatum(pgrelid),
                                   CStringGetDatum(stmt->alter_label));
        if (labeloid)
            ellabeloid = GetSysCacheOid2(PROPGRAPHELEMENTLABELELEMENTLABEL,
                                         Anum_pg_propgraph_element_label_oid,
                                         ObjectIdGetDatum(peoid),
                                         ObjectIdGetDatum(labeloid));
 
        if (!ellabeloid)
            ereport(ERROR,
                    errcode(ERRCODE_UNDEFINED_OBJECT),
                    errmsg("property graph \"%s\" element \"%s\" has no label \"%s\"",
                           get_rel_name(pgrelid), stmt->element_alias, stmt->alter_label),
                    parser_errposition(pstate, -1));
 
        foreach(lc, stmt->drop_properties)
        {
            char       *propname = strVal(lfirst(lc));
            Oid         propoid;
            Oid         plpoid = InvalidOid;
 
            propoid = GetSysCacheOid2(PROPGRAPHPROPNAME,
                                      Anum_pg_propgraph_property_oid,
                                      ObjectIdGetDatum(pgrelid),
                                      CStringGetDatum(propname));
            if (propoid)
                plpoid = GetSysCacheOid2(PROPGRAPHLABELPROP,
                                         Anum_pg_propgraph_label_property_oid,
                                         ObjectIdGetDatum(ellabeloid),
                                         ObjectIdGetDatum(propoid));
            if (!plpoid)
                ereport(ERROR,
                        errcode(ERRCODE_UNDEFINED_OBJECT),
                        errmsg("property graph \"%s\" element \"%s\" label \"%s\" has no property \"%s\"",
                               get_rel_name(pgrelid), stmt->element_alias, stmt->alter_label, propname),
                        parser_errposition(pstate, -1));
 
            ObjectAddressSet(obj, PropgraphLabelPropertyRelationId, plpoid);
            performDeletion(&obj, stmt->drop_behavior, 0);
        }
 
        check_element_label_properties(ellabeloid);
    }
 
    /* Remove any orphaned pg_propgraph_property entries */
    if (stmt->drop_properties || stmt->drop_vertex_tables || stmt->drop_edge_tables || stmt->drop_label)
    {
        foreach_oid(propoid, get_graph_property_ids(pgrelid))
        {
            Relation    rel;
            SysScanDesc scan;
            ScanKeyData key[1];
 
            rel = table_open(PropgraphLabelPropertyRelationId, RowShareLock);
            ScanKeyInit(&key[0],
                        Anum_pg_propgraph_label_property_plppropid,
                        BTEqualStrategyNumber, F_OIDEQ,
                        ObjectIdGetDatum(propoid));
            /* XXX no suitable index */
            scan = systable_beginscan(rel, InvalidOid, true, NULL, 1, key);
            if (!systable_getnext(scan))
            {
                ObjectAddress obj;
 
                ObjectAddressSet(obj, PropgraphPropertyRelationId, propoid);
                performDeletion(&obj, stmt->drop_behavior, 0);
            }
 
            systable_endscan(scan);
            table_close(rel, RowShareLock);
        }
    }
 
    /*
     * Invalidate relcache entry of the property graph so that the queries in
     * the cached plans referencing the property graph will be rewritten
     * considering changes to the property graph.
     */
    CacheInvalidateRelcacheByRelid(pgrelid);
 
    return pgaddress;
}

References AccessShareLock, Assert, BTEqualStrategyNumber, CacheInvalidateRelcacheByRelid(), check_all_labels_properties(), check_element_label_properties(), check_element_properties(), CommandCounterIncrement(), CStringGetDatum(), ereport, errcode(), errdetail(), errhint(), errmsg, ERROR, fb(), foreach_oid, Form_pg_propgraph_element_label, get_edge_oid(), get_element_relid(), get_graph_label_ids(), get_graph_property_ids(), get_label_element_label_ids(), get_rel_name(), get_rel_persistence(), get_vertex_oid(), GETSTRUCT(), GetSysCacheOid2, HeapTupleIsValid, insert_element_record(), insert_label_record(), insert_property_records(), InvalidObjectAddress, InvalidOid, element_info::key, lfirst, lfirst_node, NoLock, NOTICE, ObjectAddressSet, ObjectIdGetDatum(), palloc0_object, parser_errposition(), performDeletion(), propgraph_edge_get_ref_keys(), propgraph_element_get_key(), PROPGRAPH_ELEMENT_KIND_VERTEX, RangeVarCallbackOwnsRelation(), RangeVarGetRelidExtended(), RelationData::rd_rel, RowShareLock, RVR_MISSING_OK, ScanKeyInit(), SearchSysCacheExists2, ShareRowExclusiveLock, stmt, strVal, systable_beginscan(), systable_endscan(), systable_getnext(), table_close(), and table_open().

Referenced by ProcessUtilitySlow().

CreatePropGraph()

ObjectAddress CreatePropGraph ( ParseState *  pstate, const CreatePropGraphStmt *  stmt  )

extern

Definition at line 104 of file propgraphcmds.c.

{
    CreateStmt *cstmt = makeNode(CreateStmt);
    char        components_persistence;
    ListCell   *lc;
    ObjectAddress pgaddress;
    List       *vertex_infos = NIL;
    List       *edge_infos = NIL;
    List       *element_aliases = NIL;
    List       *element_oids = NIL;
 
    if (stmt->pgname->relpersistence == RELPERSISTENCE_UNLOGGED)
        ereport(ERROR,
                (errcode(ERRCODE_SYNTAX_ERROR),
                 errmsg("property graphs cannot be unlogged because they do not have storage")));
 
    components_persistence = RELPERSISTENCE_PERMANENT;
 
    foreach(lc, stmt->vertex_tables)
    {
        PropGraphVertex *vertex = lfirst_node(PropGraphVertex, lc);
        struct element_info *vinfo;
        Relation    rel;
 
        vinfo = palloc0_object(struct element_info);
        vinfo->kind = PGEKIND_VERTEX;
 
        vinfo->relid = RangeVarGetRelidExtended(vertex->vtable, AccessShareLock, 0, RangeVarCallbackOwnsRelation, NULL);
 
        rel = table_open(vinfo->relid, NoLock);
 
        if (rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP)
            components_persistence = RELPERSISTENCE_TEMP;
 
        if (vertex->vtable->alias)
            vinfo->aliasname = vertex->vtable->alias->aliasname;
        else
            vinfo->aliasname = vertex->vtable->relname;
 
        if (list_member(element_aliases, makeString(vinfo->aliasname)))
            ereport(ERROR,
                    (errcode(ERRCODE_DUPLICATE_TABLE),
                     errmsg("alias \"%s\" used more than once as element table", vinfo->aliasname),
                     parser_errposition(pstate, vertex->location)));
 
        vinfo->key = propgraph_element_get_key(pstate, vertex->vkey, rel, vinfo->aliasname, vertex->location);
 
        vinfo->labels = vertex->labels;
 
        table_close(rel, NoLock);
 
        vertex_infos = lappend(vertex_infos, vinfo);
 
        element_aliases = lappend(element_aliases, makeString(vinfo->aliasname));
    }
 
    foreach(lc, stmt->edge_tables)
    {
        PropGraphEdge *edge = lfirst_node(PropGraphEdge, lc);
        struct element_info *einfo;
        Relation    rel;
        ListCell   *lc2;
        Oid         srcrelid;
        Oid         destrelid;
        Relation    srcrel;
        Relation    destrel;
 
        einfo = palloc0_object(struct element_info);
        einfo->kind = PGEKIND_EDGE;
 
        einfo->relid = RangeVarGetRelidExtended(edge->etable, AccessShareLock, 0, RangeVarCallbackOwnsRelation, NULL);
 
        rel = table_open(einfo->relid, NoLock);
 
        if (rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP)
            components_persistence = RELPERSISTENCE_TEMP;
 
        if (edge->etable->alias)
            einfo->aliasname = edge->etable->alias->aliasname;
        else
            einfo->aliasname = edge->etable->relname;
 
        if (list_member(element_aliases, makeString(einfo->aliasname)))
            ereport(ERROR,
                    (errcode(ERRCODE_DUPLICATE_TABLE),
                     errmsg("alias \"%s\" used more than once as element table", einfo->aliasname),
                     parser_errposition(pstate, edge->location)));
 
        einfo->key = propgraph_element_get_key(pstate, edge->ekey, rel, einfo->aliasname, edge->location);
 
        einfo->srcvertex = edge->esrcvertex;
        einfo->destvertex = edge->edestvertex;
 
        srcrelid = 0;
        destrelid = 0;
        foreach(lc2, vertex_infos)
        {
            struct element_info *vinfo = lfirst(lc2);
 
            if (strcmp(vinfo->aliasname, edge->esrcvertex) == 0)
                srcrelid = vinfo->relid;
 
            if (strcmp(vinfo->aliasname, edge->edestvertex) == 0)
                destrelid = vinfo->relid;
 
            if (srcrelid && destrelid)
                break;
        }
        if (!srcrelid)
            ereport(ERROR,
                    (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
                     errmsg("source vertex \"%s\" of edge \"%s\" does not exist",
                            edge->esrcvertex, einfo->aliasname),
                     parser_errposition(pstate, edge->location)));
        if (!destrelid)
            ereport(ERROR,
                    (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
                     errmsg("destination vertex \"%s\" of edge \"%s\" does not exist",
                            edge->edestvertex, einfo->aliasname),
                     parser_errposition(pstate, edge->location)));
 
        srcrel = table_open(srcrelid, NoLock);
        destrel = table_open(destrelid, NoLock);
 
        propgraph_edge_get_ref_keys(pstate, edge->esrckey, edge->esrcvertexcols, rel, srcrel,
                                    einfo->aliasname, edge->location, "SOURCE",
                                    &einfo->srckey, &einfo->srcref, &einfo->srceqop);
        propgraph_edge_get_ref_keys(pstate, edge->edestkey, edge->edestvertexcols, rel, destrel,
                                    einfo->aliasname, edge->location, "DESTINATION",
                                    &einfo->destkey, &einfo->destref, &einfo->desteqop);
 
        einfo->labels = edge->labels;
 
        table_close(destrel, NoLock);
        table_close(srcrel, NoLock);
 
        table_close(rel, NoLock);
 
        edge_infos = lappend(edge_infos, einfo);
 
        element_aliases = lappend(element_aliases, makeString(einfo->aliasname));
    }
 
    cstmt->relation = stmt->pgname;
    cstmt->oncommit = ONCOMMIT_NOOP;
 
    /*
     * Automatically make it temporary if any component tables are temporary
     * (see also DefineView()).
     */
    if (stmt->pgname->relpersistence == RELPERSISTENCE_PERMANENT
        && components_persistence == RELPERSISTENCE_TEMP)
    {
        cstmt->relation = copyObject(cstmt->relation);
        cstmt->relation->relpersistence = RELPERSISTENCE_TEMP;
        ereport(NOTICE,
                (errmsg("property graph \"%s\" will be temporary",
                        stmt->pgname->relname)));
    }
 
    pgaddress = DefineRelation(cstmt, RELKIND_PROPGRAPH, InvalidOid, NULL, NULL);
 
    foreach(lc, vertex_infos)
    {
        struct element_info *vinfo = lfirst(lc);
        Oid         peoid;
 
        peoid = insert_element_record(pgaddress, vinfo);
        element_oids = lappend_oid(element_oids, peoid);
    }
 
    foreach(lc, edge_infos)
    {
        struct element_info *einfo = lfirst(lc);
        Oid         peoid;
        ListCell   *lc2;
 
        /*
         * Look up the vertices again.  Now the vertices have OIDs assigned,
         * which we need.
         */
        foreach(lc2, vertex_infos)
        {
            struct element_info *vinfo = lfirst(lc2);
 
            if (strcmp(vinfo->aliasname, einfo->srcvertex) == 0)
            {
                einfo->srcvertexid = vinfo->elementid;
                einfo->srcrelid = vinfo->relid;
            }
            if (strcmp(vinfo->aliasname, einfo->destvertex) == 0)
            {
                einfo->destvertexid = vinfo->elementid;
                einfo->destrelid = vinfo->relid;
            }
            if (einfo->srcvertexid && einfo->destvertexid)
                break;
        }
        Assert(einfo->srcvertexid);
        Assert(einfo->destvertexid);
        Assert(einfo->srcrelid);
        Assert(einfo->destrelid);
        peoid = insert_element_record(pgaddress, einfo);
        element_oids = lappend_oid(element_oids, peoid);
    }
 
    CommandCounterIncrement();
 
    foreach_oid(peoid, element_oids)
        check_element_properties(peoid);
    check_all_labels_properties(pgaddress.objectId);
 
    return pgaddress;
}

References AccessShareLock, Assert, check_all_labels_properties(), check_element_properties(), CommandCounterIncrement(), copyObject, DefineRelation(), element_info::destrelid, ereport, errcode(), errmsg, ERROR, fb(), foreach_oid, insert_element_record(), InvalidOid, lappend(), lappend_oid(), lfirst, lfirst_node, list_member(), makeNode, makeString(), NIL, NoLock, NOTICE, ONCOMMIT_NOOP, palloc0_object, parser_errposition(), propgraph_edge_get_ref_keys(), propgraph_element_get_key(), RangeVarCallbackOwnsRelation(), RangeVarGetRelidExtended(), RelationData::rd_rel, element_info::srcrelid, stmt, table_close(), and table_open().

Referenced by ProcessUtilitySlow().