Forked from islishude/node-mysql2-promise-query-stream.js
Created
December 26, 2022 15:15
-
-
Save Mauzzz0/56e79f9f262062c7ddd0bb59f8594409 to your computer and use it in GitHub Desktop.
node-mysql2 query stream with Promise
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
// 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(); | |
}); |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment