db_mysql

Complexity

Total Complexity

118

Size/Duplication

Total Lines	829
Duplicated Lines	2.53 %

Coupling/Cohesion

Components	3
Dependencies	10

Test Coverage

Coverage

0%

Importance

Changes	35
Bugs	0	Features	1

59 Methods

Rating	Name	Duplication	Size	Complexity
C	sn_db_connect()	0	29	8
A	doSelectFetchArray()	0	3	1
A	__construct()	0	5	1
A	load_db_settings()	0	9	2
A	driver_connect()	0	11	3
A	db_disconnect()	0	8	2
A	replaceTablePlaceholders()	0	10	3
A	logQuery()	0	11	2
B	traceQuery()	0	19	7
B	queryDriver()	0	30	4
A	doSql()	0	9	1
A	doSelect()	0	3	1
B	doSelectDanger()	0	19	7
A	doInsertComplex()	0	3	1
A	doInsertSet()	0	9	1
A	doInsertBatch()	0	3	1
A	doReplaceSet()	0	3	1
A	doUpdateAdjust()	0	3	1
A	doUpdateReallyComplex()	0	3	1
A	doUpdateSqlNoParam()	0	3	1
A	doUpdateDbQuery()	0	3	1
A	doUpdateDbQueryAdjust()	0	3	1
A	doUpdateWhere()	0	13	1
A	doUpdateRowSet()	0	3	1
A	doUpdateTableSet()	0	3	1
A	doUpdateRowAdjust()	0	3	1
A	doUpdateTableAdjust()	0	3	1
A	buildDeleteQuery()	0	7	1
A	doDeleteWhere()	0	7	1
A	doDeleteDanger()	0	8	1
A	doDeleteRow()	0	3	1
A	doDeleteSql()	0	3	1
A	doStmtLockAll()	0	10	1
B	security_watch_user_queries()	0	21	7
C	security_query_check_bad_words()	0	57	18
B	db_get_table_list()	0	20	5
A	db_prepare()	7	7	1
A	db_sql_query()	7	7	1
A	db_fetch()	7	7	1
A	db_fetch_row()	0	3	1
A	db_escape()	0	3	1
A	driver_disconnect()	0	3	1
A	db_error()	0	3	1
A	db_insert_id()	0	3	1
A	db_num_rows()	0	3	1
A	db_affected_rows()	0	3	1
A	db_get_client_info()	0	3	1
A	db_get_server_info()	0	3	1
A	db_get_host_info()	0	3	1
A	db_get_server_stat()	0	11	2
A	db_core_show_status()	0	13	3
A	mysql_get_table_list()	0	3	1
A	mysql_get_innodb_status()	0	3	1
A	getOperator()	0	3	1
A	getTransaction()	0	3	1
A	transactionCheck()	0	3	1
A	transactionStart()	0	3	1
A	transactionCommit()	0	3	1
A	transactionRollback()	0	3	1

<?php

use \DBAL\DbQuery;
use \DBAL\DbTransaction;

/**
 * Created by Gorlum 01.09.2015 15:58
 */
class db_mysql {
  const TRANSACTION_SERIALIZABLE = 'SERIALIZABLE';
  const TRANSACTION_REPEATABLE_READ = 'REPEATABLE READ';
  const TRANSACTION_READ_COMMITTED = 'READ COMMITTED';
  const TRANSACTION_READ_UNCOMMITTED = 'READ UNCOMMITTED';

  /**
   * Статус соеднения с MySQL
   *
   * @var bool
   */
  public $connected = false;
  /**
   * Префикс названий таблиц в БД
   *
   * @var string
   */
  public $db_prefix = '';
  /**
   * Список таблиц в БД
   *
   * @var array
   */
  public $table_list = array();

  /**
   * Настройки БД
   *
   * @var array
   */
  protected $dbsettings = array();
  /**
   * Драйвер для прямого обращения к MySQL
   *
   * @var db_mysql_v5 $driver
   */
  public $driver = null;

  /**
   * Общее время запросов
   *
   * @var float $time_mysql_total
   */
  public $time_mysql_total = 0.0;

  /**
   * Amount of queries on this DB
   *
   * @var int
   */
  public $queryCount = 0;

  public $isWatching = false;

  /**
   * @var \DBAL\DbTransaction $transaction
   */
  protected $transaction;

