PostgreSQL Source Code git master
Loading...
Searching...
No Matches
Functions
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.

1292{
1293 Oid pgrelid;
1294 ListCell *lc;
1295 ObjectAddress pgaddress;
1296
1297 pgrelid = RangeVarGetRelidExtended(stmt->pgname,
1298 ShareRowExclusiveLock,
1299 stmt->missing_ok ? RVR_MISSING_OK : 0,
1300 RangeVarCallbackOwnsRelation,
1301 NULL);
1302 if (pgrelid == InvalidOid)
1303 {
1304 ereport(NOTICE,
1305 (errmsg("relation \"%s\" does not exist, skipping",
1306 stmt->pgname->relname)));
1307 return InvalidObjectAddress;
1308 }
1309
1310 ObjectAddressSet(pgaddress, RelationRelationId, pgrelid);
1311
1312 foreach(lc, stmt->add_vertex_tables)
1313 {
1314 PropGraphVertex *vertex = lfirst_node(PropGraphVertex, lc);
1315 struct element_info *vinfo;
1316 Relation rel;
1317 Oid peoid;
1318
1319 vinfo = palloc0_object(struct element_info);
1320 vinfo->kind = PGEKIND_VERTEX;
1321
1322 vinfo->relid = RangeVarGetRelidExtended(vertex->vtable, AccessShareLock, 0, RangeVarCallbackOwnsRelation, NULL);
1323
1324 rel = table_open(vinfo->relid, NoLock);
1325
1326 if (rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP && get_rel_persistence(pgrelid) != RELPERSISTENCE_TEMP)
1327 ereport(ERROR,
1328 (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1329 errmsg("cannot add temporary element table to non-temporary property graph"),
1330 errdetail("Table \"%s\" is a temporary table.", get_rel_name(vinfo->relid)),
1331 parser_errposition(pstate, vertex->vtable->location)));
1332
1333 if (vertex->vtable->alias)
1334 vinfo->aliasname = vertex->vtable->alias->aliasname;
1335 else
1336 vinfo->aliasname = vertex->vtable->relname;
1337
1338 vinfo->key = propgraph_element_get_key(pstate, vertex->vkey, rel, vinfo->aliasname, vertex->location);
1339
1340 vinfo->labels = vertex->labels;
1341
1342 table_close(rel, NoLock);
1343
1344 if (SearchSysCacheExists2(PROPGRAPHELALIAS,
1345 ObjectIdGetDatum(pgrelid),
1346 CStringGetDatum(vinfo->aliasname)))
1347 ereport(ERROR,
1348 errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1349 errmsg("alias \"%s\" already exists in property graph \"%s\"",
1350 vinfo->aliasname, stmt->pgname->relname),
1351 parser_errposition(pstate, vertex->vtable->location));
1352
1353 peoid = insert_element_record(pgaddress, vinfo);
1354
1355 CommandCounterIncrement();
1356 check_element_properties(peoid);
1357 check_all_labels_properties(pgrelid);
1358 }
1359
1360 foreach(lc, stmt->add_edge_tables)
1361 {
1362 PropGraphEdge *edge = lfirst_node(PropGraphEdge, lc);
1363 struct element_info *einfo;
1364 Relation rel;
1365 Relation srcrel;
1366 Relation destrel;
1367 Oid peoid;
1368
1369 einfo = palloc0_object(struct element_info);
1370 einfo->kind = PGEKIND_EDGE;
1371
1372 einfo->relid = RangeVarGetRelidExtended(edge->etable, AccessShareLock, 0, RangeVarCallbackOwnsRelation, NULL);
1373
1374 rel = table_open(einfo->relid, NoLock);
1375
1376 if (rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP && get_rel_persistence(pgrelid) != RELPERSISTENCE_TEMP)
1377 ereport(ERROR,
1378 (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1379 errmsg("cannot add temporary element table to non-temporary property graph"),
1380 errdetail("Table \"%s\" is a temporary table.", get_rel_name(einfo->relid)),
1381 parser_errposition(pstate, edge->etable->location)));
1382
1383 if (edge->etable->alias)
1384 einfo->aliasname = edge->etable->alias->aliasname;
1385 else
1386 einfo->aliasname = edge->etable->relname;
1387
1388 einfo->key = propgraph_element_get_key(pstate, edge->ekey, rel, einfo->aliasname, edge->location);
1389
1390 einfo->srcvertexid = get_vertex_oid(pstate, pgrelid, edge->esrcvertex, edge->location);
1391 einfo->destvertexid = get_vertex_oid(pstate, pgrelid, edge->edestvertex, edge->location);
1392
1393 einfo->srcrelid = get_element_relid(einfo->srcvertexid);
1394 einfo->destrelid = get_element_relid(einfo->destvertexid);
1395
1396 srcrel = table_open(einfo->srcrelid, AccessShareLock);
1397 destrel = table_open(einfo->destrelid, AccessShareLock);
1398
1399 propgraph_edge_get_ref_keys(pstate, edge->esrckey, edge->esrcvertexcols, rel, srcrel,
1400 einfo->aliasname, edge->location, "SOURCE",
1401 &einfo->srckey, &einfo->srcref, &einfo->srceqop);
1402 propgraph_edge_get_ref_keys(pstate, edge->edestkey, edge->edestvertexcols, rel, destrel,
1403 einfo->aliasname, edge->location, "DESTINATION",
1404 &einfo->destkey, &einfo->destref, &einfo->desteqop);
1405
1406 einfo->labels = edge->labels;
1407
1408 table_close(destrel, NoLock);
1409 table_close(srcrel, NoLock);
1410
1411 table_close(rel, NoLock);
1412
1413 if (SearchSysCacheExists2(PROPGRAPHELALIAS,
1414 ObjectIdGetDatum(pgrelid),
1415 CStringGetDatum(einfo->aliasname)))
1416 ereport(ERROR,
1417 errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
1418 errmsg("alias \"%s\" already exists in property graph \"%s\"",
1419 einfo->aliasname, stmt->pgname->relname),
1420 parser_errposition(pstate, edge->etable->location));
1421
1422 peoid = insert_element_record(pgaddress, einfo);
1423
1424 CommandCounterIncrement();
1425 check_element_properties(peoid);
1426 check_all_labels_properties(pgrelid);
1427 }
1428
1429 foreach(lc, stmt->drop_vertex_tables)
1430 {
1431 char *alias = strVal(lfirst(lc));
1432 Oid peoid;
1433 ObjectAddress obj;
1434
1435 peoid = get_vertex_oid(pstate, pgrelid, alias, -1);
1436 ObjectAddressSet(obj, PropgraphElementRelationId, peoid);
1437 performDeletion(&obj, stmt->drop_behavior, 0);
1438 }
1439
1440 foreach(lc, stmt->drop_edge_tables)
1441 {
1442 char *alias = strVal(lfirst(lc));
1443 Oid peoid;
1444 ObjectAddress obj;
1445
1446 peoid = get_edge_oid(pstate, pgrelid, alias, -1);
1447 ObjectAddressSet(obj, PropgraphElementRelationId, peoid);
1448 performDeletion(&obj, stmt->drop_behavior, 0);
1449 }
1450
1451 /* Remove any orphaned pg_propgraph_label entries */
1452 if (stmt->drop_vertex_tables || stmt->drop_edge_tables)
1453 {
1454 foreach_oid(labeloid, get_graph_label_ids(pgrelid))
1455 {
1456 if (!get_label_element_label_ids(labeloid))
1457 {
1458 ObjectAddress obj;
1459
1460 ObjectAddressSet(obj, PropgraphLabelRelationId, labeloid);
1461 performDeletion(&obj, stmt->drop_behavior, 0);
1462 }
1463 }
1464 }
1465
1466 foreach(lc, stmt->add_labels)
1467 {
1468 PropGraphLabelAndProperties *lp = lfirst_node(PropGraphLabelAndProperties, lc);
1469 Oid peoid;
1470 Oid pgerelid;
1471 Oid ellabeloid;
1472
1473 Assert(lp->label);
1474
1475 if (stmt->element_kind == PROPGRAPH_ELEMENT_KIND_VERTEX)
1476 peoid = get_vertex_oid(pstate, pgrelid, stmt->element_alias, -1);
1477 else
1478 peoid = get_edge_oid(pstate, pgrelid, stmt->element_alias, -1);
1479
1480 pgerelid = get_element_relid(peoid);
1481
1482 ellabeloid = insert_label_record(pgrelid, peoid, lp->label);
1483 insert_property_records(pgrelid, ellabeloid, pgerelid, lp->properties);
1484
1485 CommandCounterIncrement();
1486 check_element_properties(peoid);
1487 check_element_label_properties(ellabeloid);
1488 }
1489
1490 if (stmt->drop_label)
1491 {
1492 Oid peoid;
1493 Oid labeloid;
1494 Oid ellabeloid;
1495 ObjectAddress obj;
1496
1497 if (stmt->element_kind == PROPGRAPH_ELEMENT_KIND_VERTEX)
1498 peoid = get_vertex_oid(pstate, pgrelid, stmt->element_alias, -1);
1499 else
1500 peoid = get_edge_oid(pstate, pgrelid, stmt->element_alias, -1);
1501
1502 labeloid = GetSysCacheOid2(PROPGRAPHLABELNAME,
1503 Anum_pg_propgraph_label_oid,
1504 ObjectIdGetDatum(pgrelid),
1505 CStringGetDatum(stmt->drop_label));
1506 if (!labeloid)
1507 ereport(ERROR,
1508 errcode(ERRCODE_UNDEFINED_OBJECT),
1509 errmsg("property graph \"%s\" element \"%s\" has no label \"%s\"",
1510 get_rel_name(pgrelid), stmt->element_alias, stmt->drop_label),
1511 parser_errposition(pstate, -1));
1512
1513 ellabeloid = GetSysCacheOid2(PROPGRAPHELEMENTLABELELEMENTLABEL,
1514 Anum_pg_propgraph_element_label_oid,
1515 ObjectIdGetDatum(peoid),
1516 ObjectIdGetDatum(labeloid));
1517
1518 if (!ellabeloid)
1519 ereport(ERROR,
1520 errcode(ERRCODE_UNDEFINED_OBJECT),
1521 errmsg("property graph \"%s\" element \"%s\" has no label \"%s\"",
1522 get_rel_name(pgrelid), stmt->element_alias, stmt->drop_label),
1523 parser_errposition(pstate, -1));
1524
1525 ObjectAddressSet(obj, PropgraphElementLabelRelationId, ellabeloid);
1526 performDeletion(&obj, stmt->drop_behavior, 0);
1527
1528 /* Remove any orphaned pg_propgraph_label entries */
1529 if (!get_label_element_label_ids(labeloid))
1530 {
1531 ObjectAddressSet(obj, PropgraphLabelRelationId, labeloid);
1532 performDeletion(&obj, stmt->drop_behavior, 0);
1533 }
1534 }
1535
1536 if (stmt->add_properties)
1537 {
1538 Oid peoid;
1539 Oid pgerelid;
1540 Oid labeloid;
1541 Oid ellabeloid;
1542
1543 if (stmt->element_kind == PROPGRAPH_ELEMENT_KIND_VERTEX)
1544 peoid = get_vertex_oid(pstate, pgrelid, stmt->element_alias, -1);
1545 else
1546 peoid = get_edge_oid(pstate, pgrelid, stmt->element_alias, -1);
1547
1548 labeloid = GetSysCacheOid2(PROPGRAPHLABELNAME,
1549 Anum_pg_propgraph_label_oid,
1550 ObjectIdGetDatum(pgrelid),
1551 CStringGetDatum(stmt->alter_label));
1552 if (!labeloid)
1553 ereport(ERROR,
1554 errcode(ERRCODE_UNDEFINED_OBJECT),
1555 errmsg("property graph \"%s\" element \"%s\" has no label \"%s\"",
1556 get_rel_name(pgrelid), stmt->element_alias, stmt->alter_label),
1557 parser_errposition(pstate, -1));
1558
1559 ellabeloid = GetSysCacheOid2(PROPGRAPHELEMENTLABELELEMENTLABEL,
1560 Anum_pg_propgraph_element_label_oid,
1561 ObjectIdGetDatum(peoid),
1562 ObjectIdGetDatum(labeloid));
1563 if (!ellabeloid)
1564 ereport(ERROR,
1565 errcode(ERRCODE_UNDEFINED_OBJECT),
1566 errmsg("property graph \"%s\" element \"%s\" has no label \"%s\"",
1567 get_rel_name(pgrelid), stmt->element_alias, stmt->alter_label),
1568 parser_errposition(pstate, -1));
1569
1570 pgerelid = get_element_relid(peoid);
1571
1572 insert_property_records(pgrelid, ellabeloid, pgerelid, stmt->add_properties);
1573
1574 CommandCounterIncrement();
1575 check_element_properties(peoid);
1576 check_element_label_properties(ellabeloid);
1577 }
1578
1579 if (stmt->drop_properties)
1580 {
1581 Oid peoid;
1582 Oid labeloid;
1583 Oid ellabeloid;
1584 ObjectAddress obj;
1585
1586 if (stmt->element_kind == PROPGRAPH_ELEMENT_KIND_VERTEX)
1587 peoid = get_vertex_oid(pstate, pgrelid, stmt->element_alias, -1);
1588 else
1589 peoid = get_edge_oid(pstate, pgrelid, stmt->element_alias, -1);
1590
1591 labeloid = GetSysCacheOid2(PROPGRAPHLABELNAME,
1592 Anum_pg_propgraph_label_oid,
1593 ObjectIdGetDatum(pgrelid),
1594 CStringGetDatum(stmt->alter_label));
1595 if (!labeloid)
1596 ereport(ERROR,
1597 errcode(ERRCODE_UNDEFINED_OBJECT),
1598 errmsg("property graph \"%s\" element \"%s\" has no label \"%s\"",
1599 get_rel_name(pgrelid), stmt->element_alias, stmt->alter_label),
1600 parser_errposition(pstate, -1));
1601
1602 ellabeloid = GetSysCacheOid2(PROPGRAPHELEMENTLABELELEMENTLABEL,
1603 Anum_pg_propgraph_element_label_oid,
1604 ObjectIdGetDatum(peoid),
1605 ObjectIdGetDatum(labeloid));
1606
1607 if (!ellabeloid)
1608 ereport(ERROR,
1609 errcode(ERRCODE_UNDEFINED_OBJECT),
1610 errmsg("property graph \"%s\" element \"%s\" has no label \"%s\"",
1611 get_rel_name(pgrelid), stmt->element_alias, stmt->alter_label),
1612 parser_errposition(pstate, -1));
1613
1614 foreach(lc, stmt->drop_properties)
1615 {
1616 char *propname = strVal(lfirst(lc));
1617 Oid propoid;
1618 Oid plpoid;
1619
1620 propoid = GetSysCacheOid2(PROPGRAPHPROPNAME,
1621 Anum_pg_propgraph_property_oid,
1622 ObjectIdGetDatum(pgrelid),
1623 CStringGetDatum(propname));
1624 if (!propoid)
1625 ereport(ERROR,
1626 errcode(ERRCODE_UNDEFINED_OBJECT),
1627 errmsg("property graph \"%s\" element \"%s\" label \"%s\" has no property \"%s\"",
1628 get_rel_name(pgrelid), stmt->element_alias, stmt->alter_label, propname),
1629 parser_errposition(pstate, -1));
1630
1631 plpoid = GetSysCacheOid2(PROPGRAPHLABELPROP, Anum_pg_propgraph_label_property_oid, ObjectIdGetDatum(ellabeloid), ObjectIdGetDatum(propoid));
1632
1633 ObjectAddressSet(obj, PropgraphLabelPropertyRelationId, plpoid);
1634 performDeletion(&obj, stmt->drop_behavior, 0);
1635 }
1636
1637 check_element_label_properties(ellabeloid);
1638 }
1639
1640 /* Remove any orphaned pg_propgraph_property entries */
1641 if (stmt->drop_properties || stmt->drop_vertex_tables || stmt->drop_edge_tables)
1642 {
1643 foreach_oid(propoid, get_graph_property_ids(pgrelid))
1644 {
1645 Relation rel;
1646 SysScanDesc scan;
1647 ScanKeyData key[1];
1648
1649 rel = table_open(PropgraphLabelPropertyRelationId, RowShareLock);
1650 ScanKeyInit(&key[0],
1651 Anum_pg_propgraph_label_property_plppropid,
1652 BTEqualStrategyNumber, F_OIDEQ,
1653 ObjectIdGetDatum(propoid));
1654 /* XXX no suitable index */
1655 scan = systable_beginscan(rel, InvalidOid, true, NULL, 1, key);
1656 if (!systable_getnext(scan))
1657 {
1658 ObjectAddress obj;
1659
1660 ObjectAddressSet(obj, PropgraphPropertyRelationId, propoid);
1661 performDeletion(&obj, stmt->drop_behavior, 0);
1662 }
1663
1664 systable_endscan(scan);
1665 table_close(rel, RowShareLock);
1666 }
1667 }
1668
1669 /*
1670 * Invalidate relcache entry of the property graph so that the queries in
1671 * the cached plans referencing the property graph will be rewritten
1672 * considering changes to the propert graph.
1673 */
1674 CacheInvalidateRelcacheByRelid(pgrelid);
1675
1676 return pgaddress;
1677}
Assert
#define Assert(condition)
Definition c.h:942
performDeletion
void performDeletion(const ObjectAddress *object, DropBehavior behavior, int flags)
Definition dependency.c:279
errcode
int errcode(int sqlerrcode)
Definition elog.c:874
errdetail
int errdetail(const char *fmt,...) pg_attribute_printf(1
ERROR
#define ERROR
Definition elog.h:39
NOTICE
#define NOTICE
Definition elog.h:35
ereport
#define ereport(elevel,...)
Definition elog.h:150
palloc0_object
#define palloc0_object(type)
Definition fe_memutils.h:75
systable_endscan
void systable_endscan(SysScanDesc sysscan)
Definition genam.c:603
systable_getnext
HeapTuple systable_getnext(SysScanDesc sysscan)
Definition genam.c:514
systable_beginscan
SysScanDesc systable_beginscan(Relation heapRelation, Oid indexId, bool indexOK, Snapshot snapshot, int nkeys, ScanKey key)
Definition genam.c:388
stmt
#define stmt
Definition indent_codes.h:59
CacheInvalidateRelcacheByRelid
void CacheInvalidateRelcacheByRelid(Oid relid)
Definition inval.c:1691
NoLock
#define NoLock
Definition lockdefs.h:34
ShareRowExclusiveLock
#define ShareRowExclusiveLock
Definition lockdefs.h:41
AccessShareLock
#define AccessShareLock
Definition lockdefs.h:36
RowShareLock
#define RowShareLock
Definition lockdefs.h:37
get_rel_name
char * get_rel_name(Oid relid)
Definition lsyscache.c:2148
get_rel_persistence
char get_rel_persistence(Oid relid)
Definition lsyscache.c:2298
RangeVarGetRelidExtended
Oid RangeVarGetRelidExtended(const RangeVar *relation, LOCKMODE lockmode, uint32 flags, RangeVarGetRelidCallback callback, void *callback_arg)
Definition namespace.c:442
RVR_MISSING_OK
@ RVR_MISSING_OK
Definition namespace.h:90
errmsg
static char * errmsg
Definition oauth_hook_client.c:61
InvalidObjectAddress
const ObjectAddress InvalidObjectAddress
Definition objectaddress.c:924
ObjectAddressSet
#define ObjectAddressSet(addr, class_id, object_id)
Definition objectaddress.h:41
parser_errposition
int parser_errposition(ParseState *pstate, int location)
Definition parse_node.c:106
PROPGRAPH_ELEMENT_KIND_VERTEX
@ PROPGRAPH_ELEMENT_KIND_VERTEX
Definition parsenodes.h:4305
lfirst
#define lfirst(lc)
Definition pg_list.h:172
lfirst_node
#define lfirst_node(type, lc)
Definition pg_list.h:176
foreach_oid
#define foreach_oid(var, lst)
Definition pg_list.h:471
ObjectIdGetDatum
static Datum ObjectIdGetDatum(Oid X)
Definition postgres.h:252
CStringGetDatum
static Datum CStringGetDatum(const char *X)
Definition postgres.h:370
InvalidOid
#define InvalidOid
Definition postgres_ext.h:37
Oid
unsigned int Oid
Definition postgres_ext.h:32
fb
static int fb(int x)
Definition preproc-init.c:92
check_all_labels_properties
static void check_all_labels_properties(Oid pgrelid)
Definition propgraphcmds.c:1276
get_edge_oid
static Oid get_edge_oid(ParseState *pstate, Oid pgrelid, const char *alias, int location)
Definition propgraphcmds.c:1716
propgraph_element_get_key
static ArrayType * propgraph_element_get_key(ParseState *pstate, const List *keycols, Relation element_rel, const char *aliasname, int location)
Definition propgraphcmds.c:325
get_element_relid
static Oid get_element_relid(Oid peid)
Definition propgraphcmds.c:1747
get_vertex_oid
static Oid get_vertex_oid(ParseState *pstate, Oid pgrelid, const char *alias, int location)
Definition propgraphcmds.c:1684
insert_property_records
static void insert_property_records(Oid graphid, Oid ellabeloid, Oid pgerelid, const PropGraphProperties *properties)
Definition propgraphcmds.c:823
insert_label_record
static Oid insert_label_record(Oid graphid, Oid peoid, const char *label)
Definition propgraphcmds.c:745
check_element_label_properties
static void check_element_label_properties(Oid ellabeloid)
Definition propgraphcmds.c:1182
get_graph_label_ids
static List * get_graph_label_ids(Oid graphid)
Definition propgraphcmds.c:1767
insert_element_record
static Oid insert_element_record(ObjectAddress pgaddress, struct element_info *einfo)
Definition propgraphcmds.c:612
get_label_element_label_ids
static List * get_label_element_label_ids(Oid labelid)
Definition propgraphcmds.c:1795
get_graph_property_ids
static List * get_graph_property_ids(Oid graphid)
Definition propgraphcmds.c:1860
check_element_properties
static void check_element_properties(Oid peoid)
Definition propgraphcmds.c:1051
propgraph_edge_get_ref_keys
static void propgraph_edge_get_ref_keys(ParseState *pstate, const List *keycols, const List *refcols, Relation edge_rel, Relation ref_rel, const char *aliasname, int location, const char *type, ArrayType **outkey, ArrayType **outref, ArrayType **outeqop)
Definition propgraphcmds.c:371
ScanKeyInit
void ScanKeyInit(ScanKey entry, AttrNumber attributeNumber, StrategyNumber strategy, RegProcedure procedure, Datum argument)
Definition scankey.c:76
BTEqualStrategyNumber
#define BTEqualStrategyNumber
Definition stratnum.h:31
RelationData::rd_rel
Form_pg_class rd_rel
Definition rel.h:111
element_info
Definition propgraphcmds.c:51
element_info::key
ArrayType * key
Definition propgraphcmds.c:56
SearchSysCacheExists2
#define SearchSysCacheExists2(cacheId, key1, key2)
Definition syscache.h:102
GetSysCacheOid2
#define GetSysCacheOid2(cacheId, oidcol, key1, key2)
Definition syscache.h:111
table_close
void table_close(Relation relation, LOCKMODE lockmode)
Definition table.c:126
table_open
Relation table_open(Oid relationId, LOCKMODE lockmode)
Definition table.c:40
RangeVarCallbackOwnsRelation
void RangeVarCallbackOwnsRelation(const RangeVar *relation, Oid relId, Oid oldRelId, void *arg)
Definition tablecmds.c:19795
strVal
#define strVal(v)
Definition value.h:82
CommandCounterIncrement
void CommandCounterIncrement(void)
Definition xact.c:1102

References AccessShareLock, Assert, BTEqualStrategyNumber, CacheInvalidateRelcacheByRelid(), check_all_labels_properties(), check_element_label_properties(), check_element_properties(), CommandCounterIncrement(), CStringGetDatum(), ereport, errcode(), errdetail(), errmsg, ERROR, fb(), foreach_oid, 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(), GetSysCacheOid2, 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.

105{
106 CreateStmt *cstmt = makeNode(CreateStmt);
107 char components_persistence;
108 ListCell *lc;
109 ObjectAddress pgaddress;
110 List *vertex_infos = NIL;
111 List *edge_infos = NIL;
112 List *element_aliases = NIL;
113 List *element_oids = NIL;
114
115 if (stmt->pgname->relpersistence == RELPERSISTENCE_UNLOGGED)
116 ereport(ERROR,
117 (errcode(ERRCODE_SYNTAX_ERROR),
118 errmsg("property graphs cannot be unlogged because they do not have storage")));
119
120 components_persistence = RELPERSISTENCE_PERMANENT;
121
122 foreach(lc, stmt->vertex_tables)
123 {
124 PropGraphVertex *vertex = lfirst_node(PropGraphVertex, lc);
125 struct element_info *vinfo;
126 Relation rel;
127
128 vinfo = palloc0_object(struct element_info);
129 vinfo->kind = PGEKIND_VERTEX;
130
131 vinfo->relid = RangeVarGetRelidExtended(vertex->vtable, AccessShareLock, 0, RangeVarCallbackOwnsRelation, NULL);
132
133 rel = table_open(vinfo->relid, NoLock);
134
135 if (rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP)
136 components_persistence = RELPERSISTENCE_TEMP;
137
138 if (vertex->vtable->alias)
139 vinfo->aliasname = vertex->vtable->alias->aliasname;
140 else
141 vinfo->aliasname = vertex->vtable->relname;
142
143 if (list_member(element_aliases, makeString(vinfo->aliasname)))
144 ereport(ERROR,
145 (errcode(ERRCODE_DUPLICATE_TABLE),
146 errmsg("alias \"%s\" used more than once as element table", vinfo->aliasname),
147 parser_errposition(pstate, vertex->location)));
148
149 vinfo->key = propgraph_element_get_key(pstate, vertex->vkey, rel, vinfo->aliasname, vertex->location);
150
151 vinfo->labels = vertex->labels;
152
153 table_close(rel, NoLock);
154
155 vertex_infos = lappend(vertex_infos, vinfo);
156
157 element_aliases = lappend(element_aliases, makeString(vinfo->aliasname));
158 }
159
160 foreach(lc, stmt->edge_tables)
161 {
162 PropGraphEdge *edge = lfirst_node(PropGraphEdge, lc);
163 struct element_info *einfo;
164 Relation rel;
165 ListCell *lc2;
166 Oid srcrelid;
167 Oid destrelid;
168 Relation srcrel;
169 Relation destrel;
170
171 einfo = palloc0_object(struct element_info);
172 einfo->kind = PGEKIND_EDGE;
173
174 einfo->relid = RangeVarGetRelidExtended(edge->etable, AccessShareLock, 0, RangeVarCallbackOwnsRelation, NULL);
175
176 rel = table_open(einfo->relid, NoLock);
177
178 if (rel->rd_rel->relpersistence == RELPERSISTENCE_TEMP)
179 components_persistence = RELPERSISTENCE_TEMP;
180
181 if (edge->etable->alias)
182 einfo->aliasname = edge->etable->alias->aliasname;
183 else
184 einfo->aliasname = edge->etable->relname;
185
186 if (list_member(element_aliases, makeString(einfo->aliasname)))
187 ereport(ERROR,
188 (errcode(ERRCODE_DUPLICATE_TABLE),
189 errmsg("alias \"%s\" used more than once as element table", einfo->aliasname),
190 parser_errposition(pstate, edge->location)));
191
192 einfo->key = propgraph_element_get_key(pstate, edge->ekey, rel, einfo->aliasname, edge->location);
193
194 einfo->srcvertex = edge->esrcvertex;
195 einfo->destvertex = edge->edestvertex;
196
197 srcrelid = 0;
198 destrelid = 0;
199 foreach(lc2, vertex_infos)
200 {
201 struct element_info *vinfo = lfirst(lc2);
202
203 if (strcmp(vinfo->aliasname, edge->esrcvertex) == 0)
204 srcrelid = vinfo->relid;
205
206 if (strcmp(vinfo->aliasname, edge->edestvertex) == 0)
207 destrelid = vinfo->relid;
208
209 if (srcrelid && destrelid)
210 break;
211 }
212 if (!srcrelid)
213 ereport(ERROR,
214 (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
215 errmsg("source vertex \"%s\" of edge \"%s\" does not exist",
216 edge->esrcvertex, einfo->aliasname),
217 parser_errposition(pstate, edge->location)));
218 if (!destrelid)
219 ereport(ERROR,
220 (errcode(ERRCODE_INVALID_OBJECT_DEFINITION),
221 errmsg("destination vertex \"%s\" of edge \"%s\" does not exist",
222 edge->edestvertex, einfo->aliasname),
223 parser_errposition(pstate, edge->location)));
224
225 srcrel = table_open(srcrelid, NoLock);
226 destrel = table_open(destrelid, NoLock);
227
228 propgraph_edge_get_ref_keys(pstate, edge->esrckey, edge->esrcvertexcols, rel, srcrel,
229 einfo->aliasname, edge->location, "SOURCE",
230 &einfo->srckey, &einfo->srcref, &einfo->srceqop);
231 propgraph_edge_get_ref_keys(pstate, edge->edestkey, edge->edestvertexcols, rel, destrel,
232 einfo->aliasname, edge->location, "DESTINATION",
233 &einfo->destkey, &einfo->destref, &einfo->desteqop);
234
235 einfo->labels = edge->labels;
236
237 table_close(destrel, NoLock);
238 table_close(srcrel, NoLock);
239
240 table_close(rel, NoLock);
241
242 edge_infos = lappend(edge_infos, einfo);
243
244 element_aliases = lappend(element_aliases, makeString(einfo->aliasname));
245 }
246
247 cstmt->relation = stmt->pgname;
248 cstmt->oncommit = ONCOMMIT_NOOP;
249
250 /*
251 * Automatically make it temporary if any component tables are temporary
252 * (see also DefineView()).
253 */
254 if (stmt->pgname->relpersistence == RELPERSISTENCE_PERMANENT
255 && components_persistence == RELPERSISTENCE_TEMP)
256 {
257 cstmt->relation = copyObject(cstmt->relation);
258 cstmt->relation->relpersistence = RELPERSISTENCE_TEMP;
259 ereport(NOTICE,
260 (errmsg("property graph \"%s\" will be temporary",
261 stmt->pgname->relname)));
262 }
263
264 pgaddress = DefineRelation(cstmt, RELKIND_PROPGRAPH, InvalidOid, NULL, NULL);
265
266 foreach(lc, vertex_infos)
267 {
268 struct element_info *vinfo = lfirst(lc);
269 Oid peoid;
270
271 peoid = insert_element_record(pgaddress, vinfo);
272 element_oids = lappend_oid(element_oids, peoid);
273 }
274
275 foreach(lc, edge_infos)
276 {
277 struct element_info *einfo = lfirst(lc);
278 Oid peoid;
279 ListCell *lc2;
280
281 /*
282 * Look up the vertices again. Now the vertices have OIDs assigned,
283 * which we need.
284 */
285 foreach(lc2, vertex_infos)
286 {
287 struct element_info *vinfo = lfirst(lc2);
288
289 if (strcmp(vinfo->aliasname, einfo->srcvertex) == 0)
290 {
291 einfo->srcvertexid = vinfo->elementid;
292 einfo->srcrelid = vinfo->relid;
293 }
294 if (strcmp(vinfo->aliasname, einfo->destvertex) == 0)
295 {
296 einfo->destvertexid = vinfo->elementid;
297 einfo->destrelid = vinfo->relid;
298 }
299 if (einfo->srcvertexid && einfo->destvertexid)
300 break;
301 }
302 Assert(einfo->srcvertexid);
303 Assert(einfo->destvertexid);
304 Assert(einfo->srcrelid);
305 Assert(einfo->destrelid);
306 peoid = insert_element_record(pgaddress, einfo);
307 element_oids = lappend_oid(element_oids, peoid);
308 }
309
310 CommandCounterIncrement();
311
312 foreach_oid(peoid, element_oids)
313 check_element_properties(peoid);
314 check_all_labels_properties(pgaddress.objectId);
315
316 return pgaddress;
317}
lappend
List * lappend(List *list, void *datum)
Definition list.c:339
lappend_oid
List * lappend_oid(List *list, Oid datum)
Definition list.c:375
list_member
bool list_member(const List *list, const void *datum)
Definition list.c:661
copyObject
#define copyObject(obj)
Definition nodes.h:232
makeNode
#define makeNode(_type_)
Definition nodes.h:161
NIL
#define NIL
Definition pg_list.h:68
ONCOMMIT_NOOP
@ ONCOMMIT_NOOP
Definition primnodes.h:59
List
Definition pg_list.h:54
element_info::srcrelid
Oid srcrelid
Definition propgraphcmds.c:60
element_info::destrelid
Oid destrelid
Definition propgraphcmds.c:67
DefineRelation
ObjectAddress DefineRelation(CreateStmt *stmt, char relkind, Oid ownerId, ObjectAddress *typaddress, const char *queryString)
Definition tablecmds.c:784
makeString
String * makeString(char *str)
Definition value.c:63

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().