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

mogno export+import uses EJSON

Browse Source
This commit is contained in:
Jan Prochazka
2024-08-26 15:09:44 +02:00
parent 62de736bce
commit d54b47f713
2 changed files with 18 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -245,8 +245,23 @@ const driver = {
const db = await getScriptableDb(pool);
exprValue = func(db, ObjectId.createFromHexString);
const pass = new stream.PassThrough({
objectMode: true,
highWaterMark: 100,
});
exprValue
.forEach((row) => pass.write(transformMongoData(row)))
.then(() => {
pass.end();
// pass.end(() => {
// pass.emit('end');
// })
});
return pass;
// return directly stream without header row
return exprValue.stream();
// return exprValue.stream();
// pass.write(structure || { __isDynamicStructure: true });
// exprValue.on('data', (row) => pass.write(row));