diff --git a/packages/api/src/shell/copyStream.js b/packages/api/src/shell/copyStream.js index 6a3a6848b..6e3c1aa59 100644 --- a/packages/api/src/shell/copyStream.js +++ b/packages/api/src/shell/copyStream.js @@ -11,7 +11,9 @@ class ReportingTransform extends stream.Transform { this.reporter = reporter; } _transform(chunk, encoding, callback) { - this.reporter.add(1); + if (!chunk?.__isStreamHeader) { + this.reporter.add(1); + } this.push(chunk); callback(); } diff --git a/plugins/dbgate-plugin-mssql/src/backend/createTediousBulkInsertStream.js b/plugins/dbgate-plugin-mssql/src/backend/createTediousBulkInsertStream.js index c0d6208ed..c5e453b9a 100644 --- a/plugins/dbgate-plugin-mssql/src/backend/createTediousBulkInsertStream.js +++ b/plugins/dbgate-plugin-mssql/src/backend/createTediousBulkInsertStream.js @@ -52,7 +52,7 @@ function runBulkInsertBatch(dbhan, tableName, writable, rows) { function createTediousBulkInsertStream(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 () => { if (!writable.templateColumns) {