  /**
   * Should query check be skipped?
   *
   * Used for altering scheme of DB
   *
   * @var bool $skipQueryCheck
   */
  protected $skipQueryCheck = false;

  /**
   * @var SnCache $snCache
   */
  public $snCache;

  /**
   * @var DbRowDirectOperator $operator
   */
  protected $operator;

  /**
   * db_mysql constructor.
   *
   * @param \Common\GlobalContainer $gc
   */
  public function __construct($gc) {
    $this->transaction = new \DBAL\DbTransaction($gc, $this);
    $this->snCache = new $gc->snCacheClass($gc, $this);
    $this->operator = new DbRowDirectOperator($this);
  }

  public function load_db_settings($configFile = '') {
    $dbsettings = array();

    empty($configFile) ? $configFile = SN_ROOT_PHYSICAL . "config" . DOT_PHP_EX : false;

    require $configFile;

    $this->dbsettings = $dbsettings;
  }

  /**
   * @param null|array $external_db_settings
   *
   * @return bool
   */
  public function sn_db_connect($external_db_settings = null) {
    $this->db_disconnect();

    if (is_array($external_db_settings) && !empty($external_db_settings)) {
      $this->dbsettings = $external_db_settings;
    }

    if (empty($this->dbsettings)) {
      $this->load_db_settings(SN_ROOT_PHYSICAL . "config.php");
    }

    // TODO - фатальные (?) ошибки на каждом шагу. Хотя - скорее Эксепшны
    if (!empty($this->dbsettings)) {
      $driver_name = empty($this->dbsettings['sn_driver']) ? 'db_mysql_v5' : $this->dbsettings['sn_driver'];
      $this->driver = new $driver_name();
      $this->db_prefix = $this->dbsettings['prefix'];

      $this->connected = $this->connected || $this->driver_connect();

      if ($this->connected) {
        $this->table_list = $this->db_get_table_list();
        // TODO Проверка на пустоту
      }
    } else {
      $this->connected = false;
    }

    return $this->connected;
  }

  protected function driver_connect() {
    if (!is_object($this->driver)) {
      classSupernova::$debug->error_fatal('DB Error - No driver for MySQL found!');
    }

    if (!method_exists($this->driver, 'mysql_connect')) {
      classSupernova::$debug->error_fatal('DB Error - WRONG MySQL driver!');
    }

    return $this->driver->mysql_connect($this->dbsettings);
  }

  public function db_disconnect() {
    if ($this->connected) {
      $this->connected = !$this->driver_disconnect();
      $this->connected = false;
    }

    return !$this->connected;
  }

  /**
   * @param string $query
   *
   * @return mixed|string
   */
  public function replaceTablePlaceholders($query) {
    $sql = $query;
    if (strpos($sql, '{{') !== false) {
      foreach ($this->table_list as $tableName) {
        $sql = str_replace("{{{$tableName}}}", $this->db_prefix . $tableName, $sql);
      }
    }

    return $sql;
  }

  /**
   * @param $query
   */
  protected function logQuery($query) {
    if (!classSupernova::$config->debug) {
      return;
    }

    $this->queryCount++;
    $arr = debug_backtrace();
    $file = end(explode('/', $arr[0]['file']));

explode('/', $arr[0]['file']) cannot be passed to end() as the parameter $array expects a reference.

    $line = $arr[0]['line'];
    classSupernova::$debug->add("<tr><th>Query {$this->queryCount}: </th><th>$query</th><th>{$file} @ {$line}</th><th>&nbsp;</th></tr>");
  }


  /**
   * @return string
   */
  public function traceQuery() {
    if (!defined('DEBUG_SQL_COMMENT') || constant('DEBUG_SQL_ERROR') !== true) {
      return '';
    }

    $backtrace = debug_backtrace();
    $sql_comment = classSupernova::$debug->compact_backtrace($backtrace, defined('DEBUG_SQL_COMMENT_LONG'));

    if (defined('DEBUG_SQL_ERROR') && constant('DEBUG_SQL_ERROR') === true) {
      classSupernova::$debug->add_to_array($sql_comment);
    }

    $sql_commented = implode("\r\n", $sql_comment);
    if (defined('DEBUG_SQL_ONLINE') && constant('DEBUG_SQL_ONLINE') === true) {
      classSupernova::$debug->warning($sql_commented, 'SQL Debug', LOG_DEBUG_SQL);
    }

    return $sql_commented;
  }

