Maslosoft Manganel API

Namespaces

• Maslosoft
  • Manganel
    • Adapters
      • Finder
    • Annotations
    • Decorators
      • QueryBuilder
        • Operators
        • QueryString
    • Exceptions
    • Filters
    • Helpers
      • Debug
    • Interfaces
      • QueryBuilder
    • Meta
    • Options
    • Sanitizers
    • Signals
    • Traits

Classes

• ElasticSearchAdapter
• ElasticSearchCursor

  1   2   3   4   5   6   7   8   9  10  11  12  13  14  15  16  17  18  19  20  21  22  23  24  25  26  27  28  29  30  31  32  33  34  35  36  37  38  39  40  41  42  43  44  45  46  47  48  49  50  51  52  53  54  55  56  57  58  59  60  61  62  63  64  65  66  67  68  69  70  71  72  73  74  75  76  77  78  79  80  81  82  83  84  85  86  87  88  89  90  91  92  93  94  95  96  97  98  99 100 101 102 103 

<?php

/**
 * This software package is licensed under `AGPL, Commercial` license[s].
 *
 * @package maslosoft/manganel
 * @license AGPL, Commercial
 *
 * @copyright Copyright (c) Peter Maselkowski <pmaselkowski@gmail.com>
 * @link https://maslosoft.com/manganel/
 */

namespace Maslosoft\Manganel\Adapters\Finder;

use Maslosoft\Mangan\Interfaces\Adapters\FinderAdapterInterface;
use Maslosoft\Mangan\Interfaces\CriteriaInterface;
use Maslosoft\Mangan\Interfaces\ModelAwareInterface;
use Maslosoft\Manganel\QueryBuilder;
use Maslosoft\Manganel\SearchCriteria;

/**
 * ElasticSearchAdapter
 *
 * @author Piotr Maselkowski <pmaselkowski at gmail.com>
 */
class ElasticSearchAdapter implements FinderAdapterInterface
{

    /**
     *
     * @var QueryBuilder
     */
    private $qb = null;
    private $models = [];

    public function __construct($models)
    {
        $this->qb = new QueryBuilder();
        $this->qb->setModels($models);
        $this->models = $models;
    }

    public function count(CriteriaInterface $criteria)
    {
        $this->ensure($criteria);
        return $this->qb->setCriteria($criteria)->count();
    }

    public function findMany(CriteriaInterface $criteria, $fields = array())
    {
        $this->prepare($criteria, $fields);
        return new ElasticSearchCursor($this->qb);
    }

    public function findOne(CriteriaInterface $criteria, $fields = array())
    {
        $this->prepare($criteria, $fields);
        $data = (new ElasticSearchCursor($this->qb))->current();
        if (false === $data)
        {
            return null;
        }
        return $data;
    }

    /**
     *
     * @internal Used for debugging purposes, should not be used for any manipulations!
     * @return QueryBuilder
     */
    public function getQueryBuilder()
    {
        return $this->qb;
    }

    private function prepare(CriteriaInterface $criteria, $fields)
    {
        $this->ensure($criteria);
        assert($criteria instanceof SearchCriteria);

        $this->qb->setCriteria($criteria);
        if (!empty($fields))
        {
            $selected = array_flip($fields);
            foreach ($selected as $index => $value)
            {
                $selected[$index] = true;
            }
            $this->qb->getCriteria()->select($fields);
        }
    }

    private function ensure(&$criteria)
    {
        if (!$criteria instanceof SearchCriteria)
        {
            $criteria = new SearchCriteria($criteria);
        }
        $criteria->setModels($this->models);
    }

}