dennii/dbgate
1
0
Fork 0
mirror of https://github.com/DeNNiiInc/dbgate.git synced 2026-05-03 14:03:57 +00:00
Code Issues Packages Projects Releases Wiki Activity

feat: pass dataType to bulk insert value put

Browse Source
This commit is contained in:
Nybkox
2025-02-06 11:09:14 +01:00
parent 94cccf9e17
commit 359557e321
1 changed files with 10 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -74,7 +74,16 @@ 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]?.toString())); dmp.putCollection(',', writable.columnNames, (col) => {
const existingColumn = getColumnInfo(writable.structure, col);
const dataType = existingColumn?.dataType;
if (dataType) {
dmp.putValue(row[col], dataType);
} else {
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 });
} }