DatabaseTable.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_harvest\Storage;
 
use Drupal\Core\Database\Connection;
use Drupal\dkan_common\Storage\AbstractDatabaseTable;
 
class DatabaseTable extends AbstractDatabaseTable {
  private $identifier;
 
  public function __construct(Connection $connection, string $identifier) {
    $this->identifier = $identifier;
    $this->setOurSchema();
    parent::__construct($connection);
  }
 
  public function retrieve(string $id) {
    $result = parent::retrieve($id);
    return $result->data;
  }
 
  protected function getTableName() {
    return "harvest_{$this->identifier}";
  }
 
  protected function prepareData(string $data, string $id = NULL): array {
    return ["id" => $id, "data" => $data];
  }
 
  protected function primaryKey() {
    return "id";
  }
 
  private function setOurSchema() {
    $schema = [
      'fields' => [
        'id' => ['type' => 'varchar', 'not null' => TRUE, 'length' => 190],
        'data' => ['type' => 'text', 'length' => 65535],
      ],
      'primary key' => ['id'],
    ];
 
    $this->setSchema($schema);
  }
 
}