From 94cccf9e17f679aebc8452707929880bdc6ac7e0 Mon Sep 17 00:00:00 2001
From: Nybkox <nybkox@gmail.com>
Date: Thu, 6 Feb 2025 11:05:24 +0100
Subject: [PATCH] fix(cassandra): check column name correctly

---
 .../src/backend/createBulkInsertStream.js                       | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/plugins/dbgate-plugin-cassandra/src/backend/createBulkInsertStream.js b/plugins/dbgate-plugin-cassandra/src/backend/createBulkInsertStream.js
index e920e2123..1952e5938 100644
--- a/plugins/dbgate-plugin-cassandra/src/backend/createBulkInsertStream.js
+++ b/plugins/dbgate-plugin-cassandra/src/backend/createBulkInsertStream.js
@@ -35,7 +35,7 @@ function getShouldAddUuidPkInfo(tableInfo) {
   const columnInfo = getColumnInfo(tableInfo, pkColumnName);
   if (!columnInfo) return { shouldAddUuidPk: false };
 
-  const shouldAddUuidPk = writable.columnNames.every((i) => i !== columnInfo.columnName);
+  const shouldAddUuidPk = tableInfo.columns.every((i) => i.columnName !== columnInfo.columnName);
   if (!shouldAddUuidPk) return { shouldAddUuidPk };
 
   return { shouldAddUuidPk, pkColumnName };