DB::getMDB() - Code Metrics - Inspection of "Merge pull request #1780 from nilsteampassnet/scru..." - nilsteampassnet/TeamPass - Measure and Improve Code Quality continuously with Scrutinizer

Completed
Push — development ( 6a24df...5afdf5 )

by Nils
created 2017-06-03 06:39 UTC
DB::getMDB() F

↳ Parent: DB
Complexity

Conditions	11
Paths	1024
Size

Total Lines	37
Code Lines	23
Duplication

Lines	0
Ratio	0 %
Importance

Changes
Metric	Value
cc	11
eloc	23
nc	1024
nop	0
dl	0
loc	37
rs	3.1764
c	0
b	0
f	0
How to fix Complexity

<?php
/*
    Copyright (C) 2008-2012 Sergey Tsalkov ([email protected])

    This program is free software: you can redistribute it and/or modify
    it under the terms of the GNU Lesser General Public License as published by
    the Free Software Foundation, either version 3 of the License, or
    (at your option) any later version.

    This program is distributed in the hope that it will be useful,
    but WITHOUT ANY WARRANTY; without even the implied warranty of
    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
    GNU Lesser General Public License for more details.

    You should have received a copy of the GNU Lesser General Public License
    along with this program.  If not, see <http://www.gnu.org/licenses/>.
*/


class DB {
    // initial connection
    public static $dbName = '';
    public static $user = '';
    public static $password = '';
    public static $host = 'localhost';
    public static $port = null;
    public static $encoding = 'utf8';

    // configure workings
    public static $param_char = '%';
    public static $named_param_seperator = '_';
    public static $success_handler = false;
    public static $error_handler = true;
    public static $throw_exception_on_error = false;
    public static $nonsql_error_handler = null;
    public static $throw_exception_on_nonsql_error = false;
    public static $nested_transactions = false;
    public static $usenull = true;

    // internal
    protected static $mdb = null;

    public static function getMDB() {
    $mdb = DB::$mdb;

    if ($mdb === null) {
        $mdb = DB::$mdb = new MeekroDB();
    }

    if ($mdb->param_char !== DB::$param_char) {
        $mdb->param_char = DB::$param_char;
    }
    if ($mdb->named_param_seperator !== DB::$named_param_seperator) {
        $mdb->named_param_seperator = DB::$named_param_seperator;
    }
    if ($mdb->success_handler !== DB::$success_handler) {
        $mdb->success_handler = DB::$success_handler;
    }
    if ($mdb->error_handler !== DB::$error_handler) {
        $mdb->error_handler = DB::$error_handler;
    }
    if ($mdb->throw_exception_on_error !== DB::$throw_exception_on_error) {
        $mdb->throw_exception_on_error = DB::$throw_exception_on_error;
    }
    if ($mdb->nonsql_error_handler !== DB::$nonsql_error_handler) {
        $mdb->nonsql_error_handler = DB::$nonsql_error_handler;
    }
    if ($mdb->throw_exception_on_nonsql_error !== DB::$throw_exception_on_nonsql_error) {
        $mdb->throw_exception_on_nonsql_error = DB::$throw_exception_on_nonsql_error;
    }
    if ($mdb->nested_transactions !== DB::$nested_transactions) {
        $mdb->nested_transactions = DB::$nested_transactions;
    }
    if ($mdb->usenull !== DB::$usenull) {
        $mdb->usenull = DB::$usenull;
    }

    return $mdb;
    }

