Patent attributes
Methods, systems, and apparatus, including computer programs encoded on computer storage media, for implementing a reactive database query retrieval system. One of the methods includes receiving a request to execute a query, obtaining a plurality of reactive programming operators including a database connection operator, a query operator, and a query results operator; evaluating the operators in the upstream subscription flow ordering until evaluating the database connection operator; allocating a first thread to execute the database connection operator to request a database connection; executing the database connection operator using the first thread to request a database connection; relinquishing computing resources for the first thread before the database management system responds to the request for the connection; receiving an indication that the database management system has provided a database connection; and in response, allocating a second thread to execute a query operator to provide the query to the database management system.
