Service.php

Go to the documentation of this file.

<?php
 
namespace Drupal\dkan_sql_endpoint;
 
use Drupal\Core\Config\ConfigFactory;
use Drupal\Core\DependencyInjection\ContainerInjectionInterface;
use Drupal\dkan_sql_endpoint\Helper\GetStringsFromStateMachineExecution;
use SqlParser\SqlParser;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Drupal\dkan_datastore\Storage\Query;
use Maquina\StateMachine\Machine;
 
class Service implements ContainerInjectionInterface {
  private $configFactory;
 
  public static function create(ContainerInterface $container) {
    return new static($container->get('config.factory'));
  }
 
  public function __construct(ConfigFactory $configFactory) {
    $this->configFactory = $configFactory;
  }
 
  public function getTableName(string $sqlString): string {
    $stateMachine = $this->validate($sqlString);
    return $this->getTableNameFromSelect($stateMachine->gsm('select'));
  }
 
  private function getTableNameFromSelect(Machine $selectMachine): string {
    $machine = $selectMachine->gsm('table_var');
    $strings = $this->getStringsFromStringMachine($machine);
    if (empty($strings)) {
      throw new \Exception("No table name");
    }
    return $strings[0];
  }
 
  public function getQueryObject(string $sqlString): Query {
    return $this->getQueryObjectFromStateMachine($this->validate($sqlString));
  }
 
  private function validate(string $sqlString): Machine {
    $parser = new SqlParser();
    if ($parser->validate($sqlString) === FALSE) {
      throw new \Exception("Invalid query string.");
    }
 
    return $parser->getValidatingMachine();
  }
 
  private function getQueryObjectFromStateMachine(Machine $state_machine): Query {
    $object = new Query();
    $this->setQueryObjectSelect($object, $state_machine->gsm('select'));
    $this->setQueryObjectWhere($object, $state_machine->gsm('where'));
    $this->setQueryObjectOrderBy($object, $state_machine->gsm('order_by'));
    $this->setQueryObjectLimit($object, $state_machine->gsm('limit'));
 
    return $object;
  }
 
  private function setQueryObjectSelect(Query $object, Machine $state_machine) {
    $strings = $this->getStringsFromStringMachine($state_machine->gsm('select_count_all'));
    if (!empty($strings)) {
      $object->count();
      return;
    }
 
    $strings = $this->getStringsFromStringMachine($state_machine->gsm('select_var_all'));
    if (!empty($strings)) {
      return;
    }
 
    $strings = $this->getStringsFromStringMachine($state_machine->gsm('select_var'));
    foreach ($strings as $property) {
      $object->filterByProperty($property);
    }
  }
 
  private function setQueryObjectWhere(Query $object, Machine $state_machine) {
    $properties = $this->getStringsFromStringMachine($state_machine->gsm('where_column'));
    $values = $this->getStringsFromStringMachine($state_machine->gsm('quoted_string')->gsm('string'));
 
    foreach ($properties as $index => $property) {
      $value = $values[$index];
      if ($value) {
        $object->conditionByIsEqualTo($property, $value);
      }
    }
  }
 
  private function setQueryObjectOrderBy(Query $object, Machine $state_machine) {
    $properties = $this->getStringsFromStringMachine($state_machine->gsm('order_var'));
 
    $direction = $this->getStringsFromStringMachine($state_machine->gsm('order_asc'));
    $sortMethod = (!empty($direction)) ? "sortByAscending" : "sortByDescending";
 
    foreach ($properties as $property) {
      $object->$sortMethod($property);
    }
  }
 
  private function setQueryObjectLimit(Query $object, Machine $state_machine) {
    $rows_limit = $this->configFactory->get('dkan_sql_endpoint.settings')->get('rows_limit');
 
    $limit = $this->getStringsFromStringMachine($state_machine->gsm('numeric1'));
    if (!empty($limit) && $limit[0] <= $rows_limit) {
      $object->limitTo($limit[0]);
    }
    elseif ($object->count == FALSE) {
      $object->limitTo($rows_limit);
    }
 
    $offset = $this->getStringsFromStringMachine($state_machine->gsm('numeric2'));
    if (!empty($offset)) {
      $object->offsetBy($offset[0]);
    }
  }
 
  private function getStringsFromStringMachine(Machine $machine): array {
    return (new GetStringsFromStateMachineExecution($machine->execution))->get();
  }
 
}