    public static function get() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'get'), $args); }
    public static function disconnect() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'disconnect'), $args); }
    public static function query() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'query'), $args); }
    public static function queryFirstRow() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryFirstRow'), $args); }
    public static function queryOneRow() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryOneRow'), $args); }
    public static function queryAllLists() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryAllLists'), $args); }
    public static function queryFullColumns() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryFullColumns'), $args); }
    public static function queryFirstList() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryFirstList'), $args); }
    public static function queryOneList() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryOneList'), $args); }
    public static function queryFirstColumn() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryFirstColumn'), $args); }
    public static function queryOneColumn() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryOneColumn'), $args); }
    public static function queryFirstField() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryFirstField'), $args); }
    public static function queryOneField() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryOneField'), $args); }
    public static function queryRaw() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryRaw'), $args); }
    public static function queryRawUnbuf() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'queryRawUnbuf'), $args); }

    public static function insert() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'insert'), $args); }
    public static function insertIgnore() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'insertIgnore'), $args); }
    public static function insertUpdate() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'insertUpdate'), $args); }
    public static function replace() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'replace'), $args); }
    public static function update() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'update'), $args); }
    public static function delete() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'delete'), $args); }

    public static function insertId() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'insertId'), $args); }
    public static function count() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'count'), $args); }
    public static function affectedRows() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'affectedRows'), $args); }

    public static function useDB() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'useDB'), $args); }
    public static function startTransaction() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'startTransaction'), $args); }
    public static function commit() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'commit'), $args); }
    public static function rollback() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'rollback'), $args); }
    public static function tableList() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'tableList'), $args); }
    public static function columnList() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'columnList'), $args); }

    public static function sqlEval() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'sqlEval'), $args); }
    public static function nonSQLError() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'nonSQLError'), $args); }

    public static function serverVersion() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'serverVersion'), $args); }
    public static function transactionDepth() { $args = func_get_args(); return call_user_func_array(array(DB::getMDB(), 'transactionDepth'), $args); }


    public static function debugMode($handler = true) {
    DB::$success_handler = $handler;
    }

    public function version() {
    return $this->version_info();

    }

}


class MeekroDB {
    // initial connection
    public $dbName = '';
    public $user = '';
    public $password = '';
    public $host = 'localhost';
    public $port = null;
    public $encoding = 'latin1';

    // configure workings
    public $param_char = '%';
    public $named_param_seperator = '_';
    public $success_handler = false;
    public $error_handler = true;
    public $throw_exception_on_error = false;
    public $nonsql_error_handler = null;
    public $throw_exception_on_nonsql_error = false;
    public $nested_transactions = false;
    public $usenull = true;

    // internal
    public $internal_mysql = null;
    public $server_info = null;
    public $insert_id = 0;
    public $num_rows = 0;
    public $affected_rows = 0;
    public $current_db = null;
    public $nested_transactions_count = 0;


    public function __construct($host=null, $user=null, $password=null, $dbName=null, $port=null, $encoding=null) {
    if ($host === null) $host = DB::$host;
    if ($user === null) $user = DB::$user;
    if ($password === null) $password = DB::$password;
    if ($dbName === null) $dbName = DB::$dbName;
    if ($port === null) $port = DB::$port;
    if ($encoding === null) $encoding = DB::$encoding;

    $this->host = $host;
    $this->user = $user;
    $this->password = $password;
    $this->dbName = $dbName;
    $this->port = $port;
    $this->encoding = $encoding;
    }

    public function get() {
    $mysql = $this->internal_mysql;

    if (!($mysql instanceof MySQLi)) {
        if (! $this->port) $this->port = ini_get('mysqli.default_port');
        $this->current_db = $this->dbName;
      
        $mysql = new mysqli($this->host, $this->user, $this->password, $this->dbName, $this->port);

        if ($mysql->connect_error) {
        $this->nonSQLError('Unable to connect to MySQL server! Error: ' . $mysql->connect_error);
        }

        $mysql->set_charset($this->encoding);
        $this->internal_mysql = $mysql;
        $this->server_info = $mysql->server_info;
    }

    return $mysql;
    }

    public function disconnect() {
    $mysqli = $this->internal_mysql;
    if ($mysqli instanceof MySQLi) {
        if ($thread_id = $mysqli->thread_id) $mysqli->kill($thread_id);
        $mysqli->close();
    }
    $this->internal_mysql = null;
    }

    public function nonSQLError($message) {
    if ($this->throw_exception_on_nonsql_error) {
        $e = new MeekroDBException($message);
        throw $e;
    }

    $error_handler = is_callable($this->nonsql_error_handler) ? $this->nonsql_error_handler : 'meekrodb_error_handler';

    call_user_func($error_handler, array(
        'type' => 'nonsql',
        'error' => $message
    ));
    }

    public function debugMode($handler = true) {
    $this->success_handler = $handler;
    }

    public function serverVersion() { $this->get(); return $this->server_info; }
    public function transactionDepth() { return $this->nested_transactions_count; }
    public function insertId() { return $this->insert_id; }
    public function affectedRows() { return $this->affected_rows; }
    public function count() { $args = func_get_args(); return call_user_func_array(array($this, 'numRows'), $args); }
    public function numRows() { return $this->num_rows; }

