perf: mint quad ids using term ids

Author: jeswr

src/N3Store.js

@@ -1,5 +1,6 @@
 // **N3Store** objects store N3 quads by graph in memory.
 import { default as N3DataFactory, termToId, termFromId } from './N3DataFactory';
+import { isDefaultGraph } from './N3Util';
 import { Readable } from 'readable-stream';
 import namespaces from './IRIs';
 
@@ -30,6 +31,42 @@ export default class N3Store {
       this.addQuads(quads);
   }
 
+  _termFromId(id, factory) {
+    if (id[0] === '_') {
+      const entities = this._entities;
+      const terms = id.split('_');
+      const q = this._factory.quad(
+        this._termFromId(entities[terms[1]]),
+        this._termFromId(entities[terms[2]]),
+        this._termFromId(entities[terms[3]]),
+        terms[4] && this._termFromId(entities[terms[4]]),
+      )
+      return q;
+    }
+    return termFromId(id, factory);
+  }
+
+  _termToId(term) {
+    if (term.termType === 'Quad') {
+      const subject = this._termToId(term.subject),
+        predicate = this._termToId(term.predicate),
+        object = this._termToId(term.object),
+        graph = isDefaultGraph(term.graph) && this._termToId(term.graph),
+        ids = this._ids,
+        entities = this._entities;
+
+      const res = `_${
+        ids[subject] || (ids[entities[++this._id] = subject]  = this._id)
+      }_${
+        ids[predicate] || (ids[entities[++this._id] = predicate]  = this._id)
+      }_${
+        ids[object] || (ids[entities[++this._id] = object]  = this._id)
+      }${graph ? ('_' + (ids[graph] || (ids[entities[++this._id] = graph]  = this._id))) : ''}`;
+      return res;
+    }
+    return termToId(term);
+  }
+
   // ## Public properties
 
   // ### `size` returns the number of quads in the store
