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

feat: add writeTable to firebird

Browse Source
This commit is contained in:
Pavel
2025-06-03 14:20:54 +02:00
parent b8899fcafa
commit ffb6cfaa4a
1 changed files with 7 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
plugins/dbgate-plugin-firebird/src/backend/driver.js
View File

@@ -43,6 +43,8 @@ const driver = {
dbhan.client.query(sql, (err, result) => { dbhan.client.query(sql, (err, result) => {
if (err) { if (err) {
reject(err); reject(err);
console.error(err);
console.error('Executing query:', sql);
return; return;
} }
@@ -98,6 +100,9 @@ const driver = {
} }
}, },
async writeTable(dbhan, name, options) {
return createBulkInsertStreamBase(this, stream, dbhan, name, options);
},
async script(dbhan, sql, { useTransaction } = {}) { async script(dbhan, sql, { useTransaction } = {}) {
if (useTransaction) return this.runSqlInTransaction(dbhan, sql); if (useTransaction) return this.runSqlInTransaction(dbhan, sql);
@@ -137,7 +142,7 @@ const driver = {
}, },
async writeTable(dbhan, name, options) { async writeTable(dbhan, name, options) {
return createBulkInsertStream(this, stream, dbhan, name, options); return createBulkInsertStreamBase(this, stream, dbhan, name, options);
}, },
async getVersion(dbhan) { async getVersion(dbhan) {
@@ -186,6 +191,7 @@ const driver = {
transactionPromise.query(currentSql, function (err, result) { transactionPromise.query(currentSql, function (err, result) {
if (err) { if (err) {
logger.error(extractErrorLogData(err), 'Error executing SQL in transaction'); logger.error(extractErrorLogData(err), 'Error executing SQL in transaction');
logger.error({ sql: currentSql }, 'SQL that caused the error');
return reject(err); return reject(err);
} }
resolve(result); resolve(result);