node-mysql2 query stream with Promise

node-mysql2-promise-query-stream.js

// https://github.com/sidorares/node-mysql2/issues/677

const mysql = require("mysql2/promise");
const stream = require("stream");
const dbconn = mysql.createPool({
  connectionLimit: 10,
  host: "127.0.0.1",
  user: "user",
  password: "password",
  database: "database",
});

const Reader = dbconn.pool.query(`select * from tname limit 10;`).stream();

const Writer = new stream.Writable({
  objectMode: true,
  write(data, enc, cb) {
    console.log(data);
    cb();
  },
});

stream.pipeline(Reader, Writer, (err) => {
  if (err) {
    console.log(err);
  }
  dbconn.end();
});