    public function useDB() { $args = func_get_args(); return call_user_func_array(array($this, 'setDB'), $args); }
    public function setDB($dbName) {
    $db = $this->get();
    if (! $db->select_db($dbName)) {
        $this->nonSQLError("Unable to set database to $dbName");
    }
    $this->current_db = $dbName;
    }


    public function startTransaction() {
    if ($this->nested_transactions && $this->serverVersion() < '5.5') {
        return $this->nonSQLError("Nested transactions are only available on MySQL 5.5 and greater. You are using MySQL " . $this->serverVersion());
    }

    if (!$this->nested_transactions || $this->nested_transactions_count == 0) {
        $this->query('START TRANSACTION');
        $this->nested_transactions_count = 1;
    } else {
        $this->query("SAVEPOINT LEVEL{$this->nested_transactions_count}");
        $this->nested_transactions_count++;
    }

    return $this->nested_transactions_count;
    }

    public function commit($all=false) {

    if ($this->nested_transactions && $this->serverVersion() < '5.5') {
        return $this->nonSQLError("Nested transactions are only available on MySQL 5.5 and greater. You are using MySQL " . $this->serverVersion());
    }

    if ($this->nested_transactions && $this->nested_transactions_count > 0)
        $this->nested_transactions_count--;

    if (!$this->nested_transactions || $all || $this->nested_transactions_count == 0) {
        $this->nested_transactions_count = 0;
        $this->query('COMMIT');
    } else {
        $this->query("RELEASE SAVEPOINT LEVEL{$this->nested_transactions_count}");
    }

    return $this->nested_transactions_count;
    }

    public function rollback($all=false) {

    if ($this->nested_transactions && $this->serverVersion() < '5.5') {
        return $this->nonSQLError("Nested transactions are only available on MySQL 5.5 and greater. You are using MySQL " . $this->serverVersion());
    }

    if ($this->nested_transactions && $this->nested_transactions_count > 0)
        $this->nested_transactions_count--;

    if (!$this->nested_transactions || $all || $this->nested_transactions_count == 0) {
        $this->nested_transactions_count = 0;
        $this->query('ROLLBACK');
    } else {
        $this->query("ROLLBACK TO SAVEPOINT LEVEL{$this->nested_transactions_count}");
    }

    return $this->nested_transactions_count;
    }

    protected function formatTableName($table) {
    $table = trim($table, '`');

    if (strpos($table, '.')) return implode('.', array_map(array($this, 'formatTableName'), explode('.', $table)));
    else return '`' . str_replace('`', '``', $table) . '`';
    }

    public function update() {
    $args = func_get_args();
    $table = array_shift($args);
    $params = array_shift($args);
    $where = array_shift($args);

    $query = "UPDATE %b SET %? WHERE ".$where;

    array_unshift($args, $params);
    array_unshift($args, $table);
    array_unshift($args, $query);
    return call_user_func_array(array($this, 'query'), $args);
  }

  /**
   * @param string $which
   */
  public function insertOrReplace($which, $table, $datas, $options=array()) {
    $datas = unserialize(serialize($datas)); // break references within array
    $keys = $values = array();

    if (isset($datas[0]) && is_array($datas[0])) {
      foreach ($datas as $datum) {
        ksort($datum);
        if (! $keys) {

            $keys = array_keys($datum);
        }
        $values[] = array_values($datum);
      }

    } else {
      $keys = array_keys($datas);
      $values = array_values($datas);
    }

    if (isset($options['ignore']) && $options['ignore']) {
        $which = 'INSERT IGNORE';
    }

    if (isset($options['update']) && is_array($options['update']) && $options['update'] && strtolower($which) == 'insert') {
      if (array_values($options['update']) !== $options['update']) {
        return $this->query("INSERT INTO %b %lb VALUES %? ON DUPLICATE KEY UPDATE %?", $table, $keys, $values, $options['update']);
      } else {
        $update_str = array_shift($options['update']);
        $query_param = array("INSERT INTO %b %lb VALUES %? ON DUPLICATE KEY UPDATE $update_str", $table, $keys, $values);
        $query_param = array_merge($query_param, $options['update']);
        return call_user_func_array(array($this, 'query'), $query_param);
      }

    }

    return $this->query("%l INTO %b %lb VALUES %?", $which, $table, $keys, $values);
  }

  public function insert($table, $data) { return $this->insertOrReplace('INSERT', $table, $data); }
  public function insertIgnore($table, $data) { return $this->insertOrReplace('INSERT', $table, $data, array('ignore' => true)); }
  public function replace($table, $data) { return $this->insertOrReplace('REPLACE', $table, $data); }

  public function insertUpdate() {
    $args = func_get_args();
    $table = array_shift($args);
    $data = array_shift($args);

    if (!isset($args[0])) { // update will have all the data of the insert
      if (isset($data[0]) && is_array($data[0])) { //multiple insert rows specified -- failing!
        $this->nonSQLError("Badly formatted insertUpdate() query -- you didn't specify the update component!");
      }

      $args[0] = $data;
    }

    if (is_array($args[0])) {
        $update = $args[0];
    } else {
        $update = $args;
    }

    return $this->insertOrReplace('INSERT', $table, $data, array('update' => $update));
  }

  public function delete() {
    $args = func_get_args();
    $table = $this->formatTableName(array_shift($args));
    $where = array_shift($args);
    $buildquery = "DELETE FROM $table WHERE $where";
    array_unshift($args, $buildquery);
    return call_user_func_array(array($this, 'query'), $args);
  }

  public function sqleval() {
    $args = func_get_args();
    $text = call_user_func_array(array($this, 'parseQueryParams'), $args);
    return new MeekroDBEval($text);
  }

  public function columnList($table) {
    return $this->queryOneColumn('Field', "SHOW COLUMNS FROM $table");
  }

  public function tableList($db = null) {
    if ($db) {
      $olddb = $this->current_db;
      $this->useDB($db);
    }

    $result = $this->queryFirstColumn('SHOW TABLES');
    if (isset($olddb)) {
        $this->useDB($olddb);
    }
    return $result;
  }

  protected function preparseQueryParams() {
    $args = func_get_args();
    $sql = trim(strval(array_shift($args)));
    $args_all = $args;

    if (count($args_all) == 0) {
        return array($sql);
    }

    $param_char_length = strlen($this->param_char);
    $named_seperator_length = strlen($this->named_param_seperator);

    $types = array(
        $this->param_char . 'll', // list of literals
        $this->param_char . 'ls', // list of strings
        $this->param_char . 'l',  // literal
        $this->param_char . 'li', // list of integers
        $this->param_char . 'ld', // list of decimals
        $this->param_char . 'lb', // list of backticks
        $this->param_char . 'lt', // list of timestamps
        $this->param_char . 's',  // string
        $this->param_char . 'i',  // integer
        $this->param_char . 'd',  // double / decimal
        $this->param_char . 'b',  // backtick
        $this->param_char . 't',  // timestamp
        $this->param_char . '?',  // infer type
        $this->param_char . 'ss'  // search string (like string, surrounded with %'s)
    );

    // generate list of all MeekroDB variables in our query, and their position
    // in the form "offset => variable", sorted by offsets
    $posList = array();
    foreach ($types as $type) {
        $lastPos = 0;
        while (($pos = strpos($sql, $type, $lastPos)) !== false) {
        $lastPos = $pos + 1;
        if (isset($posList[$pos]) && strlen($posList[$pos]) > strlen($type)) {
            continue;
        }
        $posList[$pos] = $type;
        }
    }

    ksort($posList);

    // for each MeekroDB variable, substitute it with array(type: i, value: 53) or whatever
    $chunkyQuery = array(); // preparsed query
    $pos_adj = 0; // how much we've added or removed from the original sql string
    foreach ($posList as $pos => $type) {
        $type = substr($type, $param_char_length); // variable, without % in front of it
        $length_type = strlen($type) + $param_char_length; // length of variable w/o %

        $new_pos = $pos + $pos_adj; // position of start of variable
        $new_pos_back = $new_pos + $length_type; // position of end of variable
        $arg_number_length = 0; // length of any named or numbered parameter addition
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}

        // handle numbered parameters
        if ($arg_number_length = strspn($sql, '0123456789', $new_pos_back)) {
        $arg_number = substr($sql, $new_pos_back, $arg_number_length);
        if (!array_key_exists($arg_number, $args_all)) $this->nonSQLError("Non existent argument reference (arg $arg_number): $sql");

        $arg = $args_all[$arg_number];

        // handle named parameters
        } else if (substr($sql, $new_pos_back, $named_seperator_length) == $this->named_param_seperator) {
        $arg_number_length = strspn($sql, 'abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ0123456789_',
            $new_pos_back + $named_seperator_length) + $named_seperator_length;

        $arg_number = substr($sql, $new_pos_back + $named_seperator_length, $arg_number_length - $named_seperator_length);
        if (count($args_all) != 1 || !is_array($args_all[0])) $this->nonSQLError("If you use named parameters, the second argument must be an array of parameters");
        if (!array_key_exists($arg_number, $args_all[0])) $this->nonSQLError("Non existent argument reference (arg $arg_number): $sql");

        $arg = $args_all[0][$arg_number];

        } else {
        $arg_number = 0;
$myVar = 'Value';
$higher = false;

if (rand(1, 6) > 3) {
    $higher = true;
} else {
    $higher = false;
}
        $arg = array_shift($args);
        }

        if ($new_pos > 0) $chunkyQuery[] = substr($sql, 0, $new_pos);

        if (is_object($arg) && ($arg instanceof WhereClause)) {
        list($clause_sql, $clause_args) = $arg->textAndArgs();
        array_unshift($clause_args, $clause_sql);
        $preparsed_sql = call_user_func_array(array($this, 'preparseQueryParams'), $clause_args);
        $chunkyQuery = array_merge($chunkyQuery, $preparsed_sql);
        } else {
        $chunkyQuery[] = array('type' => $type, 'value' => $arg);
        }

        $sql = substr($sql, $new_pos_back + $arg_number_length);
        $pos_adj -= $new_pos_back + $arg_number_length;
    }

    if (strlen($sql) > 0) {
        $chunkyQuery[] = $sql;
    }

    return $chunkyQuery;
    }

    protected function escape($str) { return "'" . $this->get()->real_escape_string(strval($str)) . "'"; }

    protected function sanitize($value) {
    if (is_object($value)) {
        if ($value instanceof MeekroDBEval) return $value->text;
        else if ($value instanceof DateTime) return $this->escape($value->format('Y-m-d H:i:s'));
        else return '';
    }

    if (is_null($value)) return $this->usenull ? 'NULL' : "''";
    else if (is_bool($value)) return ($value ? 1 : 0);
    else if (is_int($value)) return $value;
    else if (is_float($value)) return $value;

    else if (is_array($value)) {
        // non-assoc array?
        if (array_values($value) === $value) {
        if (is_array($value[0])) return implode(', ', array_map(array($this, 'sanitize'), $value));
        else return '(' . implode(', ', array_map(array($this, 'sanitize'), $value)) . ')';
        }

        $pairs = array();
        foreach ($value as $k => $v) {
        $pairs[] = $this->formatTableName($k) . '=' . $this->sanitize($v);
        }

        return implode(', ', $pairs);
    }
    else return $this->escape($value);
    }

    protected function parseTS($ts) {
    if (is_string($ts)) return date('Y-m-d H:i:s', strtotime($ts));
    else if (is_object($ts) && ($ts instanceof DateTime)) return $ts->format('Y-m-d H:i:s');
    }

    protected function intval($var) {
    if (PHP_INT_SIZE == 8) return intval($var);
    return floor(doubleval($var));
    }

    protected function parseQueryParams() {
    $args = func_get_args();
    $chunkyQuery = call_user_func_array(array($this, 'preparseQueryParams'), $args);

    $query = '';
    $array_types = array('ls', 'li', 'ld', 'lb', 'll', 'lt');

    foreach ($chunkyQuery as $chunk) {
      if (is_string($chunk)) {
        $query .= $chunk;
        continue;
      }

      $type = $chunk['type'];
      $arg = $chunk['value'];
      $result = '';

      if ($type != '?') {
        $is_array_type = in_array($type, $array_types, true);
        if ($is_array_type && !is_array($arg)) $this->nonSQLError("Badly formatted SQL query: Expected array, got scalar instead!");
        else if (!$is_array_type && is_array($arg)) $this->nonSQLError("Badly formatted SQL query: Expected scalar, got array instead!");
      }

      if ($type == 's') $result = $this->escape($arg);
      else if ($type == 'i') $result = $this->intval($arg);
      else if ($type == 'd') $result = doubleval($arg);
      else if ($type == 'b') $result = $this->formatTableName($arg);
      else if ($type == 'l') $result = $arg;
      else if ($type == 'ss') $result = $this->escape("%".str_replace(array('%', '_'), array('\%', '\_'), $arg)."%");
      else if ($type == 't') $result = $this->escape($this->parseTS($arg));

      else if ($type == 'ls') $result = array_map(array($this, 'escape'), $arg);
      else if ($type == 'li') $result = array_map(array($this, 'intval'), $arg);
      else if ($type == 'ld') $result = array_map('doubleval', $arg);
      else if ($type == 'lb') $result = array_map(array($this, 'formatTableName'), $arg);
      else if ($type == 'll') $result = $arg;
      else if ($type == 'lt') $result = array_map(array($this, 'escape'), array_map(array($this, 'parseTS'), $arg));

      else if ($type == '?') $result = $this->sanitize($arg);

      else $this->nonSQLError("Badly formatted SQL query: Invalid MeekroDB param $type");

      if (is_array($result)) $result = '('.implode(',', $result).')';

      $query .= $result;
    }

    return $query;
  }

  /**
   * @param string $prepend
   */
  protected function prependCall($function, $args, $prepend) { array_unshift($args, $prepend); return call_user_func_array($function, $args); }
  public function query() { $args = func_get_args(); return $this->prependCall(array($this, 'queryHelper'), $args, 'assoc'); }
  public function queryAllLists() { $args = func_get_args(); return $this->prependCall(array($this, 'queryHelper'), $args, 'list'); }
  public function queryFullColumns() { $args = func_get_args(); return $this->prependCall(array($this, 'queryHelper'), $args, 'full'); }

  public function queryRaw() { $args = func_get_args(); return $this->prependCall(array($this, 'queryHelper'), $args, 'raw_buf'); }
  public function queryRawUnbuf() { $args = func_get_args(); return $this->prependCall(array($this, 'queryHelper'), $args, 'raw_unbuf'); }

  protected function queryHelper() {
    $args = func_get_args();
    $type = array_shift($args);
    $db = $this->get();

    $is_buffered = true;
    $row_type = 'assoc'; // assoc, list, raw

    $full_names = false;

    switch ($type) {
        case 'assoc':
        break;
        case 'list':
        $row_type = 'list';
        break;
        case 'full':
        $row_type = 'list';
        $full_names = true;
        break;
        case 'raw_buf':
        $row_type = 'raw';
        break;
        case 'raw_unbuf':
        $is_buffered = false;
        $row_type = 'raw';
        break;
        default:
        $this->nonSQLError('Error -- invalid argument to queryHelper!');
    }

    $sql = call_user_func_array(array($this, 'parseQueryParams'), $args);

    if ($this->success_handler) {
        $starttime = microtime(true);
    }
    $result = $db->query($sql, $is_buffered ? MYSQLI_STORE_RESULT : MYSQLI_USE_RESULT);
    if ($this->success_handler) {
        $runtime = microtime(true) - $starttime;
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
    } else {
        $runtime = 0;
    }

    // ----- BEGIN ERROR HANDLING
    if (!$sql || $db->error) {
        if ($this->error_handler) {
        $db_error = $db->error;
        $db_errno = $db->errno;
    $db->query(
        "INSERT INTO ".$GLOBALS['pre']."log_system SET
      date=".time().",
      qui=".$_SESSION['user_id'].",
      label='Query: ".addslashes($sql)."<br />Error: ".addslashes($db_error)."<br />@ ".mysqli_real_escape_string($link, filter_var($_SERVER['REQUEST_URI'], FILTER_SANITIZE_STRING))."',

      type='error'",
        MYSQLI_USE_RESULT
    );

        $error_handler = is_callable($this->error_handler) ? $this->error_handler : 'meekrodb_error_handler';

        call_user_func($error_handler, array(
            'type' => 'sql',
            'query' => $sql,
            'error' => $db_error,
            'code' => $db_errno
        ));
        }

        if ($this->throw_exception_on_error) {
        $e = new MeekroDBException($db_error, $sql, $db_errno);
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
        throw $e;
        }
    } else if ($this->success_handler) {
        $runtime = sprintf('%f', $runtime * 1000);
        $success_handler = is_callable($this->success_handler) ? $this->success_handler : 'meekrodb_debugmode_handler';

        call_user_func($success_handler, array(
        'query' => $sql,
        'runtime' => $runtime,
        'affected' => $db->affected_rows
        ));
    }

    // ----- END ERROR HANDLING

    $this->insert_id = $db->insert_id;
    $this->affected_rows = $db->affected_rows;

    // mysqli_result->num_rows won't initially show correct results for unbuffered data
    if ($is_buffered && ($result instanceof MySQLi_Result)) $this->num_rows = $result->num_rows;
    else $this->num_rows = null;

    if ($row_type == 'raw' || !($result instanceof MySQLi_Result)) return $result;

    $return = array();

    if ($full_names) {
        $infos = array();
        foreach ($result->fetch_fields() as $info) {
        if (strlen($info->table)) $infos[] = $info->table . '.' . $info->name;
        else $infos[] = $info->name;
        }
    }

    while ($row = ($row_type == 'assoc' ? $result->fetch_assoc() : $result->fetch_row())) {
        if ($full_names) $row = array_combine($infos, $row);
function myFunction($a) {
    switch ($a) {
        case 'foo':
            $x = 1;
            break;

        case 'bar':
            $x = 2;
            break;
    }

    // $x is potentially undefined here.
    echo $x;
}
        $return[] = $row;
    }

    // free results
    $result->free();
    while ($db->more_results()) {
        $db->next_result();
        if ($result = $db->use_result()) $result->free();
    }

    return $return;
    }

    public function queryOneRow() { $args = func_get_args(); return call_user_func_array(array($this, 'queryFirstRow'), $args); }
    public function queryFirstRow() {

    $args = func_get_args();
    $result = call_user_func_array(array($this, 'query'), $args);
    if (!$result) return null;
    return reset($result);
    }

    public function queryOneList() { $args = func_get_args(); return call_user_func_array(array($this, 'queryFirstList'), $args); }
    public function queryFirstList() {

    $args = func_get_args();
    $result = call_user_func_array(array($this, 'queryAllLists'), $args);
    if (!$result) return null;
    return reset($result);
    }

    public function queryFirstColumn() {
    $args = func_get_args();
    $results = call_user_func_array(array($this, 'queryAllLists'), $args);
    $ret = array();

    if (!count($results) || !count($results[0])) {
        return $ret;
    }

    foreach ($results as $row) {
        $ret[] = $row[0];
    }

    return $ret;
    }

    public function queryOneColumn() {
    $args = func_get_args();
    $column = array_shift($args);
    $results = call_user_func_array(array($this, 'query'), $args);
    $ret = array();

    if (!count($results) || !count($results[0])) {
        return $ret;
    }
    if ($column === null) {
        $keys = array_keys($results[0]);
        $column = $keys[0];
    }

    foreach ($results as $row) {
        $ret[] = $row[$column];
    }

    return $ret;
    }

    public function queryFirstField() {
    $args = func_get_args();
    $row = call_user_func_array(array($this, 'queryFirstList'), $args);
    if ($row == null) {
        return null;
    }
    return $row[0];
    }

    public function queryOneField() {
    $args = func_get_args();
    $column = array_shift($args);

    $row = call_user_func_array(array($this, 'queryOneRow'), $args);
    if ($row == null) {
        return null;
    } else if ($column === null) {
        $keys = array_keys($row);
        $column = $keys[0];
    }

    return $row[$column];
    }
}

