Datalist.php

Go to the documentation of this file.

<?php
namespace Elgg\Database;

use Elgg\Cache\Pool;
use Elgg\Database;
use Elgg\Logger;

class Datalist {
    
    private $cache;

    private $db;

    private $logger;

    private $table;

    public function __construct(Pool $cache, Database $db, Logger $logger, $table) {
        $this->cache = $cache;
        $this->db = $db;
        $this->logger = $logger;
        $this->table = $table;
    }
    
    function get($name) {
        $name = trim($name);
    
        // cannot store anything longer than 255 characters in db, so catch here
        if (elgg_strlen($name) > 255) {
            $this->logger->error("The name length for configuration variables cannot be greater than 255");
            return false;
        }

        return $this->cache->get($name, function() use ($name) {
            $escaped_name = $this->db->sanitizeString($name);
            $result = $this->db->getDataRow("SELECT * FROM {$this->table} WHERE name = '$escaped_name'");
            return $result ? $result->value : null;
        });
    }
    
    function set($name, $value) {
        $name = trim($name);
    
        // cannot store anything longer than 255 characters in db, so catch before we set
        if (elgg_strlen($name) > 255) {
            $this->logger->error("The name length for configuration variables cannot be greater than 255");
            return false;
        }
    
    
        $escaped_name = $this->db->sanitizeString($name);
        $escaped_value = $this->db->sanitizeString($value);
        $success = $this->db->insertData("INSERT INTO {$this->table}"
            . " SET name = '$escaped_name', value = '$escaped_value'"
            . " ON DUPLICATE KEY UPDATE value = '$escaped_value'");

        $this->cache->put($name, $value);
    
        return $success !== false;
    }
    
    function loadAll() {
        $result = $this->db->getData("SELECT * FROM {$this->table}");
        $map = array();
        if (is_array($result)) {
            foreach ($result as $row) {
                $map[$row->name] = $row->value;
                $this->cache->put($row->name, $row->value);
            }
        }

        return $map;
    }
    
    function runFunctionOnce($functionname, $timelastupdatedcheck = 0) {
        $lastupdated = $this->get($functionname);
        if ($lastupdated) {
            $lastupdated = (int) $lastupdated;
        } elseif ($lastupdated !== false) {
            $lastupdated = 0;
        } else {
            // unable to check datalist
            return false;
        }
        if (is_callable($functionname) && $lastupdated <= $timelastupdatedcheck) {
            $functionname();
            $this->set($functionname, time());
            return true;
        } else {
            return false;
        }
    }
}