MetadataTable.php

Go to the documentation of this file.

<?php

namespace Elgg\Database;

use Elgg\Cache\MetadataCache;
use Elgg\Database;
use Elgg\Database\Clauses\MetadataWhereClause;
use Elgg\EventsService as Events;
use Elgg\TimeUsing;
use ElggMetadata;
use Elgg\Database\Clauses\OrderByClause;

class MetadataTable {

    use TimeUsing;

    protected $metadata_cache;

    protected $db;

    protected $events;

    protected $tag_names = [];

    const MYSQL_TEXT_BYTE_LIMIT = 65535;

    public function __construct(
        MetadataCache $metadata_cache,
        Database $db,
        Events $events
    ) {
        $this->metadata_cache = $metadata_cache;
        $this->db = $db;
        $this->events = $events;
    }

    public function registerTagName($name) {
        if (!in_array($name, $this->tag_names)) {
            $this->tag_names[] = $name;
        }

        return true;
    }

    public function unregisterTagName($name) {
        $index = array_search($name, $this->tag_names);
        if ($index >= 0) {
            unset($this->tag_names[$index]);

            return true;
        }

        return false;
    }

    public function getTagNames() {
        return $this->tag_names;
    }

    public function getTags(array $options = []) {
        $defaults = [
            'threshold' => 1,
            'tag_names' => [],
        ];

        $options = array_merge($defaults, $options);

        $singulars = ['tag_name'];
        $options = LegacyQueryOptionsAdapter::normalizePluralOptions($options, $singulars);

        $tag_names = elgg_extract('tag_names', $options);
        if (empty($tag_names)) {
            $tag_names = elgg_get_registered_tag_metadata_names();
        }

        $threshold = elgg_extract('threshold', $options, 1, false);

        unset($options['tag_names']);
        unset($options['threshold']);
        
        // custom selects
        $options['selects'] = [
            function(QueryBuilder $qb, $main_alias) {
                return "{$main_alias}.value AS tag";
            },
            function(QueryBuilder $qb, $main_alias) {
                return "COUNT({$main_alias}.id) AS total";
            },
        ];
        
        // additional wheres
        $wheres = (array) elgg_extract('wheres', $options, []);
        $wheres[] = function(QueryBuilder $qb, $main_alias) use ($tag_names) {
            return $qb->compare("{$main_alias}.name", 'in', $tag_names, ELGG_VALUE_STRING);
        };
        $wheres[] = function(QueryBuilder $qb, $main_alias) {
            return $qb->compare("{$main_alias}.value", '!=', '', ELGG_VALUE_STRING);
        };
        $options['wheres'] = $wheres;
        
        // custom group by
        $options['group_by'] = [
            function(QueryBuilder $qb, $main_alias) {
                return "{$main_alias}.value";
            },
        ];
        
        // having
        $having = (array) elgg_extract('having', $options, []);
        $having[] = function(QueryBuilder $qb, $main_alias) use ($threshold) {
            return $qb->compare('total', '>=', $threshold, ELGG_VALUE_INTEGER);
        };
        $options['having'] = $having;
        
        // order by
        $options['order_by'] = [
            new OrderByClause('total', 'desc'),
        ];
        
        // custom callback
        $options['callback'] = function($row) {
            $result = new \stdClass();
            $result->tag = $row->tag;
            $result->total = (int) $row->total;
            
            return $result;
        };
        
        return $this->getAll($options);
    }

    public function get($id) {
        $qb = Select::fromTable('metadata');
        $qb->select('*');

        $where = new MetadataWhereClause();
        $where->ids = $id;
        $qb->addClause($where);

        $row = $this->db->getDataRow($qb);
        if (!empty($row)) {
            return new ElggMetadata($row);
        }

        return false;
    }

    public function delete(ElggMetadata $metadata) {
        if (!$metadata->id) {
            return false;
        }

        if (!_elgg_services()->events->trigger('delete', 'metadata', $metadata)) {
            return false;
        }

        $qb = Delete::fromTable('metadata');
        $qb->where($qb->compare('id', '=', $metadata->id, ELGG_VALUE_INTEGER));

        $deleted = $this->db->deleteData($qb);

        if ($deleted) {
            $this->metadata_cache->clear($metadata->entity_guid);
        }

        return $deleted !== false;
    }

    public function create(ElggMetadata $metadata, $allow_multiple = false) {
        if (!isset($metadata->value) || !isset($metadata->entity_guid)) {
            elgg_log("Metadata must have a value and entity guid", 'ERROR');
            return false;
        }

        if (!is_scalar($metadata->value)) {
            elgg_log("To set multiple metadata values use ElggEntity::setMetadata", 'ERROR');
            return false;
        }

        if ($metadata->id) {
            if ($this->update($metadata)) {
                return $metadata->id;
            }
        }

        if (strlen($metadata->value) > self::MYSQL_TEXT_BYTE_LIMIT) {
            elgg_log("Metadata '{$metadata->name}' is above the MySQL TEXT size limit and may be truncated.", 'WARNING');
        }

        if (!$allow_multiple) {
            $id = $this->getIdsByName($metadata->entity_guid, $metadata->name);

            if (is_array($id)) {
                throw new \LogicException("
                    Multiple '{$metadata->name}' metadata values exist for entity [guid: {$metadata->entity_guid}].
                    Use ElggEntity::setMetadata()
                ");
            }

            if ($id > 0) {
                $metadata->id = $id;

                if ($this->update($metadata)) {
                    return $metadata->id;
                }
            }
        }

        if (!$this->events->triggerBefore('create', 'metadata', $metadata)) {
            return false;
        }

        $time_created = $this->getCurrentTime()->getTimestamp();

        $qb = Insert::intoTable('metadata');
        $qb->values([
            'name' => $qb->param($metadata->name, ELGG_VALUE_STRING),
            'entity_guid' => $qb->param($metadata->entity_guid, ELGG_VALUE_INTEGER),
            'value' => $qb->param($metadata->value, $metadata->value_type === 'integer' ? ELGG_VALUE_INTEGER : ELGG_VALUE_STRING),
            'value_type' => $qb->param($metadata->value_type, ELGG_VALUE_STRING),
            'time_created' => $qb->param($time_created, ELGG_VALUE_INTEGER),
        ]);

        $id = $this->db->insertData($qb);

        if ($id === false) {
            return false;
        }

        $metadata->id = (int) $id;
        $metadata->time_created = $time_created;

        if ($this->events->trigger('create', 'metadata', $metadata)) {
            $this->metadata_cache->clear($metadata->entity_guid);

            $this->events->triggerAfter('create', 'metadata', $metadata);

            return $id;
        } else {
            $this->delete($metadata);

            return false;
        }
    }

    public function update(ElggMetadata $metadata) {

        if (!$this->events->triggerBefore('update', 'metadata', $metadata)) {
            return false;
        }

        if (strlen($metadata->value) > self::MYSQL_TEXT_BYTE_LIMIT) {
            elgg_log("Metadata '{$metadata->name}' is above the MySQL TEXT size limit and may be truncated.", 'WARNING');
        }

        $qb = Update::table('metadata');
        $qb->set('name', $qb->param($metadata->name, ELGG_VALUE_STRING))
            ->set('value', $qb->param($metadata->value, $metadata->value_type === 'integer' ? ELGG_VALUE_INTEGER : ELGG_VALUE_STRING))
            ->set('value_type', $qb->param($metadata->value_type, ELGG_VALUE_STRING))
            ->where($qb->compare('id', '=', $metadata->id, ELGG_VALUE_INTEGER));

        $result = $this->db->updateData($qb);

        if ($result === false) {
            return false;
        }

        $this->metadata_cache->clear($metadata->entity_guid);

        $this->events->trigger('update', 'metadata', $metadata);
        $this->events->triggerAfter('update', 'metadata', $metadata);

        return true;
    }

    public function getAll(array $options = []) {

        $options['metastring_type'] = 'metadata';
        $options = LegacyQueryOptionsAdapter::normalizeMetastringOptions($options);

        return Metadata::find($options);
    }

    public function getRowsForGuids(array $guids) {

        $qb = Select::fromTable('metadata');
        $qb->select('*')
            ->where($qb->compare('entity_guid', 'IN', $guids, ELGG_VALUE_GUID))
            ->orderBy('entity_guid', 'asc')
            ->orderBy('time_created', 'asc')
            ->orderBy('id', 'asc');
        
        return $qb->execute()->fetchAll();
    }

    public function deleteAll(array $options) {
        if (!_elgg_is_valid_options_for_batch_operation($options, 'metadata')) {
            return false;
        }

        // This moved last in case an object's constructor sets metadata. Currently the batch
        // delete process has to create the entity to delete its metadata. See #5214
        $this->metadata_cache->invalidateByOptions($options);

        $options['batch'] = true;
        $options['batch_size'] = 50;
        $options['batch_inc_offset'] = false;

        $metadata = Metadata::find($options);
        $count = $metadata->count();

        if (!$count) {
            return;
        }

        $success = 0;
        /* @var $md \ElggMetadata */
        foreach ($metadata as $md) {
            if ($md->delete()) {
                $success++;
            }
        }

        return $success == $count;
    }

    public function getIdsByName($entity_guid, $name) {
        if ($this->metadata_cache->isLoaded($entity_guid)) {
            $ids = $this->metadata_cache->getSingleId($entity_guid, $name);
        } else {
            $qb = Select::fromTable('metadata');
            $qb->select('id')
                ->where($qb->compare('entity_guid', '=', $entity_guid, ELGG_VALUE_INTEGER))
                ->andWhere($qb->compare('name', '=', $name, ELGG_VALUE_STRING));

            $callback = function (\stdClass $row) {
                return (int) $row->id;
            };

            $ids = $this->db->getData($qb, $callback);
        }

        if (empty($ids)) {
            return null;
        }

        if (is_array($ids) && count($ids) === 1) {
            return array_shift($ids);
        }

        return $ids;
    }
}