| 摘要 |
To efficiently process a parameterized query against a relational database in a streaming transaction processing system, the transaction stream is treated as a sequence of multi-record "chunks" and a single "quasi-batch" query is executed for each chunk. A specific table in the database holds the parameter values obtained from each transaction and the parameters are bound to the rest of the query by using a database join. Another embodiment uses a framework that automates the technique by accepting the parameterized query, identifying inputs and outputs, reading the stream for the parameter values and building the parameter table, converting the parameterized query into an equivalent query that contains a join against the parameter table, performing the equivalent query and inserting the resulting query values into the stream.
|