@@ -88,24 +125,24 @@ export default class N3Store {
   *_findInIndex(index0, key0, key1, key2, name0, name1, name2, graphId) {
     let tmp, index1, index2;
     const entityKeys = this._entities;
-    const graph = termFromId(graphId, this._factory);
+    const graph = this._termFromId(graphId, this._factory);
     const parts = { subject: null, predicate: null, object: null };
 
     // If a key is specified, use only that part of index 0.
     if (key0) (tmp = index0, index0 = {})[key0] = tmp[key0];
     for (const value0 in index0) {
       if (index1 = index0[value0]) {
-        parts[name0] = termFromId(entityKeys[value0], this._factory);
+        parts[name0] = this._termFromId(entityKeys[value0], this._factory);
         // If a key is specified, use only that part of index 1.
         if (key1) (tmp = index1, index1 = {})[key1] = tmp[key1];
         for (const value1 in index1) {
           if (index2 = index1[value1]) {
-            parts[name1] = termFromId(entityKeys[value1], this._factory);
+            parts[name1] = this._termFromId(entityKeys[value1], this._factory);
             // If a key is specified, use only that part of index 2, if it exists.
             const values = key2 ? (key2 in index2 ? [key2] : []) : Object.keys(index2);
             // Create quads for all items found in index 2.
             for (let l = 0; l < values.length; l++) {
-              parts[name2] = termFromId(entityKeys[values[l]], this._factory);
+              parts[name2] = this._termFromId(entityKeys[values[l]], this._factory);
               yield this._factory.quad(parts.subject, parts.predicate, parts.object, graph);
             }
           }
@@ -190,7 +227,7 @@ export default class N3Store {
     return id => {
       if (!(id in uniqueIds)) {
         uniqueIds[id] = true;
-        callback(termFromId(this._entities[id], this._factory));
+        callback(this._termFromId(this._entities[id], this._factory));
       }
     };
   }
@@ -214,10 +251,10 @@ export default class N3Store {
         predicate = subject.predicate, subject = subject.subject;
 
     // Convert terms to internal string representation
-    subject = termToId(subject);
-    predicate = termToId(predicate);
-    object = termToId(object);
-    graph = termToId(graph);
+    subject = this._termToId(subject);
+    predicate = this._termToId(predicate);
+    object = this._termToId(object);
+    graph = this._termToId(graph);
 
     // Find the graph that will contain the triple
     let graphItem = this._graphs[graph];
@@ -281,10 +318,10 @@ export default class N3Store {
         predicate = subject.predicate, subject = subject.subject;
 
     // Convert terms to internal string representation
-    subject = termToId(subject);
-    predicate = termToId(predicate);
-    object = termToId(object);
-    graph = termToId(graph);
+    subject = this._termToId(subject);
+    predicate = this._termToId(predicate);
+    object = this._termToId(object);
+    graph = this._termToId(graph);
 
     // Find internal identifiers for all components
     // and verify the quad exists.
@@ -350,10 +387,10 @@ export default class N3Store {
   // Setting any field to `undefined` or `null` indicates a wildcard.
   *readQuads(subject, predicate, object, graph) {
     // Convert terms to internal string representation
-    subject = subject && termToId(subject);
-    predicate = predicate && termToId(predicate);
-    object = object && termToId(object);
-    graph = graph && termToId(graph);
+    subject = subject && this._termToId(subject);
+    predicate = predicate && this._termToId(predicate);
+    object = object && this._termToId(object);
+    graph = graph && this._termToId(graph);
 
     const graphs = this._getGraphs(graph), ids = this._ids;
     let content, subjectId, predicateId, objectId;
@@ -408,10 +445,10 @@ export default class N3Store {
   // Setting any field to `undefined` or `null` indicates a wildcard.
   countQuads(subject, predicate, object, graph) {
     // Convert terms to internal string representation
-    subject = subject && termToId(subject);
-    predicate = predicate && termToId(predicate);
-    object = object && termToId(object);
-    graph = graph && termToId(graph);
+    subject = subject && this._termToId(subject);
+    predicate = predicate && this._termToId(predicate);
+    object = object && this._termToId(object);
+    graph = graph && this._termToId(graph);
 
     const graphs = this._getGraphs(graph), ids = this._ids;
     let count = 0, content, subjectId, predicateId, objectId;
@@ -490,9 +527,9 @@ export default class N3Store {
   // Setting any field to `undefined` or `null` indicates a wildcard.
   forSubjects(callback, predicate, object, graph) {
     // Convert terms to internal string representation
-    predicate = predicate && termToId(predicate);
-    object = object && termToId(object);
-    graph = graph && termToId(graph);
+    predicate = predicate && this._termToId(predicate);
+    object = object && this._termToId(object);
+    graph = graph && this._termToId(graph);
 
     const ids = this._ids, graphs = this._getGraphs(graph);
     let content, predicateId, objectId;
@@ -537,9 +574,9 @@ export default class N3Store {
   // Setting any field to `undefined` or `null` indicates a wildcard.
   forPredicates(callback, subject, object, graph) {
     // Convert terms to internal string representation
-    subject = subject && termToId(subject);
-    object = object && termToId(object);
-    graph = graph && termToId(graph);
+    subject = subject && this._termToId(subject);
+    object = object && this._termToId(object);
+    graph = graph && this._termToId(graph);
 
     const ids = this._ids, graphs = this._getGraphs(graph);
     let content, subjectId, objectId;
@@ -584,9 +621,9 @@ export default class N3Store {
   // Setting any field to `undefined` or `null` indicates a wildcard.
   forObjects(callback, subject, predicate, graph) {
     // Convert terms to internal string representation
-    subject = subject && termToId(subject);
-    predicate = predicate && termToId(predicate);
-    graph = graph && termToId(graph);
+    subject = subject && this._termToId(subject);
+    predicate = predicate && this._termToId(predicate);
+    graph = graph && this._termToId(graph);
 
     const ids = this._ids, graphs = this._getGraphs(graph);
     let content, subjectId, predicateId;