ResourceDBRepository.php

Go to the documentation of this file.

<?php
 
namespace ILIAS\ResourceStorage\Resource\Repository;
 
use ILIAS\ResourceStorage\Identification\ResourceIdentification;
use ILIAS\ResourceStorage\Resource\StorableFileResource;
use ILIAS\ResourceStorage\Resource\StorableResource;
 
class ResourceDBRepository implements ResourceRepository
{
    public const TABLE_NAME = 'il_resource';
    public const IDENTIFICATION = 'rid';
 
    protected array $cache = [];
    protected \ilDBInterface $db;
 
    public function __construct(\ilDBInterface $db)
    {
        $this->db = $db;
    }
 
    public function getNamesForLocking(): array
    {
        return [self::TABLE_NAME];
    }
 
    public function blank(ResourceIdentification $identification): StorableResource
    {
        return new StorableFileResource($identification);
    }
 
    public function get(ResourceIdentification $identification): StorableResource
    {
        if (isset($this->cache[$identification->serialize()])) {
            return $this->cache[$identification->serialize()];
        }
        $resource = $this->blank($identification);
 
        $q = "SELECT " . self::IDENTIFICATION . ", storage_id FROM " . self::TABLE_NAME . " WHERE " . self::IDENTIFICATION . " = %s";
        $r = $this->db->queryF($q, ['text'], [$identification->serialize()]);
        $d = $this->db->fetchObject($r);
 
        $resource->setStorageID($d->storage_id);
 
        $this->cache[$identification->serialize()] = $resource;
 
        return $resource;
    }
 
    public function has(ResourceIdentification $identification): bool
    {
        if (isset($this->cache[$identification->serialize()])) {
            return true;
        }
        $q = "SELECT " . self::IDENTIFICATION . " FROM " . self::TABLE_NAME . " WHERE " . self::IDENTIFICATION . " = %s";
        $r = $this->db->queryF($q, ['text'], [$identification->serialize()]);
 
        return (bool)$r->numRows() > 0;
    }
 
    public function store(StorableResource $resource): void
    {
        $rid = $resource->getIdentification()->serialize();
        if ($this->has($resource->getIdentification())) {
            // UPDATE
            $this->db->update(
                self::TABLE_NAME,
                [
                    self::IDENTIFICATION => ['text', $rid],
                    'storage_id' => ['text', $resource->getStorageID()],
                ],
                [
                    self::IDENTIFICATION => ['text', $rid],
                ]
            );
        } else {
            // CREATE
            $this->db->insert(
                self::TABLE_NAME,
                [
                    self::IDENTIFICATION => ['text', $rid],
                    'storage_id' => ['text', $resource->getStorageID()],
                ]
            );
        }
        $this->cache[$rid] = $resource;
    }
 
    public function delete(StorableResource $resource): void
    {
        $rid = $resource->getIdentification()->serialize();
        $this->db->manipulateF(
            "DELETE FROM " . self::TABLE_NAME . " WHERE " . self::IDENTIFICATION . " = %s",
            ['text'],
            [$rid]
        );
        unset($this->cache[$rid]);
    }
 
    public function getAll(): \Generator
    {
        yield from [];
    }
 
    public function preload(array $identification_strings): void
    {
        $r = $this->db->query(
            "SELECT rid, storage_id FROM " . self::TABLE_NAME . " WHERE "
            . $this->db->in(self::IDENTIFICATION, $identification_strings, false, 'text')
        );
        while ($d = $this->db->fetchAssoc($r)) {
            $this->populateFromArray($d);
        }
    }
 
    public function populateFromArray(array $data): void
    {
        $resource = $this->blank(new ResourceIdentification($data['rid']));
        $resource->setStorageID($data['storage_id']);
        $this->cache[$data['rid']] = $resource;
    }
}