Wikibase\QueryEngine\SQLStore\SnakStore\ValuelessSnakStore

Complexity

Total Complexity

9

Size/Duplication

Total Lines	60
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes

0

6 Methods

Rating	Name	Duplication	Size	Complexity
A	__construct()	0	4	1
A	canStore()	0	3	1
A	storeSnakRow()	0	15	3
A	insertSnakRow()	0	12	1
A	removeSnaksOfSubject()	0	8	2
A	deleteSnakRow()	0	6	1

<?php

namespace Wikibase\QueryEngine\SQLStore\SnakStore;

use Doctrine\DBAL\Connection;
use Doctrine\DBAL\DBALException;
use InvalidArgumentException;
use Wikibase\DataModel\Entity\EntityId;
use Wikibase\QueryEngine\QueryEngineException;

/**
 * @licence GNU GPL v2+
 * @author Jeroen De Dauw < jeroendedauw@gmail.com >
 */
class ValuelessSnakStore extends SnakStore {

	private $connection;
	private $tableName;

	public function __construct( Connection $connection, $tableName ) {
		$this->connection = $connection;
		$this->tableName = $tableName;
	}

	public function canStore( SnakRow $snakRow ) {
		return $snakRow instanceof ValuelessSnakRow;
	}

	public function storeSnakRow( SnakRow $snakRow ) {
		if ( !$this->canStore( $snakRow ) ) {
			throw new InvalidArgumentException( 'Can only store ValuelessSnakRow in ValuelessSnakStore' );
		}

		/**
		 * @var ValuelessSnakRow $snakRow
		 */
		try {
			$this->insertSnakRow( $snakRow );
		}
		catch ( DBALException $ex ) {
			throw new QueryEngineException( $ex->getMessage(), 0, $ex );
		}
	}

	private function insertSnakRow( ValuelessSnakRow $snakRow ) {
		$this->connection->insert(
			$this->tableName,
			array(
				'subject_id' => $snakRow->getSubjectId()->getSerialization(),
				'subject_type' => $snakRow->getSubjectId()->getEntityType(),
				'property_id' => $snakRow->getPropertyId(),
				'statement_rank' => $snakRow->getStatementRank(),
				'snak_type' => $snakRow->getInternalSnakType(),
			)
		);
	}

	public function removeSnaksOfSubject( EntityId $subjectId ) {
		try {
			$this->deleteSnakRow( $subjectId );
		}
		catch ( DBALException $ex ) {
			throw new QueryEngineException( $ex->getMessage(), 0, $ex );
		}
	}

	private function deleteSnakRow( EntityId $subjectId ) {
		$this->connection->delete(
			$this->tableName,
			array( 'subject_id' => $subjectId->getSerialization() )
		);
	}

}