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.