EntityInserter::insertEntity() - Code Metrics - wmde/WikibaseQueryEngine - Measure and Improve Code Quality continuously with Scrutinizer

EntityInserter::insertEntity() A
last analyzed 2018-05-10 18:41 UTC

↳ Parent: EntityInserter

Complexity

Conditions	2
Paths	2

Size

Total Lines	15
Code Lines	9

Duplication

Lines	0
Ratio	0 %

Importance

Changes

Metric	Value
dl	0
loc	15
rs	9.4285
c	0
b	0
f	0
cc	2
eloc	9
nc	2
nop	1

<?php

namespace Wikibase\QueryEngine\SQLStore\EntityStore;

use Doctrine\DBAL\Connection;
use Wikibase\DataModel\Entity\EntityDocument;
use Wikibase\QueryEngine\QueryEngineException;

/**
 * @author Jeroen De Dauw < [email protected] >
 */
class EntityInserter {

	private $connection;
	private $entityInserters;

	/**
	 * @param Connection $connection
	 * @param EntityInsertionStrategy[] $entityInserters
	 */
	public function __construct( Connection $connection, array $entityInserters ) {
		$this->connection = $connection;
		$this->entityInserters = $entityInserters;
	}

	public function insertEntity( EntityDocument $entity ) {
		$inserter = $this->getEntityInserterFor( $entity );

		$this->connection->beginTransaction();

		try {
			$inserter->insertEntity( $entity );
		}
		catch ( QueryEngineException $ex ) {
			$this->connection->rollBack();
			throw $ex;
		}

		$this->connection->commit();
	}

	/**
	 * @param EntityDocument $entity
	 * @return EntityInsertionStrategy
	 * @throws QueryEngineException
	 */
	private function getEntityInserterFor( EntityDocument $entity ) {
		foreach ( $this->entityInserters as $entityInserter ) {
			if ( $entityInserter->canInsert( $entity ) ) {
				return $entityInserter;
			}
		}

		throw new QueryEngineException( 'There is no insertion strategy for ' . $entity->getId() );
	}

}


1			<?php
2
3			namespace Wikibase\QueryEngine\SQLStore\EntityStore;
4
5			use Doctrine\DBAL\Connection;
6			use Wikibase\DataModel\Entity\EntityDocument;
7			use Wikibase\QueryEngine\QueryEngineException;
8
9			/**
10			* @author Jeroen De Dauw < [email protected] >
11			*/
12			class EntityInserter {
13
14			private $connection;
15			private $entityInserters;
16
17			/**
18			* @param Connection $connection
19			* @param EntityInsertionStrategy[] $entityInserters
20			*/
21			public function __construct( Connection $connection, array $entityInserters ) {
22			$this->connection = $connection;
23			$this->entityInserters = $entityInserters;
24			}
25
26			public function insertEntity( EntityDocument $entity ) {
27			$inserter = $this->getEntityInserterFor( $entity );
28
29			$this->connection->beginTransaction();
30
31			try {
32			$inserter->insertEntity( $entity );
33			}
34			catch ( QueryEngineException $ex ) {
35			$this->connection->rollBack();
36			throw $ex;
37			}
38
39			$this->connection->commit();
40			}
41
42			/**
43			* @param EntityDocument $entity
44			* @return EntityInsertionStrategy
45			* @throws QueryEngineException
46			*/
47			private function getEntityInserterFor( EntityDocument $entity ) {
48			foreach ( $this->entityInserters as $entityInserter ) {
49			if ( $entityInserter->canInsert( $entity ) ) {
50			return $entityInserter;
51			}
52			}
53
54			throw new QueryEngineException( 'There is no insertion strategy for ' . $entity->getId() );
55			}
56
57			}
58

wmde / WikibaseQueryEngine

EntityInserter::insertEntity() A last analyzed 2018-05-10 18:41 UTC

Complexity

Size

Duplication

Importance

Duplication Side-by-Side

Filter issues like

EntityInserter::insertEntity() A
last analyzed 2018-05-10 18:41 UTC