  /**
   * @param string $query
   *
   * @return array|bool|mysqli_result|null
   */
  protected function queryDriver($query) {
    if (!$this->connected) {
      $this->sn_db_connect();
    }

    $stringQuery = $query;
    $stringQuery = trim($stringQuery);
    // You can't do it - 'cause you can break commented statement with line-end comments
    // $stringQuery = preg_replace("/\s+/", ' ', $stringQuery);

57% of this comment could be valid code. Did you maybe forget this after debugging?

    $this->security_watch_user_queries($stringQuery);
    $this->security_query_check_bad_words($stringQuery);
    $this->logQuery($stringQuery);

    $stringQuery = $this->replaceTablePlaceholders($stringQuery);

    $queryTrace = $this->traceQuery();

    $queryResult = null;
    try {
      $queryResult = $this->db_sql_query($stringQuery . DbSqlHelper::quoteComment($queryTrace));
      if (!$queryResult) {
        throw new Exception();
      }
    } catch (Exception $e) {
      classSupernova::$debug->error($this->db_error() . "<br />{$query}<br />", 'SQL Error');
    }

    return $queryResult;
  }


  // Just wrappers to distinguish query types
  /**
   * Executes non-data manipulation statements
   *
   * Can execute queries with check skip
   * Honor current state of query checking
   *
   * @param string $query
   * @param bool   $skip_query_check
   *
   * @return array|bool|mysqli_result|null
   */
  public function doSql($query, $skip_query_check = false) {
    $prevState = $this->skipQueryCheck;
    $this->skipQueryCheck = $skip_query_check;
    // TODO - disable watch ??
    $result = $this->queryDriver($query);
    $this->skipQueryCheck = $prevState;

    return $result;
  }


  // TODO - should be in DbRowDirectOperator eventually
  // SQL operations ====================================================================================================
  // SELECTS -----------------------------------------------------------------------------------------------------------
  public function doSelect($query) {
    return $this->doSql($query);
  }

  /**
   * DANGER! Fields and Where can be danger
   *
   * @param string $table
   * @param array  $fields
   * @param array  $where
   * @param bool   $isOneRecord
   *
   * @return array|bool|mysqli_result|null
   *
   * TODO - replace with appropriate DbQuery when it's be ready
   */
  public function doSelectDanger($table, $fields, $where = array(), $isOneRecord = DB_RECORDS_ALL, $forUpdate = DB_SELECT_PLAIN) {
    // TODO - TEMPORARY UNTIL DbQuery
    if (!empty($where)) {
      foreach ($where as $key => &$value) {
        if (!is_int($key)) {
          $value = "`$key` = '" . $this->db_escape($value) . "'";
        }
      }
    }

    $query =
      "SELECT " . implode(',', $fields) .
      " FROM `{{{$table}}}`" .
      (!empty($where) ? ' WHERE ' . implode(' AND ', $where) : '') .
      ($isOneRecord == DB_RECORD_ONE ? ' LIMIT 1' : '') .
      ($forUpdate == DB_SELECT_FOR_UPDATE ? ' FOR UPDATE' : '');

    return $this->doSql($query);
  }

  /**
   * @param string $strSql
   *
   * @return array|null
   *
   * @deprecated
   * TODO - УДАЛИТЬ
   * Метод временно находится здесь - слишком много переписывать, что бы его отсюда вынести
   */
  public function doSelectFetchArray($strSql) {
    return $this->operator->doSelectFetchArray($strSql);
  }



  //
  // INSERT/REPLACE ----------------------------------------------------------------------------------------------------
  public function doInsertComplex($query) {
    return $this->doSql($query);
  }

  // TODO - batch insert and replace here
  // перед тем, как переделывать данные из депрекейтов - убедится, что
  // null - это null, а не строка'NULL'

