fixed test

This commit is contained in:
Jan Prochazka
2021-06-03 11:45:27 +02:00
parent 0c48a5ee09
commit ddcb7711d4

View File

@@ -53,7 +53,7 @@ function executeStreamItem(driver, conn, sql) {
async function executeStream(driver, conn, sql) {
const results = [];
for (const sqlItem of splitQuery(driver.getQuerySplitterOptions('stream'))) {
for (const sqlItem of splitQuery(sql, driver.getQuerySplitterOptions('stream'))) {
const item = await executeStreamItem(driver, conn, sqlItem);
results.push(...item);
}