Allow ignored columns for mview to be specified at the subscription level.

Author: aligent-lturner

lib/internal/Magento/Framework/Mview/View/Subscription.php

@@ -57,13 +57,19 @@ class Subscription implements SubscriptionInterface
     protected $linkedViews = [];
 
     /**
-     * List of columns that can be updated in a subscribed table
+     * List of columns that can be updated in any subscribed table
      * without creating a new change log entry
      *
      * @var array
      */
     private $ignoredUpdateColumns = [];
 
+    /**
+     * List of columns that can be updated in a specific subscribed table
+     * for a specific view without creating a new change log entry
+     */
+    private $ignoredUpdateColumnsBySubscription = [];
+
     /**
      * @var Resource
      */
@@ -77,6 +83,7 @@ class Subscription implements SubscriptionInterface
      * @param string $tableName
      * @param string $columnName
      * @param array $ignoredUpdateColumns
+     * @param array $ignoredUpdateColumnsBySubscription
      */
     public function __construct(
         ResourceConnection $resource,
@@ -85,7 +92,8 @@ public function __construct(
         \Magento\Framework\Mview\ViewInterface $view,
         $tableName,
         $columnName,
-        $ignoredUpdateColumns = []
+        $ignoredUpdateColumns = [],
+        $ignoredUpdateColumnsBySubscription = []
     ) {
         $this->connection = $resource->getConnection();
         $this->triggerFactory = $triggerFactory;
@@ -95,6 +103,7 @@ public function __construct(
         $this->columnName = $columnName;
         $this->resource = $resource;
         $this->ignoredUpdateColumns = $ignoredUpdateColumns;
+        $this->ignoredUpdateColumnsBySubscription = $ignoredUpdateColumnsBySubscription;
     }
 
     /**
@@ -209,7 +218,9 @@ protected function buildStatement($event, $changelog)
                     $describe = $this->connection->describeTable($tableName)
                 ) {
                     $columnNames = array_column($describe, 'COLUMN_NAME');
-                    $columnNames = array_diff($columnNames, $this->ignoredUpdateColumns);
+                    $ignoredColumns = array_merge($this->ignoredUpdateColumns,
+                        $this->ignoredUpdateColumnsBySubscription[$changelog->getViewId()][$this->getTableName()] ?? []);
+                    $columnNames = array_diff($columnNames, $ignoredColumns);
                     if ($columnNames) {
                         $columns = [];
                         foreach ($columnNames as $columnName) {