TYPO3.ElasticSearch Query API proposal

MovieRepository.php

<?php
namespace Ttree\Medialib\Core\Domain\Repository\ElasticSearch;

/*                                                                        *
 * This script belongs to the FLOW3 package "Ttree.Medialib".             *
 *                                                                        *
 *                                                                        */

use TYPO3\Flow\Annotations as Flow;

/**
 * A repository for Movies
 *
 * @Flow\Scope("singleton")
 * @method findByProductionYear
 */
class MovieRepository extends \TYPO3\ElasticSearch\Persistence\Repository {

	const ENTITY_CLASSNAME = 'Ttree\Medialib\Core\Domain\Model\Movie';

	/**
	 * @Flow\Inject
	 * @var \TYPO3\Flow\Security\Context
	 */
	protected $securityContext;

	/**
	 * Returns a query for objects of this repository
	 *
	 * @return \TYPO3\ElasticSearch\Persistence\Query
	 * @api
	 */
	public function createQuery() {
		$query = parent::createQuery();

		$query->setOrderings(array(
			'public' => \TYPO3\Flow\Persistence\QueryInterface::ORDER_ASCENDING
		))->filter(
			$query->logicalAnd(
				$query->logicalAnd(
					$query->logicalOr(
						$query->createTermQuery($query->equals('owner', (string)$this->securityContext->getDomain())),
						$query->createTermQuery($query->equals('owner', 'production.'.(string)$this->securityContext->getDomain()))
					),
					$query->createTermQuery($query->equals('productionYear', 2004))
				),
				$query->logicalAnd(
					$query->createTermQuery($query->equals('owner', (string)$this->securityContext->getDomain())),
					$query->createTermQuery($query->equals('productionYear', 2004))
				)
			)
			);

		return $query;
	}

	/**
	 * @param string $title
	 * @return \TYPO3\Flow\Persistence\QueryResultInterface
	 */
	public function findByTitleWithSimpleQuery($title) {
		$query = $this->createQuery();

		$query->matching($query->equals('title', $title));

		return $query->execute();
	}

	/**
	 * @param string $title
	 * @return \TYPO3\Flow\Persistence\QueryResultInterface
	 */
	public function findByTitleAndDescriptionWithMultiMatchQuery($title) {
		$query = $this->createQuery();

		$query->matching($query->createMultiMatchPhraseQuery(array('title.technicalLocalTitle', 'description'), $title));

		return $query->execute();
	}

	/**
	 * @param string $title
	 * @return \TYPO3\Flow\Persistence\QueryResultInterface
	 */
	public function findByTitleWithBooleanQuery($title) {
		$query = $this->createQuery();

		$query->matching(
			$query->createBooleanQuery()
				->must(
					$query->createMatchPhrasePrefixQuery(
						$query->equals('title.technicalLocalTitle', $title)
					)
				)->should(
					$query->createTermQuery(
						$query->equals('title.technicalLocalTitle', 'Claude')
					)->setBoost(2.0)
				)->mustNot(
					$query->createMatchQuery(
						$query->equals('title.technicalLocalTitle', 'Closky')
					)
				)
		);

		return $query->execute();
	}

	/**
	 * @return \TYPO3\Flow\Persistence\QueryResultInterface
	 */
	public function findByTitleWithBoostingQuery() {
		$query = $this->createQuery();

		$query->matching(
			$query->createBoostingQuery()
				->positive(
					$query->createMatchPhraseQuery(
						$query->equals('title.technicalLocalTitle', 'Claude')
					)->setOperator('and')
				)->negative(
					$query->createMatchQuery(
						$query->equals('title.technicalLocalTitle', 'David')
					)->setOperator('and')
				)->negativeBoost(0.2)
		);

		return $query->execute();
	}

	/**
	 * @return \TYPO3\Flow\Persistence\QueryResultInterface
	 */
	public function findByTitleWithBoostingAndAdvancedPhraseQuery() {
		$query = $this->createQuery();

		$query->matching(
			$query->createBoostingQuery()
				->positive(
					$query->createMatchPhraseQuery(
						$query->equals('title.technicalLocalTitle', 'Claude')
					)->setOperator('and')
				)->negative(
					$query->createMatchPhrasePrefixQuery(
						$query->equals('title.technicalLocalTitle', 'David')
					)->setOperator('and')->setMaxExpansions(10)
				)->negativeBoost(0.2)
		);

		return $query->execute();
	}
}

?>

The patchset on Gerrit is updated with the last modification: https://review.typo3.org/#/c/20167/