9 repository-uri
Non-blocking execution of SQL queries as reactive streams for asynchronous data consumption.
Distinct from Reactive Query Engines: Distinct from Reactive Query Engines: focuses on executing SQL queries reactively rather than general incremental or real-time query engines.
Explore 9 awesome GitHub repositories matching data & databases · Reactive SQL Query Execution. Refine with filters or upvote what's useful.
jOOQ is a type-safe SQL query builder for Java that generates code from live database schemas, enabling compile-time validation of SQL syntax and data types. Its core identity is built around a fluent DSL that mirrors SQL structure, a code generator that maps tables, views, and routines to Java objects, and a multi-dialect engine that translates the same DSL into vendor-specific SQL for over 30 databases. The project also includes a SQL parser and transformer for refactoring or dialect conversion, reactive stream integration for non-blocking query execution, and a JDBC proxy diagnostics tool f
Provides reactive stream integration for non-blocking SQL query execution.
General purpose redis client
Groups multiple Redis operations into atomic transactions that execute without interference from other clients.
Lettuce is a Redis client library for Java that provides synchronous, asynchronous, and reactive programming models for interacting with Redis databases. It supports standalone, cluster, sentinel, pub/sub, and search operations through a single thread-safe connection model that handles command execution without blocking the calling thread. The library distinguishes itself through its reactive streams integration with Project Reactor, enabling non-blocking, backpressure-aware data processing with Mono and Flux types. It offers cluster slot routing that transparently handles MOVED and ASK redir
Issues Redis commands reactively, returning Mono/Flux streams for non-blocking, backpressure-aware processing.
Acest proiect este o implementare de referință care oferă o colecție de exemple practice pentru tiparele de acces la date și abstractizările de repository în ecosistemul Spring Data. Acesta servește drept vitrină cuprinzătoare pentru implementarea straturilor de date consistente în diverse baze de date relaționale și non-relaționale. Repository-ul demonstrează în mod specific persistența multi-store prin integrarea bazelor de date relaționale, document și vectoriale într-o singură aplicație. Include implementări pentru căutarea vectorială pentru a gestiona embedding-uri de înaltă dimensiune și căutări de similaritate între diferite tehnologii de baze de date. Capabilitățile suplimentare acoperite includ accesul reactiv la date pentru operațiuni non-blocking și fluxuri de date asincrone. Proiectul oferă, de asemenea, îndrumări privind optimizarea imaginilor native pentru a îmbunătăți performanța de pornire și utilizarea memoriei prin compilare ahead-of-time. Exemplele ilustrează în continuare izolarea datelor multi-tenant, designul API-urilor de repository de date și integrarea căutării geospațiale și full-text.
Retrieves database records as asynchronous streams to prevent thread blocking during heavy I/O.
This is an educational relational database engine used in Carnegie Mellon University's database systems course. Students learn internals by implementing core components of a working database, including storage, indexing, concurrency control, and crash recovery. The system covers key database architecture: a B+ tree index for fast key-based lookups and range scans, a disk-oriented buffer pool that caches pages from disk, an iterator-based query execution model that composes physical operators, page-based storage for records, two-phase locking for coordinating concurrent transactions, and write
Parses and executes SQL statements against a relational schema with support for multiple query types.
Sqlbrite este un manager de baze de date SQLite reactiv și un wrapper ușor pentru Android. Acesta funcționează ca o bibliotecă SQL reactivă care convertește interogările SQLite standard în fluxuri observabile, permițând aplicației să emită automat noi rezultate atunci când tabelele de bază se modifică. Proiectul oferă un mecanism pentru urmărirea modificărilor în tabele specifice ale bazei de date, declanșând reîmprospătarea interogărilor fără polling manual. Include, de asemenea, un manager de tranzacții atomice pentru a grupa mai multe modificări SQL în unități unice, asigurând integritatea datelor și prevenind notificările redundante. Biblioteca gestionează persistența datelor locale pe Android prin delegarea operațiunilor de schemă și a gestionării ciclului de viață al bazei de date către helper-ul standard SQLite. Capabilitățile sale principale acoperă observarea datelor în timp real și gestionarea tranzacțiilor bazei de date.
Executes SQL queries as reactive streams that emit new data upon table updates.
Memgraph is an in-memory, distributed graph database designed for high-performance labeled property graph management. It utilizes a Cypher query engine for declarative data retrieval and manipulation, providing a scalable knowledge graph backend that integrates vector search and graph traversals. The system distinguishes itself as a real-time graph analytics platform, employing native C++ and CUDA implementations to execute complex network analysis and dynamic community detection on streaming data. It provides specialized support for AI integration, including GraphRAG capabilities, the constr
Executes a sequence of queries as a single unit of work to maintain data consistency.
Drift is a type-safe SQL persistence library and relational mapper that provides a structured way to map database tables to classes and execute SQL queries with build-time validation. It functions as a type-safe query builder and a wrapper for SQLite and PostgreSQL, eliminating manual result set parsing by binding query outputs to native objects. The project distinguishes itself through a build-time code generation system that produces type-safe APIs and validates raw SQL statements against database versions before execution. It features reactive query streaming, which transforms SQL queries
Returns reactive streams for manual SQL queries that emit updates when underlying tables change.
Spring GraphQL is a Java framework designed for building GraphQL services by mapping schema definitions directly to backend controller logic. It provides a reactive execution engine that processes queries and subscriptions asynchronously, supporting multiple network transports to facilitate communication between clients and data sources. The framework distinguishes itself through annotation-driven request routing, which decouples schema definitions from business logic to reduce implementation boilerplate. It includes native support for federated service composition, allowing developers to agg
Processes queries asynchronously using non-blocking streams to handle high-concurrency data fetching and real-time updates.