  /**
   * @param string        $table
   * @param array|array[] $valuesOptionallyKeyByFields
   * @param array         $fields
   *
   * @param int           $replace - DB_INSERT_PLAIN || DB_INSERT_IGNORE
   *
   * @return array|bool|mysqli_result|null TODO - избаватьися от $fields. Это поле нужно только при пакетной вставке - а поля вполне можно брать из общего массива
   * TODO - избаватьися от $fields. Это поле нужно только при пакетной вставке - а поля вполне можно брать из общего массива
   */
  public function doInsertSet($table, $valuesOptionallyKeyByFields, $fields = array(), $replace = DB_INSERT_PLAIN) {
    $query = DbQuery::build($this)
      ->setTable($table)
      ->setFields($fields)
      ->setValues($valuesOptionallyKeyByFields)
      ->insert($replace);

    return $this->doSql($query);
  }

  /**+
   * Values should be passed as array of arrays
   *
   * @param string  $table
   * @param array[] $valuesBatch
   * @param array   $fields
   *
   * @param int     $replace
   *
   * @return array|bool|mysqli_result|null
   */
  public function doInsertBatch($table, &$valuesBatch, $fields, $replace) {
    return $this->doInsertSet($table, $valuesBatch, $fields, $replace);
  }

  // Just to separate INSERTS from REPLACES
  /**
   * Replaces record in DB
   *
   * There are no DANGER replace operations
   *
   * @param string $table
   * @param array  $fieldsAndValues
   *
   * @return array|bool|mysqli_result|null
   */
  public function doReplaceSet($table, $fieldsAndValues) {
    return $this->doInsertSet($table, $fieldsAndValues, array(), DB_INSERT_REPLACE);
  }


  //
  // UPDATERS
  // Deprecated
  public function doUpdateAdjust($strSql) {
    return $this->doSql($strSql);
  }

  public function doUpdateReallyComplex($query) {
    return $this->doSql($query);
  }

  /**
   * Executes self-contained SQL UPDATE query
   *
   * Self-contained - means no params used
   * Such queries usually used to make large amount of in-base calculations
   *
   * @param $query
   *
   * @return array|bool|mysqli_result|null
   */
  public function doUpdateSqlNoParam($query) {
    return $this->doSql($query);
  }


  /**
   * @param $DbQuery DbQuery
   */
  protected function doUpdateDbQuery($DbQuery) {
    return $this->doSql($DbQuery->update());
  }

  /**
   * @param $DbQuery DbQuery
   */
  public function doUpdateDbQueryAdjust($DbQuery) {
    return $this->doUpdateDbQuery($DbQuery);
  }


  protected function doUpdateWhere($table, $fieldsSet, $fieldsAdjust = array(), $where = array(), $isOneRecord = DB_RECORDS_ALL, $whereDanger = array()) {
    $query = DbQuery::build($this)
      ->setTable($table)
      ->setValues($fieldsSet)
      ->setAdjust($fieldsAdjust)
      // TODO - separate danger WHEREs
      ->setWhereArray($where)
      ->setWhereArrayDanger($whereDanger)
      ->setOneRow($isOneRecord)
      ->update();

    return $this->doSql($query);
  }

  public function doUpdateRowSet($table, $fieldsAndValues, $where) {
    return $this->doUpdateWhere($table, $fieldsAndValues, array(), $where, DB_RECORD_ONE);
  }

  public function doUpdateTableSet($table, $fieldsAndValues, $where = array()) {
    return $this->doUpdateWhere($table, $fieldsAndValues, array(), $where, DB_RECORDS_ALL);
  }

  public function doUpdateRowAdjust($table, $fieldsSet, $fieldsAdjust, $where) {
    return $this->doUpdateWhere($table, $fieldsSet, $fieldsAdjust, $where, DB_RECORD_ONE);
  }

  public function doUpdateTableAdjust($table, $fieldsSet, $fieldsAdjust, $where, $whereDanger = array()) {
    return $this->doUpdateWhere($table, $fieldsSet, $fieldsAdjust, $where, DB_RECORDS_ALL, $whereDanger);
  }


  //
  // DELETERS ----------------------------------------------------------------------------------------------------------
  /**
   * @param string $table
   * @param array  $where
   * @param bool   $isOneRecord
   *
   * @return DbQuery
   */
  protected function buildDeleteQuery($table, $where, $isOneRecord = DB_RECORDS_ALL) {
    return
      DbQuery::build($this)
        ->setTable($table)
        ->setWhereArray($where)
        ->setOneRow($isOneRecord);
  }

