class DatabaseStorageSortedSet in Key-value Extensions 8

Hierarchy

• class \Drupal\key_value\KeyValueStore\DatabaseStorageSortedBase implements KeyValueStoreSortedInterface
  • class \Drupal\key_value\KeyValueStore\DatabaseStorageSortedSet implements KeyValueStoreSortedSetInterface

File

src/KeyValueStore/DatabaseStorageSortedSet.php, line 5

Namespace

Drupal\key_value\KeyValueStore

class DatabaseStorageSortedSet extends DatabaseStorageSortedBase implements KeyValueStoreSortedSetInterface {

  /**
   * {@inheritdoc}
   */
  public function add($score, $member) {
    $this
      ->addMultiple([
      [
        $score => $member,
      ],
    ]);
  }

  /**
   * {@inheritdoc}
   */
  public function addMultiple(array $pairs) {

    // @todo Find out if we can to multiple merge queries in one atomic
    // operation.
    foreach ($pairs as $pair) {
      foreach ($pair as $score => $member) {
        $encoded_member = $this->serializer
          ->encode($member);
        $this->connection
          ->merge($this->table)
          ->fields([
          'collection' => $this->collection,
          'name' => $score,
          'value' => $encoded_member,
        ])
          ->condition('collection', $this->collection)
          ->condition('value', $encoded_member)
          ->execute();
      }
    }
  }

  /**
   * {@inheritdoc}
   */
  public function deleteRange($start, $stop, $inclusive = TRUE) {

    // @todo
  }

  /**
   * {@inheritdoc}
   */
  public function getCount() {
    return $this->connection
      ->select($this->table, 't')
      ->condition('collection', $this->collection)
      ->countQuery()
      ->execute()
      ->fetchField();
  }
  public function getMaxScore() {
    $query = $this->connection
      ->select($this->table);
    $query
      ->condition('collection', $this->collection, '=');
    $query
      ->addExpression('MAX(name)');
    return $query
      ->execute()
      ->fetchField();
  }
  public function getMinScore() {
    $query = $this->connection
      ->select($this->table);
    $query
      ->condition('collection', $this->collection, '=');
    $query
      ->addExpression('MIN(name)');
    return $query
      ->execute()
      ->fetchField();
  }

}

Members

Name	Modifiers	Type	Description	Overrides
DatabaseStorageSortedBase::$collection	protected	property
DatabaseStorageSortedBase::$connection	protected	property
DatabaseStorageSortedBase::$serializer	protected	property
DatabaseStorageSortedBase::$table	protected	property
DatabaseStorageSortedBase::getRange	public	function	Overrides KeyValueStoreSortedInterface::getRange
DatabaseStorageSortedBase::__construct	public	function
DatabaseStorageSortedSet::add	public	function	Overrides KeyValueStoreSortedSetInterface::add
DatabaseStorageSortedSet::addMultiple	public	function	Overrides KeyValueStoreSortedSetInterface::addMultiple
DatabaseStorageSortedSet::deleteRange	public	function	Overrides KeyValueStoreSortedSetInterface::deleteRange
DatabaseStorageSortedSet::getCount	public	function	Overrides DatabaseStorageSortedBase::getCount
DatabaseStorageSortedSet::getMaxScore	public	function	Overrides KeyValueStoreSortedSetInterface::getMaxScore
DatabaseStorageSortedSet::getMinScore	public	function	Overrides KeyValueStoreSortedSetInterface::getMinScore