Chris@0: <?php
Chris@0: 
Chris@0: namespace Drupal\node;
Chris@0: 
Chris@0: use Drupal\Core\Entity\Sql\SqlContentEntityStorage;
Chris@0: use Drupal\Core\Session\AccountInterface;
Chris@0: use Drupal\Core\Language\LanguageInterface;
Chris@0: 
Chris@0: /**
Chris@0:  * Defines the storage handler class for nodes.
Chris@0:  *
Chris@0:  * This extends the base storage class, adding required special handling for
Chris@0:  * node entities.
Chris@0:  */
Chris@0: class NodeStorage extends SqlContentEntityStorage implements NodeStorageInterface {
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public function revisionIds(NodeInterface $node) {
Chris@0:     return $this->database->query(
Chris@17:       'SELECT vid FROM {' . $this->getRevisionTable() . '} WHERE nid=:nid ORDER BY vid',
Chris@0:       [':nid' => $node->id()]
Chris@0:     )->fetchCol();
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public function userRevisionIds(AccountInterface $account) {
Chris@0:     return $this->database->query(
Chris@17:       'SELECT vid FROM {' . $this->getRevisionDataTable() . '} WHERE uid = :uid ORDER BY vid',
Chris@0:       [':uid' => $account->id()]
Chris@0:     )->fetchCol();
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public function countDefaultLanguageRevisions(NodeInterface $node) {
Chris@17:     return $this->database->query('SELECT COUNT(*) FROM {' . $this->getRevisionDataTable() . '} WHERE nid = :nid AND default_langcode = 1', [':nid' => $node->id()])->fetchField();
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public function updateType($old_type, $new_type) {
Chris@17:     return $this->database->update($this->getBaseTable())
Chris@0:       ->fields(['type' => $new_type])
Chris@0:       ->condition('type', $old_type)
Chris@0:       ->execute();
Chris@0:   }
Chris@0: 
Chris@0:   /**
Chris@0:    * {@inheritdoc}
Chris@0:    */
Chris@0:   public function clearRevisionsLanguage(LanguageInterface $language) {
Chris@17:     return $this->database->update($this->getRevisionTable())
Chris@0:       ->fields(['langcode' => LanguageInterface::LANGCODE_NOT_SPECIFIED])
Chris@0:       ->condition('langcode', $language->getId())
Chris@0:       ->execute();
Chris@0:   }
Chris@0: 
Chris@0: }