  /**
   * @param string $table
   * @param array  $where - simple WHERE statement list which can be combined with AND
   * @param bool   $isOneRecord
   *
   * @return array|bool|mysqli_result|null
   */
  public function doDeleteWhere($table, $where, $isOneRecord = DB_RECORDS_ALL) {
    return
      $this->doSql(
        $this->buildDeleteQuery($table, $where, $isOneRecord)
          ->delete()
      );
  }

  /**
   * Early deprecated function for complex delete conditions
   *
   * Used for malformed $where conditions
   * Also whereDanger can contain references for other {{tables}}
   *
   * @param string $table
   * @param array  $where
   * @param array  $whereDanger
   *
   * @return array|bool|mysqli_result|null
   * @deprecated
   */
  public function doDeleteDanger($table, $where, $whereDanger) {
    return
      $this->doSql(
        $this->buildDeleteQuery($table, $where, DB_RECORDS_ALL)
          ->setWhereArrayDanger($whereDanger)
          ->delete()
      );
  }

  /**
   * @param string $table
   * @param array  $where - simple WHERE statement list which can be combined with AND
   *
   * @return array|bool|mysqli_result|null
   */
  public function doDeleteRow($table, $where) {
    return $this->doDeleteWhere($table, $where, DB_RECORD_ONE);
  }

  /**
   * Perform simple delete queries on fixed tables w/o params
   *
   * @param string $query
   *
   * @return array|bool|mysqli_result|null
   */
  public function doDeleteSql($query) {
    return $this->doSql($query);
  }


  // LOCKERS ----------------------------------------------------------------------------------------------------------
  /**
   * @param DbQueryConstructor $stmt
   * @param bool               $skip_query_check
   */
  public function doStmtLockAll($stmt, $skip_query_check = false) {
    $this->doSql(
      $stmt
        ->select()
        ->field(1)
        ->setForUpdate()
        ->__toString(),
      $skip_query_check
    );
  }


  //
  // OTHER FUNCTIONS ----------------------------------------------------------------------------------------------------------
  // TODO Заменить это на новый логгер
  protected function security_watch_user_queries($query) {
    global $user;

    if (
      !$this->isWatching // Not already watching
      && !empty(classSupernova::$config->game_watchlist_array) // There is some players in watchlist
      && in_array($user['id'], classSupernova::$config->game_watchlist_array) // Current player is in watchlist
      && !preg_match('/^(select|commit|rollback|start transaction)/i', $query) // Current query should be watched
    ) {
      $this->isWatching = true;
      $msg = "\$query = \"{$query}\"\n\r";
      if (!empty($_POST)) {
        $msg .= "\n\r" . dump($_POST, '$_POST');
      }
      if (!empty($_GET)) {
        $msg .= "\n\r" . dump($_GET, '$_GET');
      }
      classSupernova::$debug->warning($msg, "Watching user {$user['id']}", 399, array('base_dump' => true));
      $this->isWatching = false;
    }
  }


