rowsAffected field added

plugins/dbgate-plugin-mssql/src/backend/tediousDriver.js

@@ -165,6 +165,7 @@ async function tediousReadQuery(dbhan, sql, structure) {
 
 async function tediousStream(dbhan, sql, options) {
   let currentColumns = [];
+  let skipAffectedMessage = false;
 
   const handleInfo = info => {
     const { message, lineNumber, procName } = info;
@@ -200,11 +201,14 @@ async function tediousStream(dbhan, sql, options) {
     dbhan.client.off('infoMessage', handleInfo);
     dbhan.client.off('errorMessage', handleError);
 
-    options.info({
-      message: `${rowCount} rows affected`,
-      time: new Date(),
-      severity: 'info',
-    });
+    if (!skipAffectedMessage) {
+      options.info({
+        message: `${rowCount} rows affected`,
+        time: new Date(),
+        severity: 'info',
+        rowsAffected: rowCount,
+      });
+    }
   });
   request.on('columnMetadata', function (columns) {
     currentColumns = extractTediousColumns(columns);
@@ -216,6 +220,7 @@ async function tediousStream(dbhan, sql, options) {
       columns.map(x => x.value)
     );
     options.row(row);
+    skipAffectedMessage = true;
   });
   dbhan.client.execSqlBatch(request);
 }

plugins/dbgate-plugin-mysql/src/backend/drivers.js

@@ -129,6 +129,7 @@ const drivers = driverBases.map(driverBase => ({
           message: `${row.affectedRows} rows affected`,
           time: new Date(),
           severity: 'info',
+          rowsAffected: row.affectedRows,
         });
         if (row.stateChanges?.schema) {
           options.changedCurrentDatabase(row.stateChanges.schema);

plugins/dbgate-plugin-oracle/src/backend/driver.js

@@ -223,6 +223,7 @@ const driver = {
               message: `${rowsAffected} rows affected`,
               time: new Date(),
               severity: 'info',
+              rowsAffected,
             });
           }
         }

plugins/dbgate-plugin-postgres/src/backend/drivers.js

@@ -232,6 +232,7 @@ const drivers = driverBases.map(driverBase => ({
           message: `${rowCount} rows affected`,
           time: new Date(),
           severity: 'info',
+          rowsAffected: rowCount,
         });
       }
 

plugins/dbgate-plugin-sqlite/src/backend/driver.libsql.js

@@ -74,6 +74,7 @@ const libsqlDriver = {
           message: `${rowCounter.count} rows affected`,
           time: new Date(),
           severity: 'info',
+          rowsAffected: rowCounter.count,
         });
       }
     });

plugins/dbgate-plugin-sqlite/src/backend/driver.sqlite.js

@@ -69,6 +69,7 @@ const driver = {
           message: `${rowCounter.count} rows affected`,
           time: new Date(),
           severity: 'info',
+          rowsAffected: rowCounter.count,
         });
       }
     });

plugins/dbgate-plugin-sqlite/src/backend/helpers.js

@@ -27,6 +27,7 @@ function runStreamItem(dbhan, sql, options, rowCounter) {
         message: `${rowCounter.count} rows affected`,
         time: new Date(),
         severity: 'info',
+        rowsAffected: rowCounter.count,
       });
       rowCounter.count = 0;
       rowCounter.date = null;