View source
<?php
namespace Drupal\file\FileUsage;
use Drupal\Core\Database\Connection;
use Drupal\file\FileInterface;
class DatabaseFileUsageBackend extends FileUsageBase {
protected $connection;
protected $tableName;
public function __construct(Connection $connection, $table = 'file_usage') {
$this->connection = $connection;
$this->tableName = $table;
}
public function add(FileInterface $file, $module, $type, $id, $count = 1) {
$this->connection
->merge($this->tableName)
->keys(array(
'fid' => $file
->id(),
'module' => $module,
'type' => $type,
'id' => $id,
))
->fields(array(
'count' => $count,
))
->expression('count', 'count + :count', array(
':count' => $count,
))
->execute();
parent::add($file, $module, $type, $id, $count);
}
public function delete(FileInterface $file, $module, $type = NULL, $id = NULL, $count = 1) {
$query = $this->connection
->delete($this->tableName)
->condition('module', $module)
->condition('fid', $file
->id());
if ($type && $id) {
$query
->condition('type', $type)
->condition('id', $id);
}
if ($count) {
$query
->condition('count', $count, '<=');
}
$result = $query
->execute();
if (!$result && $count > 0) {
$query = $this->connection
->update($this->tableName)
->condition('module', $module)
->condition('fid', $file
->id());
if ($type && $id) {
$query
->condition('type', $type)
->condition('id', $id);
}
$query
->expression('count', 'count - :count', array(
':count' => $count,
));
$query
->execute();
}
parent::delete($file, $module, $type, $id, $count);
}
public function listUsage(FileInterface $file) {
$result = $this->connection
->select($this->tableName, 'f')
->fields('f', array(
'module',
'type',
'id',
'count',
))
->condition('fid', $file
->id())
->condition('count', 0, '>')
->execute();
$references = array();
foreach ($result as $usage) {
$references[$usage->module][$usage->type][$usage->id] = $usage->count;
}
return $references;
}
}