From 13ee14c752cf449c116580bcdc5307bbac8eb964 Mon Sep 17 00:00:00 2001 From: Nybkox Date: Thu, 6 Feb 2025 09:39:49 +0100 Subject: [PATCH] fix: do not insert second id column --- .../src/backend/createBulkInsertStream.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/plugins/dbgate-plugin-cassandra/src/backend/createBulkInsertStream.js b/plugins/dbgate-plugin-cassandra/src/backend/createBulkInsertStream.js index a0bb81d0d..e920e2123 100644 --- a/plugins/dbgate-plugin-cassandra/src/backend/createBulkInsertStream.js +++ b/plugins/dbgate-plugin-cassandra/src/backend/createBulkInsertStream.js @@ -27,6 +27,8 @@ function getColumnInfo(tableInfo, columnName) { * @returns {{ shouldAddUuidPk: true, pkColumnName: string } | { shouldAddUuidPk: false }} */ function getShouldAddUuidPkInfo(tableInfo) { + const hasIdColumn = tableInfo.columns.some((x) => x.columnName == 'id'); + if (hasIdColumn && !tableInfo.primaryKey) return { shouldAddUuidPk: false }; const pkColumnName = tableInfo.primaryKey?.columns[0]?.columnName; if (!pkColumnName) return { shouldAddUuidPk: true, pkColumnName: 'id' }; @@ -72,7 +74,7 @@ function createCassandraBulkInsertStream(driver, stream, dbhan, name, options) { dmp.putRaw('uuid()'); dmp.putRaw(', '); } - dmp.putCollection(',', writable.columnNames, (col) => dmp.putValue(row[col])); + dmp.putCollection(',', writable.columnNames, (col) => dmp.putValue(row[col]?.toString())); dmp.putRaw(')'); await driver.query(dbhan, dmp.s, { discardResult: true }); }