class WhereClause {
    public $type = 'and'; //AND or OR
    public $negate = false;
    public $clauses = array();

    function __construct($type) {
    $type = strtolower($type);
    if ($type !== 'or' && $type !== 'and') {
        DB::nonSQLError('you must use either WhereClause(and) or WhereClause(or)');
    }
    $this->type = $type;
    }

    function add() {
    $args = func_get_args();
    $sql = array_shift($args);

    if ($sql instanceof WhereClause) {
        $this->clauses[] = $sql;
    } else {
        $this->clauses[] = array('sql' => $sql, 'args' => $args);
    }
    }

    function negateLast() {
    $i = count($this->clauses) - 1;
    if (!isset($this->clauses[$i])) {
        return;
    }

    if ($this->clauses[$i] instanceof WhereClause) {
        $this->clauses[$i]->negate();
    } else {
        $this->clauses[$i]['sql'] = 'NOT (' . $this->clauses[$i]['sql'] . ')';
    }
    }

    function negate() {
    $this->negate = ! $this->negate;
    }

    function addClause($type) {
    $r = new WhereClause($type);
    $this->add($r);
    return $r;
    }

    function count() {
    return count($this->clauses);
    }

    function textAndArgs() {
    $sql = array();
    $args = array();

    if (count($this->clauses) == 0) {
        return array('(1)', $args);
    }

    foreach ($this->clauses as $clause) {
        if ($clause instanceof WhereClause) {
        list($clause_sql, $clause_args) = $clause->textAndArgs();
        } else {
        $clause_sql = $clause['sql'];
        $clause_args = $clause['args'];
        }

        $sql[] = "($clause_sql)";
        $args = array_merge($args, $clause_args);
    }

    if ($this->type == 'and') $sql = implode(' AND ', $sql);
    else $sql = implode(' OR ', $sql);

    if ($this->negate) $sql = '(NOT '.$sql.')';
    return array($sql, $args);
    }

