dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-18 03:16:01 +00:00
Code Issues Packages Projects Releases Wiki Activity

mixed mongoDB export #1044

Browse Source
This commit is contained in:
SPRINX0\prochazka
2025-02-25 17:59:31 +01:00
parent 63314b54bc
commit f2bd08f02a
1 changed files with 19 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

27
plugins/dbgate-plugin-mongo/src/backend/driver.js
View File

@@ -260,14 +260,25 @@ const driver = {
highWaterMark: 100,
});
exprValue
.forEach((row) => pass.write(transformMongoData(row)))
.then(() => {
pass.end();
// pass.end(() => {
// pass.emit('end');
// })
});
const cursorStream = exprValue.stream();
cursorStream.on('data', (row) => {
pass.write(transformMongoData(row));
});
// Called once the cursor is fully read
cursorStream.on('end', () => {
pass.emit('end');
});
// exprValue
// .forEach((row) => pass.write(transformMongoData(row)))
// .then(() => {
// pass.end();
// // pass.end(() => {
// // pass.emit('end');
// // })
// });
return pass;
// return directly stream without header row