class.ilTermsOfServiceTableDatabaseDataProvider.php

Go to the documentation of this file.

<?php

declare(strict_types=1);

abstract class ilTermsOfServiceTableDatabaseDataProvider implements ilTermsOfServiceTableDataProvider
{
    protected ilDBInterface $db;

    public function __construct(ilDBInterface $db)
    {
        $this->db = $db;
    }

    abstract protected function getSelectPart(array $params, array $filter): string;

    abstract protected function getFromPart(array $params, array $filter): string;

    abstract protected function getWherePart(array $params, array $filter): string;

    abstract protected function getGroupByPart(array $params, array $filter): string;

    abstract protected function getHavingPart(array $params, array $filter): string;

    abstract protected function getOrderByPart(array $params, array $filter): string;

    public function getList(array $params, array $filter): array
    {
        $data = [
            'items' => [],
            'cnt' => 0
        ];

        $select = $this->getSelectPart($params, $filter);
        $where = $this->getWherePart($params, $filter);
        $from = $this->getFromPart($params, $filter);
        $order = $this->getOrderByPart($params, $filter);
        $group = $this->getGroupByPart($params, $filter);
        $having = $this->getHavingPart($params, $filter);

        if (isset($params['limit'])) {
            if (!is_numeric($params['limit'])) {
                throw new InvalidArgumentException('Please provide a valid numerical limit.');
            }

            if (!isset($params['offset'])) {
                $params['offset'] = 0;
            } elseif (!is_numeric($params['offset'])) {
                throw new InvalidArgumentException('Please provide a valid numerical offset.');
            }

            $this->db->setLimit($params['limit'], $params['offset']);
        }

        $where = $where !== '' ? 'WHERE ' . $where : '';
        $query = "SELECT $select FROM $from $where";

        if ($group !== '') {
            $query .= " GROUP BY $group";
        }

        if ($having !== '') {
            $query .= " HAVING $having";
        }

        if ($order !== '') {
            $query .= " ORDER BY $order";
        }

        $res = $this->db->query($query);
        while ($row = $this->db->fetchAssoc($res)) {
            $data['items'][] = $row;
        }

        if (isset($params['limit'])) {
            $cnt_sql = "SELECT COUNT(*) cnt FROM ($query) subquery";
            $row_cnt = $this->db->fetchAssoc($this->db->query($cnt_sql));
            $data['cnt'] = (int) $row_cnt['cnt'];
        }

        return $data;
    }
}