    // backwards compatability
    // we now return full WhereClause object here and evaluate it in preparseQueryParams
    function text() { return $this; }
}

class DBTransaction {
    private $committed = false;

    function __construct() {
    DB::startTransaction();
    }
    function __destruct() {
    if (! $this->committed) DB::rollback();
    }
    function commit() {
    DB::commit();
    $this->committed = true;
    }


}

class MeekroDBException extends Exception {
    protected $query = '';

    function __construct($message='', $query='', $code = 0) {
    parent::__construct($message);
    $this->query = $query;
    $this->code = $code;
    }

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

class DBHelper {
    /*
    verticalSlice
    1. For an array of assoc rays, return an array of values for a particular key
    2. if $keyfield is given, same as above but use that hash key as the key in new array
  */

    public static function verticalSlice($array, $field, $keyfield = null) {
    $array = (array) $array;

    $R = array();
    foreach ($array as $obj) {
        if (! array_key_exists($field, $obj)) die("verticalSlice: array doesn't have requested field\n");

        if ($keyfield) {
        if (! array_key_exists($keyfield, $obj)) die("verticalSlice: array doesn't have requested field\n");
        $R[$obj[$keyfield]] = $obj[$field];
        } else {
        $R[] = $obj[$field];
        }
    }
    return $R;
    }

