class.ilLSPostConditionDB.php

Go to the documentation of this file.

<?php
 
declare(strict_types=1);
 
class ilLSPostConditionDB
{
    public const TABLE_NAME = 'post_conditions';
    public const STD_ALWAYS_OPERATOR = 'always';
 
    protected ilDBInterface $db;
 
    public function __construct(ilDBInterface $db)
    {
        $this->db = $db;
    }
 
    public function select(array $ref_ids): array
    {
        if ($ref_ids === []) {
            return [];
        }
 
        $data = [];
        $query =
              "SELECT ref_id, condition_operator, value" . PHP_EOL
            . "FROM " . static::TABLE_NAME . PHP_EOL
            . "WHERE ref_id IN (" . implode(',', $ref_ids) . ")" . PHP_EOL
        ;
 
        $result = $this->db->query($query);
 
        while ($row = $this->db->fetchAssoc($result)) {
            $data[$row['ref_id']] = [$row['condition_operator'], $row['value']];
        }
 
        $conditions = [];
        foreach ($ref_ids as $ref_id) {
            //always-condition, standard
            $op = self::STD_ALWAYS_OPERATOR;
            $value = null;
 
            //if from db: proper values
            if (array_key_exists($ref_id, $data)) {
                list($op, $value) = $data[$ref_id];
            }
            $conditions[] = new \ilLSPostCondition($ref_id, $op, $value);
        }
        return $conditions;
    }
 
    public function delete(array $ref_ids, ?ilDBInterface $db = null): void
    {
        if ($ref_ids === []) {
            return;
        }
 
        if (is_null($db)) {
            $db = $this->db;
        }
 
        $query =
              "DELETE FROM " . static::TABLE_NAME . PHP_EOL
            . "WHERE ref_id IN (" . implode(',', $ref_ids) . ")" . PHP_EOL
        ;
 
        $db->manipulate($query);
    }
 
    protected function insert(array $ls_post_conditions, ilDBInterface $db): void
    {
        foreach ($ls_post_conditions as $condition) {
            $values = [
                "ref_id" => ["integer", $condition->getRefId()],
                "condition_operator" => ["text", $condition->getConditionOperator()],
                "value" => ["text", $condition->getValue()]
            ];
            $db->insert(static::TABLE_NAME, $values);
        }
    }
 
    public function upsert(array $ls_post_conditions): void
    {
        if ($ls_post_conditions === []) {
            return;
        }
 
        $ref_ids = array_map(
            fn (ilLSPostCondition $condition) => $condition->getRefId(),
            $ls_post_conditions
        );
 
        $ilAtomQuery = $this->db->buildAtomQuery();
        $ilAtomQuery->addTableLock(static::TABLE_NAME);
        $ilAtomQuery->addQueryCallable(
            function (ilDBInterface $db) use ($ref_ids, $ls_post_conditions): void {
                $this->delete($ref_ids, $db);
                $this->insert($ls_post_conditions, $db);
            }
        );
        $ilAtomQuery->run();
    }
}