Quick updates to make sure mySQL works with automations.

packages/server/src/api/controllers/row/external.js

@@ -22,19 +22,26 @@ function inputProcessing(row, table) {
   return newRow
 }
 
-function outputProcessing(rows, table) {
+function generateIdForRow(row, table) {
-  // if no rows this is what is returned? Might be PG only
+  if (!row) {
-  if (rows[0].read === true) {
+    return
-    return []
   }
   const primary = table.primary
-  for (let row of rows) {
   // build id array
   let idParts = []
   for (let field of primary) {
     idParts.push(row[field])
   }
-    row._id = generateRowIdField(idParts)
+  return generateRowIdField(idParts)
+}
+
+function outputProcessing(rows, table) {
+  // if no rows this is what is returned? Might be PG only
+  if (rows[0].read === true) {
+    return []
+  }
+  for (let row of rows) {
+    row._id = generateIdForRow(row, table)
     row.tableId = table._id
     row._rev = "rev"
   }
@@ -89,8 +96,6 @@ async function handleRequest(
   }
   // clean up row on ingress using schema
   filters = buildFilters(id, filters, table)
-  // get the id after building filters, but before it is removed from the row
-  id = id || (row ? row._id : null)
   row = inputProcessing(row, table)
   if (
     operation === DataSourceOperation.DELETE &&
@@ -114,7 +119,7 @@ async function handleRequest(
     body: row,
     // pass an id filter into extra, purely for mysql/returning
     extra: {
-      idFilter: buildFilters(id, {}, table),
+      idFilter: buildFilters(id || generateIdForRow(row, table), {}, table),
     }
   }
   // can't really use response right now

packages/server/src/integrations/mysql.js

@@ -180,6 +180,9 @@ class MySQLIntegration extends Sql {
   }
 
   async getReturningRow(json) {
+    if (!json.extra.idFilter) {
+      return {}
+    }
     const input = this._query({
       endpoint: {
         ...json.endpoint,