  public function security_query_check_bad_words($query) {
    if ($this->skipQueryCheck) {
      return;
    }

    global $user, $dm_change_legit, $mm_change_legit;

    switch(true) {
      case stripos($query, 'RUNCATE TABL') != false:

It seems like you are loosely comparing stripos($query, 'RUNCATE TABL') of type integer to the boolean false. If you are specifically checking for non-zero, consider using something more explicit like > 0 or !== 0 instead.

      case stripos($query, 'ROP TABL') != false:

It seems like you are loosely comparing stripos($query, 'ROP TABL') of type integer to the boolean false. If you are specifically checking for non-zero, consider using something more explicit like > 0 or !== 0 instead.

      case stripos($query, 'ENAME TABL') != false:

It seems like you are loosely comparing stripos($query, 'ENAME TABL') of type integer to the boolean false. If you are specifically checking for non-zero, consider using something more explicit like > 0 or !== 0 instead.

      case stripos($query, 'REATE DATABAS') != false:

It seems like you are loosely comparing stripos($query, 'REATE DATABAS') of type integer to the boolean false. If you are specifically checking for non-zero, consider using something more explicit like > 0 or !== 0 instead.

      case stripos($query, 'REATE TABL') != false:

It seems like you are loosely comparing stripos($query, 'REATE TABL') of type integer to the boolean false. If you are specifically checking for non-zero, consider using something more explicit like > 0 or !== 0 instead.

      case stripos($query, 'ET PASSWOR') != false:

It seems like you are loosely comparing stripos($query, 'ET PASSWOR') of type integer to the boolean false. If you are specifically checking for non-zero, consider using something more explicit like > 0 or !== 0 instead.

      case stripos($query, 'EOAD DAT') != false:

It seems like you are loosely comparing stripos($query, 'EOAD DAT') of type integer to the boolean false. If you are specifically checking for non-zero, consider using something more explicit like > 0 or !== 0 instead.

      case stripos($query, 'RPG_POINTS') != false && stripos(trim($query), 'UPDATE ') === 0 && !$dm_change_legit:

It seems like you are loosely comparing stripos($query, 'RPG_POINTS') of type integer to the boolean false. If you are specifically checking for non-zero, consider using something more explicit like > 0 or !== 0 instead.

      case stripos($query, 'METAMATTER') != false && stripos(trim($query), 'UPDATE ') === 0 && !$mm_change_legit:

It seems like you are loosely comparing stripos($query, 'METAMATTER') of type integer to the boolean false. If you are specifically checking for non-zero, consider using something more explicit like > 0 or !== 0 instead.

      case stripos($query, 'AUTHLEVEL') != false && $user['authlevel'] < 3 && stripos($query, 'SELECT') !== 0:

It seems like you are loosely comparing stripos($query, 'AUTHLEVEL') of type integer to the boolean false. If you are specifically checking for non-zero, consider using something more explicit like > 0 or !== 0 instead.

        $report = "Hacking attempt (" . date("d.m.Y H:i:s") . " - [" . time() . "]):\n";
        $report .= ">Database Inforamation\n";
        $report .= "\tID - " . $user['id'] . "\n";
        $report .= "\tUser - " . $user['username'] . "\n";
        $report .= "\tAuth level - " . $user['authlevel'] . "\n";
        $report .= "\tAdmin Notes - " . $user['adminNotes'] . "\n";
        $report .= "\tCurrent Planet - " . $user['current_planet'] . "\n";
        $report .= "\tUser IP - " . $user['user_lastip'] . "\n";
        $report .= "\tUser IP at Reg - " . $user['ip_at_reg'] . "\n";
        $report .= "\tUser Agent- " . $_SERVER['HTTP_USER_AGENT'] . "\n";
        $report .= "\tCurrent Page - " . $user['current_page'] . "\n";
        $report .= "\tRegister Time - " . $user['register_time'] . "\n";
        $report .= "\n";

        $report .= ">Query Information\n";
        $report .= "\tQuery - " . $query . "\n";
        $report .= "\n";

        $report .= ">\$_SERVER Information\n";
        $report .= "\tIP - " . $_SERVER['REMOTE_ADDR'] . "\n";
        $report .= "\tHost Name - " . $_SERVER['HTTP_HOST'] . "\n";
        $report .= "\tUser Agent - " . $_SERVER['HTTP_USER_AGENT'] . "\n";
        $report .= "\tRequest Method - " . $_SERVER['REQUEST_METHOD'] . "\n";
        $report .= "\tCame From - " . $_SERVER['HTTP_REFERER'] . "\n";
        $report .= "\tPage is - " . $_SERVER['SCRIPT_NAME'] . "\n";
        $report .= "\tUses Port - " . $_SERVER['REMOTE_PORT'] . "\n";
        $report .= "\tServer Protocol - " . $_SERVER['SERVER_PROTOCOL'] . "\n";

        $report .= "\n--------------------------------------------------------------------------------------------------\n";

        $fp = fopen(SN_ROOT_PHYSICAL . 'badqrys.txt', 'a');
        fwrite($fp, $report);

        fclose($fp);

        $message = 'Привет, я не знаю то, что Вы пробовали сделать, но команда, которую Вы только послали базе данных, не выглядела очень дружественной и она была заблокированна.<br /><br />Ваш IP, и другие данные переданны администрации сервера. Удачи!.';
        die($message);
      break;

break; does not seem to be reachable.

    }
  }

