From e2547c72959a9f2ab808cce784665bb4fd7bba1f Mon Sep 17 00:00:00 2001
From: Nybkox <nybkox@gmail.com>
Date: Thu, 6 Feb 2025 11:11:06 +0100
Subject: [PATCH] feat: add test for importing data to an existing table

---
 .../__tests__/db-import-export.spec.js        | 19 +++++++++++++++++++
 1 file changed, 19 insertions(+)

diff --git a/integration-tests/__tests__/db-import-export.spec.js b/integration-tests/__tests__/db-import-export.spec.js
index ed99ee08b..f28b2d46b 100644
--- a/integration-tests/__tests__/db-import-export.spec.js
+++ b/integration-tests/__tests__/db-import-export.spec.js
@@ -54,6 +54,25 @@ describe('DB Import/export', () => {
     })
   );
 
+  test.each(engines.map(engine => [engine.label, engine]))(
+    `Import to existing table - %s`,
+    testWrapper(async (conn, driver, engine) => {
+      await runQueryOnDriver(conn, driver, dmp => dmp.put(`create table ~t1 (~id int primary key, ~country text)`));
+
+      const reader = createImportStream();
+      const writer = await tableWriter({
+        systemConnection: conn,
+        driver,
+        pureName: 't1',
+        createIfNotExists: true,
+      });
+      await copyStream(reader, writer);
+
+      const res = await runQueryOnDriver(conn, driver, dmp => dmp.put(`select count(*) as ~cnt from ~t1`));
+      expect(res.rows[0].cnt.toString()).toEqual('6');
+    })
+  );
+
   test.each(engines.map(engine => [engine.label, engine]))(
     'Import two tables - %s',
     testWrapper(async (conn, driver, engine) => {