this.db.select_stream

Вызов

 this.db.select_stream (sql, params, options)

извлекает выборку по заданному запросу sql с параметрами params в виде потока объектов, соответствующих записям. Объект options может использоваться для установки highWaterMark и прочих опций потока.

Реализовано для PostgreSQL (требует установки pg-query-stream), Clickhouse и MySQL.

Пример: перекачка выборки из БД this.db в this.db_dw в потоковом режиме через ограниченный буфер с преобразованием каждой записи r:

  await this.db_dw.insert (table, 
    (await this.db.select_stream (sql, params)).pipe (
      new Transform ({objectMode: true, transform (r, e, cb) {
        // ...r...
        this.push (r)
        cb ()
      }})
    )
  )