    /*
    reIndex
    For an array of assoc rays, return a new array of assoc rays using a certain field for keys
  */

    public static function reIndex() {
    $fields = func_get_args();
    $array = array_shift($fields);
    $array = (array) $array;

    $R = array();
    foreach ($array as $obj) {
        $target =& $R;

        foreach ($fields as $field) {
        if (! array_key_exists($field, $obj)) die("reIndex: array doesn't have requested field\n");

        $nextkey = $obj[$field];
        $target =& $target[$nextkey];
        }
        $target = $obj;
    }
    return $R;
    }
}

function meekrodb_error_handler($params) {
    echo prepareExchangedData('[{"error" : "'.$params['error'].'"}]', "encode");

    die;
}

function meekrodb_debugmode_handler($params) {
    echo "QUERY: " . $params['query'] . " [" . $params['runtime'] . " ms]";
    if (php_sapi_name() == 'cli' && empty($_SERVER['REMOTE_ADDR'])) {
    echo "\n";
    } else {
    echo "<br>\n";
    }
}

class MeekroDBEval {
    public $text = '';

    function __construct($text) {
    $this->text = $text;
    }
}
Push — development ( 6a24df...5afdf5 )

DB::getMDB() F

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Available Fixes

Available Fixes

Available Fixes

Available Fixes

nilsteampassnet / TeamPass

Push — development ( 6a24df...5afdf5 )

DB::getMDB() F

Complexity

Size

Duplication

Importance

How to fix Complexity

Long Method

Available Fixes

Available Fixes

Available Fixes

Available Fixes

Duplication Side-by-Side

Filter issues like
