basedatabase.php

См. документацию.

<?php
 
namespace Bitrix\Perfmon;
 
class BaseDatabase
{
    protected $connection = null;
    protected $schema = null;
 
    public function __construct($connection)
    {
        $this->connection = $connection;
        $this->schema = new \Bitrix\Perfmon\Sql\Schema;
    }

    public static function createFromConnection($connection)
    {
        if (is_a($connection, '\Bitrix\Main\DB\MysqliConnection'))
        {
            return new MysqliDatabase($connection);
        }
        elseif (is_a($connection, '\Bitrix\Main\DB\PgsqlConnection'))
        {
            return new PgsqlDatabase($connection);
        }
        else
        {
            throw new \Bitrix\Main\DB\ConnectionException('Unsupported connection type.');
        }
    }

    public function getTables($full = true)
    {
        $result = new \CDBResult();
        $result->InitFromArray([]);
 
        return $result;
    }

    protected function fillTableIndexes($tableName)
    {
        $table = $this->schema->tables->search($tableName);
        if (!$table)
        {
            $table = new \Bitrix\Perfmon\Sql\Table($tableName);
            $this->schema->tables->add($table);
        }
 
        return $table;
    }

    public function getIndexes($tableName)
    {
        $result = [];
 
        $table = $this->fillTableIndexes($tableName);
        foreach ($table->indexes->getList() as $index)
        {
            $result[$index->name] = $index->columns;
        }
 
        return $result;
    }

    public function getUniqueIndexes($tableName)
    {
        $result = [];
 
        $table = $this->fillTableIndexes($tableName);
        foreach ($table->indexes->getList() as $index)
        {
            if ($index->unique)
            {
                $result[$index->name] = $index->columns;
            }
        }
 
        return $result;
    }

    public function getFullTextIndexes($tableName)
    {
        $result = [];
 
        $table = $this->fillTableIndexes($tableName);
        foreach ($table->indexes->getList() as $index)
        {
            if ($index->fulltext)
            {
                $result[$index->name] = $index->columns;
            }
        }
 
        return $result;
    }

    public function getTableFields($tableName = false)
    {
        return [];
    }
}