Wikibase\QueryEngine\SQLStore\SnakStore\SnakInserter

Complexity

Total Complexity

5

Size/Duplication

Total Lines	43
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	2

Importance

Changes

0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	insertSnak()	0	4	1
A	insertSnakRow()	0	10	3

<?php

namespace Wikibase\QueryEngine\SQLStore\SnakStore;

use RuntimeException;
use Wikibase\DataModel\Entity\EntityId;
use Wikibase\DataModel\Snak\Snak;

/**
 * Use case for inserting snaks into the store.
 *
 * @licence GNU GPL v2+
 * @author Jeroen De Dauw < jeroendedauw@gmail.com >
 */
class SnakInserter {

	/**
	 * @var SnakStore[]
	 */
	private $snakStores;

	private $snakRowBuilder;

	/**
	 * @param SnakStore[] $snakStores
	 * @param SnakRowBuilder $snakRowBuilder
	 */
	public function __construct( array $snakStores, SnakRowBuilder $snakRowBuilder ) {
		$this->snakStores = $snakStores;
		$this->snakRowBuilder = $snakRowBuilder;
	}

	/**
	 * @param Snak $snak
	 * @param int $snakRole
	 * @param EntityId $subjectId
	 * @param int $statementRank
	 *
	 * TODO: exception
	 */
	public function insertSnak( Snak $snak, $snakRole, EntityId $subjectId, $statementRank ) {
		$snakRow = $this->snakRowBuilder->newSnakRow( $snak, $snakRole, $subjectId, $statementRank );
		$this->insertSnakRow( $snakRow );
	}

	private function insertSnakRow( SnakRow $snakRow ) {
		foreach ( $this->snakStores as $snakStore ) {
			if ( $snakStore->canStore( $snakRow ) ) {
				$snakStore->storeSnakRow( $snakRow );
				return;
			}
		}

		throw new RuntimeException( 'Cannot store the snak as there is no SnakStore that can handle it' );
	}

}