From 3a041667473c1ac615c5e2908110e5f1545167ba Mon Sep 17 00:00:00 2001
From: "SPRINX0\\prochazka" <jan.prochazka@sprinx.com>
Date: Wed, 5 Mar 2025 12:55:37 +0100
Subject: [PATCH] fixed bulk import

---
 packages/api/src/shell/copyStream.js                          | 4 +++-
 .../src/backend/createTediousBulkInsertStream.js              | 2 +-
 2 files changed, 4 insertions(+), 2 deletions(-)

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) {