Subscription Class Reference

Inheritance diagram for Subscription:

Public Member Functions
	__construct (ResourceConnection $resource, \Magento\Framework\DB\Ddl\TriggerFactory $triggerFactory, \Magento\Framework\Mview\View\CollectionInterface $viewCollection, \Magento\Framework\Mview\ViewInterface $view, $tableName, $columnName, $ignoredUpdateColumns=[])
	getView ()
	getTableName ()
	getColumnName ()
Public Member Functions inherited from SubscriptionInterface
	create ()
	remove ()

Protected Member Functions
	buildStatement ($event, $changelog)

Protected Attributes
	$connection
	$triggerFactory
	$viewCollection
	$view
	$tableName
	$columnName
	$linkedViews = []
	$resource

Detailed Description

Definition at line 18 of file Subscription.php.

Constructor & Destructor Documentation

__construct()

__construct	(	ResourceConnection	$resource,
		\Magento\Framework\DB\Ddl\TriggerFactory	$triggerFactory,
		\Magento\Framework\Mview\View\CollectionInterface	$viewCollection,
		\Magento\Framework\Mview\ViewInterface	$view,
			$tableName,
			$columnName,
			$ignoredUpdateColumns = []
	)

Parameters

ResourceConnection	$resource
\Magento\Framework\DB\Ddl\TriggerFactory	$triggerFactory
\Magento\Framework\Mview\View\CollectionInterface	$viewCollection
\Magento\Framework\Mview\ViewInterface	$view
string	$tableName
string	$columnName
array	$ignoredUpdateColumns

Definition at line 81 of file Subscription.php.

      {
        $this->connection = $resource->getConnection();
        $this->triggerFactory = $triggerFactory;
        $this->viewCollection = $viewCollection;
        $this->view = $view;
        $this->tableName = $tableName;
        $this->columnName = $columnName;
        $this->resource = $resource;
        $this->ignoredUpdateColumns = $ignoredUpdateColumns;
    }

Member Function Documentation

buildStatement()

buildStatement (   $event,   $changelog  )

protected

Build trigger statement for INSERT, UPDATE, DELETE events

Parameters

string	$event
\Magento\Framework\Mview\View\ChangelogInterface	$changelog

Returns

string

Definition at line 199 of file Subscription.php.

    {
        switch ($event) {
            case Trigger::EVENT_INSERT:
                $trigger = "INSERT IGNORE INTO %s (%s) VALUES (NEW.%s);";
                break;
            case Trigger::EVENT_UPDATE:
                $tableName = $this->resource->getTableName($this->getTableName());
                $trigger = "INSERT IGNORE INTO %s (%s) VALUES (NEW.%s);";
                if ($this->connection->isTableExists($tableName) &&
                    $describe = $this->connection->describeTable($tableName)
                ) {
                    $columnNames = array_column($describe, 'COLUMN_NAME');
                    $columnNames = array_diff($columnNames, $this->ignoredUpdateColumns);
                    if ($columnNames) {
                        $columns = [];
                        foreach ($columnNames as $columnName) {
                            $columns[] = sprintf(
                                'NEW.%1$s <=> OLD.%1$s',
                                $this->connection->quoteIdentifier($columnName)
                            );
                        }
                        $trigger = sprintf(
                            "IF (%s) THEN %s END IF;",
                            implode(' OR ', $columns),
                            $trigger
                        );
                    }
                }
                break;
            case Trigger::EVENT_DELETE:
                $trigger = "INSERT IGNORE INTO %s (%s) VALUES (OLD.%s);";
                break;
            default:
                return '';
        }
        return sprintf(
            $trigger,
            $this->connection->quoteIdentifier($this->resource->getTableName($changelog->getName())),
            $this->connection->quoteIdentifier($changelog->getColumnName()),
            $this->connection->quoteIdentifier($this->getColumnName())
        );
    }

getColumnName()

getColumnName

(

)

Retrieve table column name

Returns

string @codeCoverageIgnore

Implements SubscriptionInterface.

Definition at line 287 of file Subscription.php.

    {
        return $this->columnName;
    }

getTableName()

getTableName

(

)

Retrieve table name

Returns

string @codeCoverageIgnore

Implements SubscriptionInterface.

Definition at line 276 of file Subscription.php.

    {
        return $this->tableName;
    }

getView()

getView

(

)

Retrieve View related to subscription

Returns

\Magento\Framework\Mview\ViewInterface @codeCoverageIgnore

Implements SubscriptionInterface.

Definition at line 265 of file Subscription.php.

    {
        return $this->view;
    }

Field Documentation

$columnName

$columnName

protected

Definition at line 50 of file Subscription.php.

$connection

$connection

protected

Definition at line 25 of file Subscription.php.

$linkedViews

$linkedViews = []

protected

Definition at line 57 of file Subscription.php.

$resource

$resource

protected

Definition at line 70 of file Subscription.php.

$tableName

$tableName

protected

Definition at line 45 of file Subscription.php.

$triggerFactory

$triggerFactory

protected

Definition at line 30 of file Subscription.php.

$view

$view

protected

Definition at line 40 of file Subscription.php.

$viewCollection

$viewCollection

protected

Definition at line 35 of file Subscription.php.

---

The documentation for this class was generated from the following file:

• vendor/magento/framework/Mview/View/Subscription.php