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

fix

Browse Source
This commit is contained in:
Jan Prochazka
2021-04-18 20:14:32 +02:00
parent cef6b8520e
commit 29aa59771c
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
plugins/dbgate-plugin-mongo/src/backend/createBulkInsertStream.js
View File

@@ -1,4 +1,4 @@
export function createBulkInsertStream(driver, stream, pool, name, options) { function createBulkInsertStream(driver, stream, pool, name, options) {
const collectionName = name.pureName; const collectionName = name.pureName;
const db = pool.__getDatabase(); const db = pool.__getDatabase();
@@ -12,9 +12,12 @@ export function createBulkInsertStream(driver, stream, pool, name, options) {
writable.addRow = (row) => { writable.addRow = (row) => {
if (!writable.wasHeader) { if (!writable.wasHeader) {
writable.wasHeader = true; writable.wasHeader = true;
if (row.__isStreamHeader || if (
row.__isStreamHeader ||
// TODO remove isArray test // TODO remove isArray test
Array.isArray(row.columns)) return; Array.isArray(row.columns)
)
return;
} }
writable.buffer.push(row); writable.buffer.push(row);
}; };
@@ -56,3 +59,5 @@ export function createBulkInsertStream(driver, stream, pool, name, options) {
return writable; return writable;
} }
module.exports = createBulkInsertStream;