  /**
   * @param bool $prefixed_only
   *
   * @return array
   */
  public function db_get_table_list($prefixed_only = true) {
    $query = $this->mysql_get_table_list();

    $prefix_length = strlen($this->db_prefix);

    $tl = array();
    while($row = $this->db_fetch($query)) {

It seems like $query defined by $this->mysql_get_table_list() on line 649 can also be of type boolean; however, db_mysql::db_fetch() does only seem to accept object<mysqli_result>, maybe add an additional type check?

      foreach ($row as $table_name) {
        if (strpos($table_name, $this->db_prefix) === 0) {
          $table_name = substr($table_name, $prefix_length);
        } elseif ($prefixed_only) {
          continue;
        }
        // $table_name = str_replace($db_prefix, '', $table_name);

57% of this comment could be valid code. Did you maybe forget this after debugging?

        $tl[$table_name] = $table_name;
      }
    }

    return $tl;
  }

  /**
   * @param string $statement
   *
   * @return bool|mysqli_stmt
   */
  public function db_prepare($statement) {

This method seems to be duplicated in your project.

    $microtime = microtime(true);
    $result = $this->driver->mysql_prepare($statement);
    $this->time_mysql_total += microtime(true) - $microtime;

    return $result;
  }


  /**
   * L1 perform the query
   *
   * @param $query_string
   *
   * @return bool|mysqli_result
   */
  public function db_sql_query($query_string) {

This method seems to be duplicated in your project.

    $microtime = microtime(true);
    $result = $this->driver->mysql_query($query_string);
    $this->time_mysql_total += microtime(true) - $microtime;

    return $result;
  }

  /**
   * L1 fetch assoc array
   *
   * @param mysqli_result $query
   *
   * @return array|null
   */
  public function db_fetch($query) {

This method seems to be duplicated in your project.

    $microtime = microtime(true);
    $result = $this->driver->mysql_fetch_assoc($query);
    $this->time_mysql_total += microtime(true) - $microtime;

    return $result;
  }

  public function db_fetch_row(&$query) {
    return $this->driver->mysql_fetch_row($query);
  }

  public function db_escape($unescaped_string) {
    return $this->driver->mysql_real_escape_string($unescaped_string);
  }

  public function driver_disconnect() {
    return $this->driver->mysql_close_link();
  }

  public function db_error() {
    return $this->driver->mysql_error();
  }

  public function db_insert_id() {
    return $this->driver->mysql_insert_id();
  }

  public function db_num_rows(&$result) {
    return $this->driver->mysql_num_rows($result);
  }

  /**
   * @return int -1 means error
   */
  public function db_affected_rows() {
    return $this->driver->mysql_affected_rows();
  }

  /**
   * @return string
   */
  public function db_get_client_info() {
    return $this->driver->mysql_get_client_info();
  }

  /**
   * @return string
   */
  public function db_get_server_info() {
    return $this->driver->mysql_get_server_info();
  }

  /**
   * @return string
   */
  public function db_get_host_info() {
    return $this->driver->mysql_get_host_info();
  }

  public function db_get_server_stat() {
    $result = array();

    $status = explode('  ', $this->driver->mysql_stat());
    foreach ($status as $value) {
      $row = explode(': ', $value);
      $result[$row[0]] = $row[1];
    }

    return $result;
  }

  /**
   * @return array
   * @throws Exception
   */
  public function db_core_show_status() {
    $result = array();

    $query = $this->db_sql_query('SHOW STATUS;');
    if (is_bool($query)) {
      throw new Exception('Result of SHOW STATUS command is boolean - which should never happen. Connection to DB is lost?');
    }
    while($row = db_fetch($query)) {
      $result[$row['Variable_name']] = $row['Value'];
    }

    return $result;
  }

  public function mysql_get_table_list() {
    return $this->db_sql_query('SHOW TABLES;');
  }

  public function mysql_get_innodb_status() {
    return $this->db_sql_query('SHOW ENGINE INNODB STATUS;');
  }

  /**
   * @return DbRowDirectOperator
   */
  public function getOperator() {
    return $this->operator;
  }



  // Some wrappers to DbTransaction
  // Unused for now
  /**
   * @return DbTransaction
   */
  public function getTransaction() {
    return $this->transaction;
  }

  public function transactionCheck($status = null) {
    return $this->transaction->check($status);
  }

  public function transactionStart($level = '') {
    return $this->transaction->start($level);
  }

  public function transactionCommit() {
    return $this->transaction->commit();
  }

  public function transactionRollback() {
    return $this->transaction->rollback();
  }

}