library\search\indexer\TermFieldLengthNorm

Complexity

Total Complexity

9

Size/Duplication

Total Lines	71
Duplicated Lines	21.13 %

Coupling/Cohesion

Components	1
Dependencies	0

Importance

Changes	2
Bugs	0	Features	0

3 Methods

Rating	Name	Duplication	Size	Complexity
A	executeUpdateTermNorm()	5	11	2
A	__construct()	0	4	1
B	execute()	10	36	6

<?php
/**
 * User: jensk
 * Date: 1-3-2017
 * Time: 13:21
 */

namespace library\search\indexer;
use library\search\Indexer;


/**
 * Class TermFieldLengthNorm
 * Formula = norm(d) = 1 / √numTerms
 *
 * @package library\search\indexer
 */
class TermFieldLengthNorm
{
	/**
	 * @var \PDO
	 */
	protected $dbHandle;

	/**
	 * TermFieldLengthNorm constructor.
	 *
	 * @param \PDO $dbHandle
	 */
	public function __construct($dbHandle)
	{
		$this->dbHandle = $dbHandle;
	}

	public function execute()
	{
		$db = $this->dbHandle;
		$db->sqliteCreateFunction('sqrt', 'sqrt', 1);
		$sql = '
		SELECT documentPath, field, COUNT(`count`) as termCount
		  FROM term_count
	  GROUP BY documentPath, field
		';
		$stmt = $db->prepare($sql);
		if ($stmt === false) {

This code seems to be duplicated across your project.

			$errorInfo = $db->errorInfo();
			$errorMsg = $errorInfo[2];
			throw new \Exception('SQLite Exception: ' . $errorMsg . ' in SQL: <br /><pre>' . $sql . '</pre>');
		}
		if (($stmt->execute()) === false) {

This code seems to be duplicated across your project.

			$errorInfo = $db->errorInfo();
			$errorMsg = $errorInfo[2];
			throw new \Exception('SQLite Exception: ' . $errorMsg . ' in SQL: <br /><pre>' . $sql . '</pre>');
		}
		$uniqueFieldsPerDocument = $stmt->fetchAll(\PDO::FETCH_OBJ);
		$values = array();
		$i = 0;
		foreach ($uniqueFieldsPerDocument as $fieldRow) {
			$values[] = 'UPDATE term_frequency SET termNorm = 1/sqrt(' . intval($fieldRow->termCount) . ') WHERE documentPath = ' . $db->quote($fieldRow->documentPath) . ' AND field = ' . $db->quote($fieldRow->field) . ';';
			$i += 1;
			if ($i >= Indexer::SQLITE_MAX_COMPOUND_SELECT) {
				$this->executeUpdateTermNorm($values, $db);
				$values = array();
				$i = 0;
			}
		}
		if (count($values) != 0) {
			$this->executeUpdateTermNorm($values, $db);
		}
	}

	/**
	 * @param array $values
	 * @param \PDO $db
	 * @throws \Exception
	 */
	private function executeUpdateTermNorm($values, $db)
	{
		$sql  = 'BEGIN TRANSACTION;' . PHP_EOL;
		$sql .= implode(PHP_EOL, $values) . PHP_EOL;
		$sql .= 'COMMIT;';
		if (($db->exec($sql)) === false) {

This code seems to be duplicated across your project.

			$errorInfo = $db->errorInfo();
			$errorMsg = $errorInfo[2];
			throw new \Exception('SQLite Exception: ' . $errorMsg . ' in SQL: <br /><pre>' . $sql . '</pre>');
		}
	}
}