View source
<?php
namespace Drupal\view_custom_table\Form;
use Drupal\Component\Utility\UrlHelper;
use Drupal\Core\Form\FormBase;
use Drupal\Core\Form\FormStateInterface;
use Drupal\Core\Url;
use Drupal\Core\Session\AccountProxy;
use Symfony\Component\DependencyInjection\ContainerInterface;
use Drupal\Core\Database\Database;
use Drupal\Core\Entity\EntityTypeManager;
use Drupal\Core\Config\ImmutableConfig;
use Drupal\Core\Config\Config;
use Drupal\Component\Render\FormattableMarkup;
class AddViewsCustomTable extends FormBase {
protected $step;
protected $PreviousStepData;
protected $entityManager;
protected $account;
protected $config;
protected $configEditable;
public function __construct(AccountProxy $account, EntityTypeManager $entityManager, ImmutableConfig $config, Config $configEditable) {
$this->step = 1;
$this->PreviousStepData = [];
$this->account = $account;
$this->entityManager = $entityManager;
$this->config = $config;
$this->configEditable = $configEditable;
}
public static function create(ContainerInterface $container) {
return new static($container
->get('current_user'), $container
->get('entity_type.manager'), $container
->get('config.factory')
->get('view_custom_table.tables'), $container
->get('config.factory')
->getEditable('view_custom_table.tables'));
}
public function getFormId() {
return 'view_custom_table_add_table_form';
}
public function buildForm(array $form, FormStateInterface $form_state) {
if ($this->step == 1) {
$all_database_connections = Database::getAllConnectionInfo();
foreach ($all_database_connections as $connection_name => $connection) {
$displyName = $connection['default']['database'];
$databaseOptions[$connection_name] = $displyName;
}
$form['table_database'] = [
'#type' => 'select',
'#options' => $databaseOptions,
'#title' => $this
->t('Database'),
];
$form['table_name'] = [
'#type' => 'textfield',
'#title' => $this
->t('Table'),
'#required' => TRUE,
];
$form['description'] = [
'#type' => 'textarea',
'#title' => $this
->t('Description'),
'#rows' => 5,
'#description' => $this
->t('Maximum 255 letters are allowed.'),
];
$form['actions'] = [
'#type' => 'actions',
];
$form['actions']['next'] = [
'#type' => 'submit',
'#value' => $this
->t('Next'),
];
}
elseif ($this->step == 2) {
$table_name = $this->PreviousStepData['table_name'];
$databaseName = $this->PreviousStepData['table_database'];
$form['columns'] = [
'#type' => 'fieldset',
'#title' => $this
->t('"@table" Int Type Columns', [
'@table' => $table_name,
]),
'#tree' => TRUE,
];
$entities['none'] = $this
->t('None');
if ($databaseName == 'default') {
$all_entities = $this->entityManager
->getDefinitions();
foreach ($all_entities as $entity_name => $entity) {
if ($entity
->getBaseTable()) {
$entities[$entity_name] = $entity
->getLabel()
->render();
}
}
}
$all_custom_tables = $this->config
->getRawData();
if (!empty($all_custom_tables)) {
foreach ($all_custom_tables as $custom_table) {
if ($custom_table['table_database'] == $databaseName && $custom_table['table_name'] != $table_name) {
$entities[$custom_table->table_name] = $custom_table->table_name;
}
}
}
$int_types = [
'tinyint',
'smallint',
'mediumint',
'int',
'bigint',
];
$text_query = new FormattableMarkup('DESCRIBE @table_name', [
'@table_name' => $table_name,
]);
$connection = Database::getConnection('default', $databaseName);
$query = $connection
->query($text_query);
foreach ($query as $row) {
$row_type = explode('(', $row->Type);
if (in_array($row_type[0], $int_types)) {
$form['columns']['column_' . $row->Field] = [
'#type' => 'fieldset',
'#title' => $this
->t('Relation of "@field_name" with', [
'@field_name' => ucfirst($row->Field),
]),
'#tree' => TRUE,
'#attributes' => [
'class' => [
'container-inline',
],
],
];
$form['columns']['column_' . $row->Field]['entity'] = [
'#type' => 'select',
'#title' => $this
->t('Entity'),
'#options' => $entities,
];
$form['columns']['column_' . $row->Field]['field'] = [
'#type' => 'hidden',
'#value' => $row->Field,
];
}
}
$form['actions']['submit'] = [
'#type' => 'submit',
'#value' => $this
->t('Save'),
];
}
$form['actions']['cancel'] = [
'#type' => 'link',
'#title' => $this
->t('Cancel'),
'#url' => $this
->buildCancelLinkUrl(),
];
return $form;
}
public function validateForm(array &$form, FormStateInterface $form_state) {
if ($this->step == 1) {
$databaseName = $form_state
->getValue('table_database');
$table_name = $form_state
->getValue('table_name');
$description = $form_state
->getValue('description');
$connection = Database::getConnection('default', $databaseName);
if (!$connection
->schema()
->tableExists($table_name)) {
$form_state
->setErrorByName('table_name', $this
->t('@table not found in database @database_name, please check table name, and database again.', [
'@table' => $table_name,
'@database_name' => $databaseName,
]));
}
$config = $this->config
->getRawData();
if (isset($config[$table_name]) && $config[$table_name]['table_database'] == $databaseName) {
$form_state
->setErrorByName('table_name', $this
->t("@table is already available for views. If you can't find it, please clear cache and try again.", [
'@table' => $table_name,
]));
}
if (strlen($description) > 254) {
$form_state
->setErrorByName('description', $this
->t("Description can not be more then 255 letters. Please update it and try again.", [
'@table' => $table_name,
]));
}
}
}
public function submitForm(array &$form, FormStateInterface $form_state) {
$opeation = $form_state
->getValue('op')
->render();
if ($opeation == $this
->t('Next')) {
$this->PreviousStepData = $form_state
->cleanValues()
->getValues();
$form_state
->setRebuild();
$this->step++;
}
if ($opeation == $this
->t('Save')) {
$user = $this->account;
$table_name = $this->PreviousStepData['table_name'];
$table_database = $this->PreviousStepData['table_database'];
$description = $this->PreviousStepData['description'];
$relations = $form_state
->getValue('columns');
$column_relations = [];
foreach ($relations as $relation) {
if ($relation['entity'] != 'none') {
$column_relations[$relation['field']] = $relation['entity'];
}
}
$serialize_relations = serialize($column_relations);
$this->configEditable
->set($table_name . '.table_name', $table_name)
->set($table_name . '.table_database', $table_database)
->set($table_name . '.description', $description)
->set($table_name . '.column_relations', $serialize_relations)
->set($table_name . '.created_by', $user
->id());
$result = $this->configEditable
->save();
if ($result) {
\Drupal::messenger()
->addStatus($this
->t('@table is added to views. Please clear cache to see changes.', [
'@table' => $table_name,
]));
}
else {
\Drupal::messenger()
->addError($this
->t('Could not add table to views, please check log messages for error.'));
}
}
$form_state
->setRedirect('view_custom_table.customtable');
}
private function buildCancelLinkUrl() {
$query = $this
->getRequest()->query;
if ($query
->has('destination')) {
$options = UrlHelper::parse($query
->get('destination'));
$url = Url::fromUri('internal:/' . $options['path'], $options);
}
else {
$url = Url::fromRoute('view_custom_table.customtable');
}
return $url;
}
}