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

fixed bulk import

Browse Source
This commit is contained in:
SPRINX0\prochazka
2025-03-05 12:55:37 +01:00
parent 75bf58359c
commit 3a04166747
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
packages/api/src/shell/copyStream.js
View File

@@ -11,7 +11,9 @@ class ReportingTransform extends stream.Transform {
this.reporter = reporter; this.reporter = reporter;
} }
_transform(chunk, encoding, callback) { _transform(chunk, encoding, callback) {
this.reporter.add(1); if (!chunk?.__isStreamHeader) {
this.reporter.add(1);
}
this.push(chunk); this.push(chunk);
callback(); callback();
} }

2
plugins/dbgate-plugin-mssql/src/backend/createTediousBulkInsertStream.js
View File

@@ -52,7 +52,7 @@ function runBulkInsertBatch(dbhan, tableName, writable, rows) {
function createTediousBulkInsertStream(driver, stream, dbhan, name, options) { function createTediousBulkInsertStream(driver, stream, dbhan, name, options) {
const writable = createBulkInsertStreamBase(driver, stream, dbhan, name, options); const writable = createBulkInsertStreamBase(driver, stream, dbhan, name, options);
const fullName = name.schemaName ? `[${name.schemaName}].[${name.pureName}]` : name.pureName; const fullName = name.schemaName ? `[${name.schemaName}].[${name.pureName}]` : `[${name.pureName}]`;
writable.send = async () => { writable.send = async () => {
if (!writable.templateColumns) { if (!writable.templateColumns) {