DatabaseQueue.php

Go to the documentation of this file.

<?php

class Elgg_Queue_DatabaseQueue implements Elgg_Queue_Queue {

    protected $name;

    protected $db;

    protected $workerId;

    public function __construct($name, Elgg_Database $db) {
        $this->db = $db;
        $this->name = $this->db->sanitizeString($name);
        $this->workerId = $this->db->sanitizeString(md5(microtime() . getmypid()));
    }

    public function enqueue($item) {
        $prefix = $this->db->getTablePrefix();
        $blob = $this->db->sanitizeString(serialize($item));
        $time = time();
        $query = "INSERT INTO {$prefix}queue
            SET name = '$this->name', data = '$blob', timestamp = $time";
        return $this->db->insertData($query) !== false;
    }

    public function dequeue() {
        $prefix = $this->db->getTablePrefix();
        $update = "UPDATE {$prefix}queue
            SET worker = '$this->workerId'
            WHERE name = '$this->name' AND worker IS NULL
            ORDER BY id ASC LIMIT 1";
        $num = $this->db->updateData($update, true);
        if ($num === 1) {
            $select = "SELECT data FROM {$prefix}queue
                WHERE worker = '$this->workerId'";
            $obj = $this->db->getDataRow($select);
            if ($obj) {
                $data = unserialize($obj->data);
                $delete = "DELETE FROM {$prefix}queue
                    WHERE name = '$this->name' AND worker = '$this->workerId'";
                $this->db->deleteData($delete);
                return $data;
            }
        }

        return null;
    }

    public function clear() {
        $prefix = $this->db->getTablePrefix();
        $this->db->deleteData("DELETE FROM {$prefix}queue WHERE name = '$this->name'");
    }

    public function size() {
        $prefix = $this->db->getTablePrefix();
        $result = $this->db->getDataRow("SELECT COUNT(id) AS total FROM {$prefix}queue WHERE name = '$this->name'");
        return (int)$result->total;
    }
}