-
Notifications
You must be signed in to change notification settings - Fork 1
features_cursor_pagination
Effiziente Pagination mit Cursors für große Ergebnismengen.
- 📋 Übersicht
- ✨ Features
- 🚀 Schnellstart
- 📖 Detaillierte Dokumentation
- 💡 Best Practices
- 🔧 Troubleshooting
- 📚 Siehe auch
- 📝 Changelog
Themis unterstützt Cursor-basierte Pagination für AQL-Queries. Dabei wird auf Index-Ebene ein effizienter Startpunkt gesetzt (Start-after/Start-before), statt große Offsets zu überspringen.
- ORDER BY über eine Range-indexierte Spalte aktiviert einen indexbasierten Scan in Sortierreihenfolge.
- Der Cursor enthält den Primary Key der zuletzt gelieferten Entity. Der Server lädt die Entity und extrahiert den Wert der Sortierspalte, um einen Anchor (value, pk) zu bilden.
- Asc (ASC): Start strictly after (value, pk) – Einträge mit demselben Sortwert und höherem PK kommen danach.
- Desc (DESC): Start strictly before (value, pk) – Einträge mit demselben Sortwert und niedrigerem PK kommen davor.
- Für die Erkennung von
has_morewirdLIMITintern alscount + 1an die Engine übergeben und im HTTP-Pfad wieder aufcountbeschnitten.
Diese Logik vermeidet das O(N)-Skipping großer Offsets und skaliert stabil über große Datenmengen.
To enable cursor-based pagination, include the following parameters in your AQL query request:
{
"query": "FOR user IN users SORT user.name ASC LIMIT 10 RETURN user",
"use_cursor": true,
"cursor": "optional_cursor_token_from_previous_response"
}Parameters:
-
use_cursor(boolean): Set totrueto enable cursor pagination -
cursor(string, optional): Token from previous response'snext_cursorfield to continue pagination
When use_cursor is enabled, the response format changes from the standard format to:
{
"items": [ /* array of result entities */ ],
"has_more": true,
"next_cursor": "base64_encoded_cursor_token",
"batch_size": 10
}Response Fields:
-
items: Array of result entities (same format as standardentitiesfield) -
has_more: Boolean indicating if more results are available -
next_cursor: Cursor token to use for fetching the next page (only present ifhas_moreis true) -
batch_size: Number of items in the current batch
Without use_cursor, the response uses the traditional format:
{
"table": "users",
"count": 10,
"entities": [ /* array of result entities */ ]
}curl -X POST http://localhost:8080/query/aql \
-H "Content-Type: application/json" \
-d '{
"query": "FOR user IN users SORT user.name ASC LIMIT 10 RETURN user",
"use_cursor": true
}'Response:
{
"items": [
{"_key": "alice", "name": "Alice", "age": "25"},
{"_key": "bob", "name": "Bob", "age": "30"},
...
],
"has_more": true,
"next_cursor": "eyJwayI6ImJvYiIsImNvbGxlY3Rpb24iOiJ1c2VycyIsInZlcnNpb24iOjF9",
"batch_size": 10
}Use the next_cursor from the previous response:
curl -X POST http://localhost:8080/query/aql \
-H "Content-Type: application/json" \
-d '{
"query": "FOR user IN users SORT user.name ASC LIMIT 10 RETURN user",
"use_cursor": true,
"cursor": "eyJwayI6ImJvYiIsImNvbGxlY3Rpb24iOiJ1c2VycyIsInZlcnNpb24iOjF9"
}'When there are no more results, has_more will be false and next_cursor will not be present:
{
"items": [
{"_key": "zack", "name": "Zack", "age": "28"}
],
"has_more": false,
"batch_size": 1
}Cursors are Base64-encoded JSON objects containing:
-
pk: Primary key of the last item in the current page -
collection: Name of the collection being queried -
version: Cursor format version (for future compatibility)
Example decoded cursor:
{
"pk": "users:bob",
"collection": "users",
"version": 1
}- Ties (gleicher Sortwert): Reihenfolge ist deterministisch durch PK-Tiebreaker. Cursor-Anker verwendet (value, pk), dadurch keine Duplikate/Übersprünge zwischen Seiten.
- DESC-Reihenfolge: Start-before-Verhalten spiegelt die absteigende Sortierung korrekt wider,
has_morewird viacount+1erkannt. - Kombination mit Filtern: Cursor-Position respektiert die aktive Filtermenge; Seiten sind konsistent mit den Filterbedingungen.
- Ungültiger Cursor: Der Server antwortet mit HTTP 400 (Bad Request) und einer Fehlernachricht.
- Für Cursor-Pagination ist eine sortierende Spalte mit Range-Index empfohlen, damit der indexbasierte Scan greift.
- Ohne ORDER BY kann
use_cursorverwendet werden, jedoch ist die Ordnung dann implizit nach PK; für reproduzierbares Paging wird eine Sortierung empfohlen.
If an invalid or expired cursor token is provided, the server returns a 400 Bad Request:
{
"error": "Invalid or expired cursor"
}If the cursor was generated for a different collection, the server returns a 400 Bad Request:
{
"error": "Cursor collection mismatch (expected: users, got: products)"
}-
Always check
has_more: Don't assume there are more results based on batch size alone - Store cursors short-term: Cursors are stateless but may become invalid if underlying data changes significantly
- Use consistent queries: The same query should be used across pagination requests (same SORT, FILTER, etc.)
- Handle errors gracefully: If a cursor becomes invalid, restart pagination from the beginning
- Combine with LIMIT: Use reasonable LIMIT values to control page size (recommended: 10-100 items)
| Aspect | Cursor-Based | Offset-Based |
|---|---|---|
| Performance | O(1) resume | O(N) skip |
| Consistency | Stable across pages | May skip/duplicate if data changes |
| Stateless | Yes (token-based) | Yes |
| Use Case | Large datasets, real-time data | Small datasets, random access |
| Current Support | ✅ Implemented | ✅ Implemented |
- Architecture-ACCESS-MODEL-IMPLEMENTATION-SUMMARY
- Architecture-ADR-003-pg-dump-sql-parser
- Architecture-BASEENTITY-PRINCIPLE
- Architecture-CACHE-STORAGE-INTEGRATION
- Architecture-CMAKE-ARCHITECTURE
- Architecture-CMAKE-FLAGS-REFERENCE
- Architecture-CMAKE-MODULAR-ARCHITECTURE
- Architecture-CONCERNS-ARCHITECTURE-DIAGRAM
- Architecture-CONCERNS-IMPLEMENTATION-SUMMARY
- Architecture-CONTENT-MODEL
- Architecture-COPILOT-THEMISDB-GRAPH-RAG-BACKEND-ARCHITECTURE
- Architecture-CRYPTO-AND-KEYS
- Architecture-FEATURE-FLAGS-REFERENCE
- Architecture-GPU-ARCHITECTURE-REVIEW-TEMPLATE
- Architecture-HTTP-SHUTDOWN-HARDENING
- Architecture-MIGRATION-GUIDE-CONCERNS
- Architecture-MIGRATION-GUIDE-v13-v14
- Architecture-MODULARIZATION-GUIDE
- Architecture-MODULAR-ARCHITECTURE-ROADMAP
- Architecture-MODULE-ARCHITECTURE-INDEX
- Architecture-P1D01-ISSMPLUGIN-DESIGN-REVIEW
- Architecture-P1-D01-ISSMPLUGIN-DESIGN-REVIEW
- Architecture-P1-D08-MAMBA-GOVERNANCE-CONTRACT
- Architecture-P1-P2-IMPLEMENTATION-COMPLETION-INDEX
- Architecture-PHASE0-COMPLETION-ASSESSMENT
- Architecture-PHASE3-QUERYENGINE-DI-ARCHITECTURE
- Architecture-PHASE4-INDEX-MANAGER-DI
- Architecture-POSTGRESQL-WIRE-PROTOCOL
- Architecture-QUERYENGINE-IMPLEMENTATION-GUIDE
- Architecture-QUERY-SCHEDULING
- Architecture-RAFT-CONSENSUS-DESIGN
- Architecture-README
- Architecture-README-SSM-HYBRID-IMPLEMENTATION
- Architecture-REFACTORING-SUMMARY
- Architecture-RESOURCE-POOLING
- Architecture-SOURCE-DIRECTORY-GUIDE
- Architecture-THEMIS-CORE-GUIDE
- Architecture-UNIFIED-ACCESS-MODEL
- Architecture-WAL-GRPC-MTLS-CONFIGURATION
- Architecture-WIRE-PROTOCOL-RETRY
- Architecture-boltzmann-observability-draft
- Architecture-experimental-logarithmic-vector-storage
- Architecture-llm-wiki-mvp-adr
- Architecture-rewrite-engine-architecture
- Architecture-rope-api-architecture
- Architecture-ssm-gguf-mamba-status
- Architecture-ssm-hybrid-analysis
- Architecture-ssm-hybrid-rollout-plan
- Architecture-ssm-plugin-interface-design-review
- Architecture-transaction-coordinators
- Architecture-wiki-secondary-index
- Architecture-wire-protocol
- Governance-DISABLED-STUB-POLICY
- Governance-DOCS-PR-POLICY
- Governance-GA-PROMOTION-SIGN-OFF
- Governance-GITHUB-MILESTONES-SETUP
- Governance-MATURITY-CLAIM-VERIFICATION-CHECKLIST
- Governance-MATURITY-EVIDENCE-REGISTRY
- Governance-MERGE-GATE-BOT-CONFIG
- Governance-MERGE-GATE-STATUS-LIVE
- Governance-PHASE3-ENFORCEMENT-RUNBOOK
- Governance-PHASE-1-CLOSURE-REPORT
- Governance-PHASE-CLOSURE-POLICY
- Governance-PHASE-DEPENDENCY-GRAPH
- Governance-PLUGIN-SUBMODULE-ROLLBACK
- Governance-PRODUCTION-READY-2026-DELIVERY-PLAN
- Governance-PR-VERSION-TARGETING
- Governance-PR-VERSION-TARGETING-BACKFILL
- Governance-QUERY-MODULE-STATUS
- Governance-README
- Governance-RELEASE-PROMOTION-GATE-POLICY
- Governance-RELEASE-VALIDATION-CHECKLIST
- Governance-SECURITY-MODULE-5671-EVIDENCE-SUMMARY
- Governance-SHARDING-P6-RESIDUAL-RISK-ACCEPTANCE
- Governance-SOURCECODE-COMPLIANCE-GOVERNANCE
- Governance-UPDATES-DEVELOPMENT-STATUS-SIGN-OFF
- Governance-WAVE-C-IMPLEMENTATION-COMPLETE
- Module-acceleration-Roadmap
- Module-access-model-Roadmap
- Module-ai-Roadmap
- Module-analytics-Roadmap
- Module-api-Roadmap
- Module-aql-Roadmap
- Module-auth-Roadmap
- Module-base-Roadmap
- Module-cache-Roadmap
- Module-cdc-Roadmap
- Module-chaos-Roadmap
- Module-chimera-Roadmap
- Module-config-Roadmap
- Module-content-Roadmap
- Module-core-Roadmap
- Module-distributed-knowledge-Roadmap
- Module-distributed-tensor-Roadmap
- Module-document-Roadmap
- Module-ethics-ai-Roadmap
- Module-evaluation-Roadmap
- Module-execution-Roadmap
- Module-exporters-Roadmap
- Module-failover-Roadmap
- Module-geo-Roadmap
- Module-governance-Roadmap
- Module-gpu-Roadmap
- Module-graph-Roadmap
- Module-image-analysis-Roadmap
- Module-importers-Roadmap
- Module-index-Roadmap
- Module-ingestion-Roadmap
- Module-llama-cpp-Roadmap
- Module-llm-Roadmap
- Module-llm-streaming-Roadmap
- Module-llm-wiki-Roadmap
- Module-maintenance-Roadmap
- Module-metadata-Roadmap
- Module-network-Roadmap
- Module-observability-Roadmap
- Module-onnx-clip-Roadmap
- Module-performance-Roadmap
- Module-plugins-Roadmap
- Module-process-Roadmap
- Module-projects-Roadmap
- Module-prompt-engineering-Roadmap
- Module-query-Roadmap
- Module-rag-Roadmap
- Module-replication-Roadmap
- Module-retrieval-Roadmap
- Module-rpc-grpc-Roadmap
- Module-scheduler-Roadmap
- Module-scraper-Roadmap
- Module-search-Roadmap
- Module-security-Roadmap
- Module-server-Roadmap
- Module-sharding-Roadmap
- Module-stable-diffusion-Roadmap
- Module-storage-Roadmap
- Module-temporal-Roadmap
- Module-tensor-Roadmap
- Module-themis-Roadmap
- Module-timeseries-Roadmap
- Module-toolbox-Roadmap
- Module-training-Roadmap
- Module-transaction-Roadmap
- Module-updates-Roadmap
- Module-user-storage-encrypted-Roadmap
- Module-utils-Roadmap
- Module-vector-search-Roadmap
- Module-voice-Roadmap
- Module-whisper-Roadmap