dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-04-30 09:13:58 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix: do not insert second id column

Browse Source
This commit is contained in:
Nybkox
2025-02-06 09:39:49 +01:00
parent 1d1e488755
commit 13ee14c752
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
plugins/dbgate-plugin-cassandra/src/backend/createBulkInsertStream.js
View File

@@ -27,6 +27,8 @@ function getColumnInfo(tableInfo, columnName) {
* @returns {{ shouldAddUuidPk: true, pkColumnName: string } | { shouldAddUuidPk: false }} * @returns {{ shouldAddUuidPk: true, pkColumnName: string } | { shouldAddUuidPk: false }}
*/ */
function getShouldAddUuidPkInfo(tableInfo) { 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; const pkColumnName = tableInfo.primaryKey?.columns[0]?.columnName;
if (!pkColumnName) return { shouldAddUuidPk: true, pkColumnName: 'id' }; if (!pkColumnName) return { shouldAddUuidPk: true, pkColumnName: 'id' };
@@ -72,7 +74,7 @@ function createCassandraBulkInsertStream(driver, stream, dbhan, name, options) {
dmp.putRaw('uuid()'); dmp.putRaw('uuid()');
dmp.putRaw(', '); dmp.putRaw(', ');
} }
dmp.putCollection(',', writable.columnNames, (col) => dmp.putValue(row[col])); dmp.putCollection(',', writable.columnNames, (col) => dmp.putValue(row[col]?.toString()));
dmp.putRaw(')'); dmp.putRaw(')');
await driver.query(dbhan, dmp.s, { discardResult: true }); await driver.query(dbhan, dmp.s, { discardResult: true });
} }