Native Graph Storage POC

And now the real work can begin! What has held this system back since
it was called AgensGraph is now over. Graph Native Storage is no
longer a dream.

Author: JoshInnis

src/backend/access/vertex_heap/vertex_heapam_handler.c

@@ -127,7 +127,7 @@ TableScanDesc vertex_scan_begin(Relation relation, Snapshot snapshot, int nkeys,
     vertex_desc->desc = palloc(sizeof (TableScanDesc *) * vertex_desc->ndesc);
     vertex_desc->isIndex = palloc(sizeof (bool) * vertex_desc->ndesc);
 
-    /*List *indexoidlist = RelationGetIndexList(relation);
+    List *indexoidlist = RelationGetIndexList(relation);
     if(list_length(indexoidlist) == 1) {
         Oid idx = linitial_oid(indexoidlist);
 
@@ -140,13 +140,13 @@ TableScanDesc vertex_scan_begin(Relation relation, Snapshot snapshot, int nkeys,
 
         vertex_desc->desc[0] = desc;
         vertex_desc->isIndex[0] = true;
-    } else {*/
+    } else {
 
         TableScanDesc *desc = tableam->scan_begin(rel, snapshot, nkeys, key, parallel_scan, flags);
 
         vertex_desc->desc[0] = desc;
         vertex_desc->isIndex[0] = false;
-    //}
+    }
 	return vertex_desc;
 }
 

src/backend/utils/edge_searching.c

@@ -88,13 +88,6 @@ static Datum get_vertex(Oid graph_oid, int64 graphid)
 PG_FUNCTION_INFO_V1(retrieve_vertex);
 Datum retrieve_vertex(PG_FUNCTION_ARGS) {
 
-	//PG_RETURN_POINTER(get_vertex(graph_oid, id));
-
- 	//gtype *graph_oid = GT_ARG_TO_INT4_DATUM(0);
-    //graphid id = AG_GETARG_GRAPHID(1);
-   
-    //lquery *label = PG_GETARG_LQUERY_P(1);
-    //bool include_props = PG_GETARG_BOOL(2);
 	FuncCallContext *funcctx;
 	if (SRF_IS_FIRSTCALL())
 	{
@@ -132,12 +125,6 @@ Datum retrieve_vertex(PG_FUNCTION_ARGS) {
 	}
 
 	SRF_RETURN_DONE(funcctx);
-	
-	
-	
-
-
-
 }
 
 
@@ -189,7 +176,7 @@ Datum edge_search(PG_FUNCTION_ARGS)
 
 		Snapshot snapshot = GetActiveSnapshot();
 
-		ScanKeyInit(cxt->scanKey, Anum_ag_label_edge_table_start_id, BTEqualStrategyNumber, F_GRAPHIDEQ, GRAPHID_GET_DATUM(id));
+		ScanKeyInit(cxt->scanKey, 1, HTEqualStrategyNumber, F_GRAPHIDEQ, GRAPHID_GET_DATUM(id));
 
 		cxt->rel = table_open(lcd->vertex_adjlist, ShareLock);
 		cxt->scan_desc = table_beginscan(cxt->rel, snapshot, 1, cxt->scanKey);