86 lines
2.5 KiB
PHP
86 lines
2.5 KiB
PHP
<?php
|
|
|
|
declare(strict_types=1);
|
|
|
|
namespace PhpMyAdmin\Tracking;
|
|
|
|
use PhpMyAdmin\Cache;
|
|
use PhpMyAdmin\ConfigStorage\Features\TrackingFeature;
|
|
use PhpMyAdmin\ConfigStorage\Relation;
|
|
use PhpMyAdmin\DatabaseInterface;
|
|
use PhpMyAdmin\Dbal\Connection;
|
|
use PhpMyAdmin\Dbal\TableName;
|
|
use PhpMyAdmin\Util;
|
|
|
|
use function array_column;
|
|
use function array_diff;
|
|
use function array_values;
|
|
use function sprintf;
|
|
|
|
class TrackingChecker
|
|
{
|
|
private TrackingFeature|null $trackingFeature;
|
|
|
|
public function __construct(
|
|
private DatabaseInterface $dbi,
|
|
Relation $relation,
|
|
) {
|
|
$this->trackingFeature = $relation->getRelationParameters()->trackingFeature;
|
|
}
|
|
|
|
/**
|
|
* Get a list of untracked tables.
|
|
* Deactivated tracked tables are not included in the list.
|
|
*
|
|
* @return array<int, string|TableName>
|
|
*/
|
|
public function getUntrackedTableNames(string $dbName): array
|
|
{
|
|
$tableList = $this->dbi->getTables($dbName, Connection::TYPE_CONTROL);
|
|
|
|
if ($this->trackingFeature === null) {
|
|
return $tableList;
|
|
}
|
|
|
|
$trackedTables = array_column($this->getTrackedTables($dbName), 'name');
|
|
|
|
return array_values(array_diff($tableList, $trackedTables));
|
|
}
|
|
|
|
/** @return TrackedTable[] */
|
|
public function getTrackedTables(string $dbName): array
|
|
{
|
|
$trackingEnabled = Cache::get(Tracker::TRACKER_ENABLED_CACHE_KEY, false);
|
|
if (! $trackingEnabled) {
|
|
return [];
|
|
}
|
|
|
|
if ($this->trackingFeature === null) {
|
|
return [];
|
|
}
|
|
|
|
$sqlQuery = sprintf(
|
|
"SELECT table_name, tracking_active
|
|
FROM (
|
|
SELECT table_name, MAX(version) version
|
|
FROM %s.%s WHERE db_name = %s AND table_name <> ''
|
|
GROUP BY table_name
|
|
) filtered_tables
|
|
JOIN %s.%s USING(table_name, version)",
|
|
Util::backquote($this->trackingFeature->database),
|
|
Util::backquote($this->trackingFeature->tracking),
|
|
$this->dbi->quoteString($dbName, Connection::TYPE_CONTROL),
|
|
Util::backquote($this->trackingFeature->database),
|
|
Util::backquote($this->trackingFeature->tracking),
|
|
);
|
|
|
|
$trackedTables = [];
|
|
foreach ($this->dbi->queryAsControlUser($sqlQuery) as $row) {
|
|
$trackedTable = new TrackedTable(TableName::fromValue($row['table_name']), (bool) $row['tracking_active']);
|
|
$trackedTables[$trackedTable->name->getName()] = $trackedTable;
|
|
}
|
|
|
|
return $trackedTables;
|
|
}
|
|
}
|
