Yuri Kuznetsov
467 lines
13 KiB
PHP
467 lines
13 KiB
PHP
<?php
|
|
/************************************************************************
|
|
* This file is part of EspoCRM.
|
|
*
|
|
* EspoCRM - Open Source CRM application.
|
|
* Copyright (C) 2014-2021 Yurii Kuznietsov, Taras Machyshyn, Oleksii Avramenko
|
|
* Website: https://www.espocrm.com
|
|
*
|
|
* EspoCRM is free software: you can redistribute it and/or modify
|
|
* it under the terms of the GNU General Public License as published by
|
|
* the Free Software Foundation, either version 3 of the License, or
|
|
* (at your option) any later version.
|
|
*
|
|
* EspoCRM is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
* GNU General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with EspoCRM. If not, see http://www.gnu.org/licenses/.
|
|
*
|
|
* The interactive user interfaces in modified source and object code versions
|
|
* of this program must display Appropriate Legal Notices, as required under
|
|
* Section 5 of the GNU General Public License version 3.
|
|
*
|
|
* In accordance with Section 7(b) of the GNU General Public License version 3,
|
|
* these Appropriate Legal Notices must retain the display of the "EspoCRM" word.
|
|
************************************************************************/
|
|
|
|
namespace Espo\ORM\Repository;
|
|
|
|
use Espo\ORM\Collection;
|
|
use Espo\ORM\SthCollection;
|
|
use Espo\ORM\Entity;
|
|
use Espo\ORM\EntityManager;
|
|
use Espo\ORM\Query\Select;
|
|
use Espo\ORM\Query\SelectBuilder;
|
|
use Espo\ORM\Query\Part\WhereItem;
|
|
use Espo\ORM\Query\Part\Selection;
|
|
use Espo\ORM\Query\Part\Join;
|
|
use Espo\ORM\Mapper\Mapper;
|
|
use Espo\ORM\Query\Part\Expression;
|
|
use Espo\ORM\Query\Part\Order;
|
|
use Espo\ORM\Mapper\BaseMapper;
|
|
|
|
use RuntimeException;
|
|
|
|
/**
|
|
* Builds select parameters for an RDB repository. Contains 'find' methods.
|
|
*
|
|
* @template TEntity of Entity
|
|
*/
|
|
class RDBSelectBuilder
|
|
{
|
|
private $entityManager;
|
|
|
|
private $builder;
|
|
|
|
private $repository = null;
|
|
|
|
private $returnSthCollection = false;
|
|
|
|
public function __construct(EntityManager $entityManager, string $entityType, ?Select $query = null)
|
|
{
|
|
$this->entityManager = $entityManager;
|
|
|
|
$this->repository = $this->entityManager->getRepository($entityType);
|
|
|
|
if ($query && $query->getFrom() !== $entityType) {
|
|
throw new RuntimeException("SelectBuilder: Passed query doesn't match the entity type.");
|
|
}
|
|
|
|
$this->builder = new SelectBuilder();
|
|
|
|
if ($query) {
|
|
$this->builder->clone($query);
|
|
}
|
|
|
|
if (!$query) {
|
|
$this->builder->from($entityType);
|
|
}
|
|
}
|
|
|
|
protected function getMapper(): Mapper
|
|
{
|
|
return $this->entityManager->getMapper();
|
|
}
|
|
|
|
/**
|
|
* @param ?array $params @deprecated. Omit it.
|
|
* @phpstan-return iterable<TEntity>&Collection
|
|
*
|
|
* @todo Fix phpstan-return after php7.4 to Collection<TEntity> or remove.
|
|
*/
|
|
public function find(?array $params = null): Collection
|
|
{
|
|
$query = $this->getMergedParams($params);
|
|
|
|
/** @var iterable<TEntity>&SthCollection $collection */
|
|
$collection = $this->getMapper()->select($query);
|
|
|
|
return $this->handleReturnCollection($collection);
|
|
}
|
|
|
|
/**
|
|
* @param ?array $params @deprecated
|
|
*
|
|
* @phpstan-return ?TEntity
|
|
*/
|
|
public function findOne(?array $params = null): ?Entity
|
|
{
|
|
$builder = $this;
|
|
|
|
if ($params !== null) { // @todo Remove.
|
|
$query = $this->getMergedParams($params);
|
|
$builder = $this->repository->clone($query);
|
|
}
|
|
|
|
$collection = $builder->sth()->limit(0, 1)->find();
|
|
|
|
foreach ($collection as $entity) {
|
|
return $entity;
|
|
}
|
|
|
|
return null;
|
|
}
|
|
|
|
/**
|
|
* Get a number of records.
|
|
*
|
|
* @param ?array $params @deprecated
|
|
*/
|
|
public function count(?array $params = null): int
|
|
{
|
|
if ($params) { // @todo Remove.
|
|
$query = $this->getMergedParams($params);
|
|
return $this->getMapper()->count($query);
|
|
}
|
|
|
|
$query = $this->builder->build();
|
|
|
|
return $this->getMapper()->count($query);
|
|
}
|
|
|
|
/**
|
|
* Get a max value.
|
|
*
|
|
* @return int|float
|
|
*/
|
|
public function max(string $attribute)
|
|
{
|
|
$query = $this->builder->build();
|
|
|
|
$mapper = $this->getMapper();
|
|
|
|
assert($mapper instanceof BaseMapper);
|
|
|
|
return $mapper->max($query, $attribute);
|
|
}
|
|
|
|
/**
|
|
* Get a min value.
|
|
*
|
|
* @return int|float
|
|
*/
|
|
public function min(string $attribute)
|
|
{
|
|
$query = $this->builder->build();
|
|
|
|
$mapper = $this->getMapper();
|
|
|
|
assert($mapper instanceof BaseMapper);
|
|
|
|
return $mapper->min($query, $attribute);
|
|
}
|
|
|
|
/**
|
|
* Get a sum value.
|
|
*
|
|
* @return int|float
|
|
*/
|
|
public function sum(string $attribute)
|
|
{
|
|
$query = $this->builder->build();
|
|
|
|
$mapper = $this->getMapper();
|
|
|
|
assert($mapper instanceof BaseMapper);
|
|
|
|
return $mapper->sum($query, $attribute);
|
|
}
|
|
|
|
/**
|
|
* Add JOIN.
|
|
*
|
|
* @param Join|string $target
|
|
* A relation name or table. A relation name should be in camelCase, a table in CamelCase.
|
|
* @param string|null $alias An alias.
|
|
* @param WhereItem|array|null $conditions Join conditions.
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function join($target, ?string $alias = null, $conditions = null): self
|
|
{
|
|
$this->builder->join($target, $alias, $conditions);
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Add LEFT JOIN.
|
|
*
|
|
* @param Join|string $target
|
|
* A relation name or table. A relation name should be in camelCase, a table in CamelCase.
|
|
* @param string|null $alias An alias.
|
|
* @param WhereItem|array|null $conditions Join conditions.
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function leftJoin($target, ?string $alias = null, $conditions = null): self
|
|
{
|
|
$this->builder->leftJoin($target, $alias, $conditions);
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Set DISTINCT parameter.
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function distinct(): self
|
|
{
|
|
$this->builder->distinct();
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Lock selected rows. To be used within a transaction.
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function forUpdate(): self
|
|
{
|
|
$this->builder->forUpdate();
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Set to return STH collection. Recommended for fetching large number of records.
|
|
*
|
|
* @todo Remove.
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function sth(): self
|
|
{
|
|
$this->returnSthCollection = true;
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Add a WHERE clause.
|
|
*
|
|
* Usage options:
|
|
* * `where(WhereItem $clause)`
|
|
* * `where(array $clause)`
|
|
* * `where(string $key, string $value)`
|
|
*
|
|
* @param WhereItem|array|string $clause A key or where clause.
|
|
* @param array|string|null $value A value. Omitted if the first argument is not string.
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function where($clause = [], $value = null): self
|
|
{
|
|
$this->builder->where($clause, $value);
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Add a HAVING clause.
|
|
*
|
|
* Usage options:
|
|
* * `having(WhereItem $clause)`
|
|
* * `having(array $clause)`
|
|
* * `having(string $key, string $value)`
|
|
*
|
|
* @param WhereItem|array|string $clause A key or where clause.
|
|
* @param array|string|null $value A value. Omitted if the first argument is not string.
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function having($clause = [], $value = null): self
|
|
{
|
|
$this->builder->having($clause, $value);
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Apply ORDER. Passing an array will override previously set items.
|
|
* Passing non-array will append an item,
|
|
*
|
|
* Usage options:
|
|
* * `order(OrderExpression $expression)
|
|
* * `order([$expr1, $expr2, ...])
|
|
* * `order(string $expression, string $direction)
|
|
*
|
|
* @param Order|Order[]|Expression|string $orderBy
|
|
* An attribute to order by or an array or order items.
|
|
* Passing an array will reset a previously set order.
|
|
* @param string|bool|null $direction Select::ORDER_ASC|Select::ORDER_DESC.
|
|
*
|
|
* @phpstan-param Order|Order[]|Expression|string|array<int, string[]>|string[] $orderBy
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function order($orderBy = 'id', $direction = null): self
|
|
{
|
|
$this->builder->order($orderBy, $direction);
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Apply OFFSET and LIMIT.
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function limit(?int $offset = null, ?int $limit = null): self
|
|
{
|
|
$this->builder->limit($offset, $limit);
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Specify SELECT. Columns and expressions to be selected. If not called, then
|
|
* all entity attributes will be selected. Passing an array will reset
|
|
* previously set items. Passing a string|Expression|SelectExpression will append the item.
|
|
*
|
|
* Usage options:
|
|
* * `select([$expr1, $expr2, ...])`
|
|
* * `select([[$expr1, $alias1], [$expr2, $alias2], ...])`
|
|
* * `select([$selectItem1, $selectItem2, ...])`
|
|
* * `select(string|Expression $expression)`
|
|
* * `select(string|Expression $expression, string $alias)`
|
|
* * `select(SelectExpression $selectItem)`
|
|
*
|
|
* @param Selection|Selection[]|Expression|Expression[]|string[]|string|array<int, string[]|string> $select
|
|
* An array of expressions or one expression.
|
|
* @param string|null $alias An alias. Actual if the first parameter is a string.
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function select($select, ?string $alias = null): self
|
|
{
|
|
$this->builder->select($select, $alias);
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* Specify GROUP BY.
|
|
* Passing an array will reset previously set items.
|
|
* Passing a string|Expression will append an item.
|
|
*
|
|
* Usage options:
|
|
* * `groupBy(Expression|string $expression)`
|
|
* * `groupBy([$expr1, $expr2, ...])`
|
|
*
|
|
* @param Expression|Expression[]|string|string[] $groupBy
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function group($groupBy): self
|
|
{
|
|
$this->builder->group($groupBy);
|
|
|
|
return $this;
|
|
}
|
|
|
|
/**
|
|
* @deprecated Use `group` method.
|
|
*
|
|
* @phpstan-return RDBSelectBuilder<TEntity>
|
|
*/
|
|
public function groupBy($groupBy): self
|
|
{
|
|
return $this->group($groupBy);
|
|
}
|
|
|
|
/**
|
|
* @phpstan-return iterable<TEntity>&Collection
|
|
*
|
|
* @todo Fix phpstan-return after php7.4 to Collection<TEntity> or remove.
|
|
*/
|
|
protected function handleReturnCollection(SthCollection $collection): Collection
|
|
{
|
|
if ($this->returnSthCollection) {
|
|
return $collection;
|
|
}
|
|
|
|
return $this->entityManager->getCollectionFactory()->createFromSthCollection($collection);
|
|
}
|
|
|
|
/**
|
|
* For backward compatibility.
|
|
* @todo Remove.
|
|
*/
|
|
protected function getMergedParams(?array $params = null): Select
|
|
{
|
|
if ($params === null || empty($params)) {
|
|
return $this->builder->build();
|
|
}
|
|
|
|
$builtParams = $this->builder->build()->getRaw();
|
|
|
|
$whereClause = $builtParams['whereClause'] ?? [];
|
|
$havingClause = $builtParams['havingClause'] ?? [];
|
|
$joins = $builtParams['joins'] ?? [];
|
|
$leftJoins = $builtParams['leftJoins'] ?? [];
|
|
|
|
if (!empty($params['whereClause'])) {
|
|
unset($builtParams['whereClause']);
|
|
if (count($whereClause)) {
|
|
$params['whereClause'][] = $whereClause;
|
|
}
|
|
}
|
|
|
|
if (!empty($params['havingClause'])) {
|
|
unset($builtParams['havingClause']);
|
|
if (count($havingClause)) {
|
|
$params['havingClause'][] = $havingClause;
|
|
}
|
|
}
|
|
|
|
if (empty($params['whereClause'])) {
|
|
unset($params['whereClause']);
|
|
}
|
|
|
|
if (empty($params['havingClause'])) {
|
|
unset($params['havingClause']);
|
|
}
|
|
|
|
if (!empty($params['leftJoins']) && !empty($leftJoins)) {
|
|
foreach ($leftJoins as $j) {
|
|
$params['leftJoins'][] = $j;
|
|
}
|
|
}
|
|
|
|
if (!empty($params['joins']) && !empty($joins)) {
|
|
foreach ($joins as $j) {
|
|
$params['joins'][] = $j;
|
|
}
|
|
}
|
|
|
|
$params = array_replace_recursive($builtParams, $params);
|
|
|
|
return Select::fromRaw($params);
|
|
}
|
|
}
|