Class IndexedDBDataset

Number of quads waiting in the write buffer (not yet flushed)

Synchronous size is the number of buffered (unflushed) adds. Use getSize() for the total authoritative count.

Queue a quad for insertion. The quad is added to the write buffer and will be persisted on the next flush.

Close the database connection. Stop the auto-flush timer. Does NOT flush pending writes — call flush() first if needed.

Count quads matching the given pattern. Flushes first for accurate counts.

Queue a quad for deletion. The quad is added to the delete buffer and will be removed on the next flush.

Delete the entire IndexedDB database. Closes the connection first.

Flush all pending writes to IndexedDB. Awaiting this guarantees that all previously add()ed quads are persisted.

Get the total quad count in the persistent store (after flushing).

Synchronous has() — checks pending adds only. Not authoritative for quads already flushed to IndexedDB. Use matchAsync() for a reliable check.

Import quads from an iterable/async-iterable OR from an EventEmitter stream.

Two calling conventions are supported:

1. Iterable / AsyncIterable (e.g. array of quads, async generator): await dataset.import(quadsArray) → Promise
2. EventEmitter stream (Comunica SPARQL UPDATE INSERT path): dataset.import(quadStream) → EventEmitter (emits 'end' when done)

Comunica's RdfJsQuadDestination calls the EventEmitter form and awaits 'end' via event-emitter-promisify. Passing an array (no .on method) takes the async-iterable path and returns a plain Promise, which callers can await.

Returns a MatchResult that implements both DatasetCore and AsyncIterable. The async iteration path queries IndexedDB via IndexManager. This is the interface Comunica uses via its RDFJS source adapter.

Async generator that yields all matching quads from IndexedDB. Automatically flushes the write buffer first so results include all quads.

Remove quads supplied by an EventEmitter stream. Required by the RDFJS Store interface; called by Comunica for SPARQL UPDATE DELETE. Returns an EventEmitter that emits 'end' when all deletions are flushed.

Open (or create) the IndexedDB hexastore database.

The upgrade callback creates:

• "terms" store with autoincrement PK and unique "by_term" index
• "spo", "ops", "pso" key-only stores (keys are compound arrays)