detain / db_abstraction

src/Mysqli/Db.php

Indentation +495 added lines, -495 removed lines

@@ -19,504 +19,504 @@
  */
 class Db extends Generic implements Db_Interface
 {
-    /**
-     * @var string
-     */
-    public $type = 'mysqli';
-
-    /**
-     * alias function of select_db, changes the database we are working with.
-     *
-     * @param string $database the name of the database to use
-     * @return void
-     */
-    public function useDb($database)
-    {
-        $this->selectDb($database);
-    }
-
-    /**
-     * changes the database we are working with.
-     *
-     * @param string $database the name of the database to use
-     * @return void
-     */
-    public function selectDb($database)
-    {
-        $this->connect();
-        mysqli_select_db($this->linkId, $database);
-    }
-
-    /* public: connection management */
-
-    /**
-     * Db::connect()
-     * @param string $database
-     * @param string $host
-     * @param string $user
-     * @param string $password
-     * @return int|\mysqli
-     */
-    public function connect($database = '', $host = '', $user = '', $password = '', $port = '')
-    {
-        /* Handle defaults */
-        if ($database == '') {
-            $database = $this->database;
-        }
-        if ($host == '') {
-            $host = $this->host;
-        }
-        if ($user == '') {
-            $user = $this->user;
-        }
-        if ($password == '') {
-            $password = $this->password;
-        }
-        if ($port == '') {
-            $port = $this->port;
-        }
-        /* establish connection, select database */
-        if (!is_object($this->linkId)) {
-            $this->connectionAttempt++;
-            if ($this->connectionAttempt >= $this->maxConnectErrors - 1) {
-                error_log("MySQLi Connection Attempt #{$this->connectionAttempt}/{$this->maxConnectErrors}");
-            }
-            if ($this->connectionAttempt >= $this->maxConnectErrors) {
-                $this->halt("connect($host, $user, \$password) failed. ".$this->linkId->connect_error);
-                return 0;
-            }
-            //error_log("real_connect($host, $user, $password, $database, $port)");
-            $this->linkId = mysqli_init();
-            $this->linkId->options(MYSQLI_INIT_COMMAND, "SET NAMES {$this->characterSet} COLLATE {$this->collation}, COLLATION_CONNECTION = {$this->collation}, COLLATION_DATABASE = {$this->collation}");
-            if (!$this->linkId->real_connect($host, $user, $password, $database, $port != '' ? $port : NULL)) {
-                $this->halt("connect($host, $user, \$password) failed. ".$this->linkId->connect_error);
-                return 0;
-            }
-            $this->linkId->set_charset($this->characterSet);
-            if ($this->linkId->connect_errno) {
-                $this->halt("connect($host, $user, \$password) failed. ".$this->linkId->connect_error);
-                return 0;
-            }
-        }
-        return $this->linkId;
-    }
-
-    /**
-     * Db::disconnect()
-     * @return bool
-     */
-    public function disconnect()
-    {
-        $return = !is_int($this->linkId) && method_exists($this->linkId, 'close') ? $this->linkId->close() : false;
-        $this->linkId = 0;
-        return $return;
-    }
-
-    /**
-     * @param $string
-     * @return string
-     */
-    public function real_escape($string = '')
-    {
-        if ((!is_resource($this->linkId) || $this->linkId == 0) && !$this->connect()) {
-            return $this->escape($string);
-        }
-        return mysqli_real_escape_string($this->linkId, $string);
-    }
-
-    /**
-     * discard the query result
-     * @return void
-     */
-    public function free()
-    {
-        if (is_resource($this->queryId)) {
-            @mysqli_free_result($this->queryId);
-        }
-        $this->queryId = 0;
-    }
-
-    /**
-     * Db::queryReturn()
-     *
-     * Sends an SQL query to the server like the normal query() command but iterates through
-     * any rows and returns the row or rows immediately or FALSE on error
-     *
-     * @param mixed $query SQL Query to be used
-     * @param string $line optionally pass __LINE__ calling the query for logging
-     * @param string $file optionally pass __FILE__ calling the query for logging
-     * @return mixed FALSE if no rows, if a single row it returns that, if multiple it returns an array of rows, associative responses only
-     */
-    public function queryReturn($query, $line = '', $file = '')
-    {
-        $this->query($query, $line, $file);
-        if ($this->num_rows() == 0) {
-            return false;
-        } elseif ($this->num_rows() == 1) {
-            $this->next_record(MYSQLI_ASSOC);
-            return $this->Record;
-        } else {
-            $out = [];
-            while ($this->next_record(MYSQLI_ASSOC)) {
-                $out[] = $this->Record;
-            }
-            return $out;
-        }
-    }
-
-    /**
-     * db:qr()
-     *
-     *  alias of queryReturn()
-     *
-     * @param mixed $query SQL Query to be used
-     * @param string $line optionally pass __LINE__ calling the query for logging
-     * @param string $file optionally pass __FILE__ calling the query for logging
-     * @return mixed FALSE if no rows, if a single row it returns that, if multiple it returns an array of rows, associative responses only
-     */
-    public function qr($query, $line = '', $file = '')
-    {
-        return $this->queryReturn($query, $line, $file);
-    }
-
-    /**
-     * creates a prepaired statement from query
-     *
-     * @param string $query sql query like INSERT INTO table (col) VALUES (?)  or  SELECT * from table WHERE col1 = ? and col2 = ?  or  UPDATE table SET col1 = ?, col2 = ? WHERE col3 = ?
-     * @return int|\MyDb\Mysqli\mysqli_stmt
-     * @param string $line
-     * @param string $file
-     */
-    public function prepare($query, $line = '', $file = '')
-    {
-        if (!$this->connect()) {
-            return 0;
-        }
-        $haltPrev = $this->haltOnError;
-        $this->haltOnError = 'no';
-        $start = microtime(true);
-        $prepare = mysqli_prepare($this->linkId, $query);
-        if (!isset($GLOBALS['disable_db_queries'])) {
-            $this->addLog($query, microtime(true) - $start, $line, $file);
-        }
-        return $prepare;
-    }
-
-    /**
-     * Db::query()
-     *
-     *  Sends an SQL query to the database
-     *
-     * @param mixed $queryString
-     * @param int $line
-     * @param string $file
-     * @param bool $log
-     * @return mixed 0 if no query or query id handler, safe to ignore this return
-     */
-    public function query($queryString, $line = '', $file = '', $log = false)
-    {
-        /* No empty queries, please, since PHP4 chokes on them. */
-        /* The empty query string is passed on from the constructor,
+	/**
+	 * @var string
+	 */
+	public $type = 'mysqli';
+
+	/**
+	 * alias function of select_db, changes the database we are working with.
+	 *
+	 * @param string $database the name of the database to use
+	 * @return void
+	 */
+	public function useDb($database)
+	{
+		$this->selectDb($database);
+	}
+
+	/**
+	 * changes the database we are working with.
+	 *
+	 * @param string $database the name of the database to use
+	 * @return void
+	 */
+	public function selectDb($database)
+	{
+		$this->connect();
+		mysqli_select_db($this->linkId, $database);
+	}
+
+	/* public: connection management */
+
+	/**
+	 * Db::connect()
+	 * @param string $database
+	 * @param string $host
+	 * @param string $user
+	 * @param string $password
+	 * @return int|\mysqli
+	 */
+	public function connect($database = '', $host = '', $user = '', $password = '', $port = '')
+	{
+		/* Handle defaults */
+		if ($database == '') {
+			$database = $this->database;
+		}
+		if ($host == '') {
+			$host = $this->host;
+		}
+		if ($user == '') {
+			$user = $this->user;
+		}
+		if ($password == '') {
+			$password = $this->password;
+		}
+		if ($port == '') {
+			$port = $this->port;
+		}
+		/* establish connection, select database */
+		if (!is_object($this->linkId)) {
+			$this->connectionAttempt++;
+			if ($this->connectionAttempt >= $this->maxConnectErrors - 1) {
+				error_log("MySQLi Connection Attempt #{$this->connectionAttempt}/{$this->maxConnectErrors}");
+			}
+			if ($this->connectionAttempt >= $this->maxConnectErrors) {
+				$this->halt("connect($host, $user, \$password) failed. ".$this->linkId->connect_error);
+				return 0;
+			}
+			//error_log("real_connect($host, $user, $password, $database, $port)");
+			$this->linkId = mysqli_init();
+			$this->linkId->options(MYSQLI_INIT_COMMAND, "SET NAMES {$this->characterSet} COLLATE {$this->collation}, COLLATION_CONNECTION = {$this->collation}, COLLATION_DATABASE = {$this->collation}");
+			if (!$this->linkId->real_connect($host, $user, $password, $database, $port != '' ? $port : NULL)) {
+				$this->halt("connect($host, $user, \$password) failed. ".$this->linkId->connect_error);
+				return 0;
+			}
+			$this->linkId->set_charset($this->characterSet);
+			if ($this->linkId->connect_errno) {
+				$this->halt("connect($host, $user, \$password) failed. ".$this->linkId->connect_error);
+				return 0;
+			}
+		}
+		return $this->linkId;
+	}
+
+	/**
+	 * Db::disconnect()
+	 * @return bool
+	 */
+	public function disconnect()
+	{
+		$return = !is_int($this->linkId) && method_exists($this->linkId, 'close') ? $this->linkId->close() : false;
+		$this->linkId = 0;
+		return $return;
+	}
+
+	/**
+	 * @param $string
+	 * @return string
+	 */
+	public function real_escape($string = '')
+	{
+		if ((!is_resource($this->linkId) || $this->linkId == 0) && !$this->connect()) {
+			return $this->escape($string);
+		}
+		return mysqli_real_escape_string($this->linkId, $string);
+	}
+
+	/**
+	 * discard the query result
+	 * @return void
+	 */
+	public function free()
+	{
+		if (is_resource($this->queryId)) {
+			@mysqli_free_result($this->queryId);
+		}
+		$this->queryId = 0;
+	}
+
+	/**
+	 * Db::queryReturn()
+	 *
+	 * Sends an SQL query to the server like the normal query() command but iterates through
+	 * any rows and returns the row or rows immediately or FALSE on error
+	 *
+	 * @param mixed $query SQL Query to be used
+	 * @param string $line optionally pass __LINE__ calling the query for logging
+	 * @param string $file optionally pass __FILE__ calling the query for logging
+	 * @return mixed FALSE if no rows, if a single row it returns that, if multiple it returns an array of rows, associative responses only
+	 */
+	public function queryReturn($query, $line = '', $file = '')
+	{
+		$this->query($query, $line, $file);
+		if ($this->num_rows() == 0) {
+			return false;
+		} elseif ($this->num_rows() == 1) {
+			$this->next_record(MYSQLI_ASSOC);
+			return $this->Record;
+		} else {
+			$out = [];
+			while ($this->next_record(MYSQLI_ASSOC)) {
+				$out[] = $this->Record;
+			}
+			return $out;
+		}
+	}
+
+	/**
+	 * db:qr()
+	 *
+	 *  alias of queryReturn()
+	 *
+	 * @param mixed $query SQL Query to be used
+	 * @param string $line optionally pass __LINE__ calling the query for logging
+	 * @param string $file optionally pass __FILE__ calling the query for logging
+	 * @return mixed FALSE if no rows, if a single row it returns that, if multiple it returns an array of rows, associative responses only
+	 */
+	public function qr($query, $line = '', $file = '')
+	{
+		return $this->queryReturn($query, $line, $file);
+	}
+
+	/**
+	 * creates a prepaired statement from query
+	 *
+	 * @param string $query sql query like INSERT INTO table (col) VALUES (?)  or  SELECT * from table WHERE col1 = ? and col2 = ?  or  UPDATE table SET col1 = ?, col2 = ? WHERE col3 = ?
+	 * @return int|\MyDb\Mysqli\mysqli_stmt
+	 * @param string $line
+	 * @param string $file
+	 */
+	public function prepare($query, $line = '', $file = '')
+	{
+		if (!$this->connect()) {
+			return 0;
+		}
+		$haltPrev = $this->haltOnError;
+		$this->haltOnError = 'no';
+		$start = microtime(true);
+		$prepare = mysqli_prepare($this->linkId, $query);
+		if (!isset($GLOBALS['disable_db_queries'])) {
+			$this->addLog($query, microtime(true) - $start, $line, $file);
+		}
+		return $prepare;
+	}
+
+	/**
+	 * Db::query()
+	 *
+	 *  Sends an SQL query to the database
+	 *
+	 * @param mixed $queryString
+	 * @param int $line
+	 * @param string $file
+	 * @param bool $log
+	 * @return mixed 0 if no query or query id handler, safe to ignore this return
+	 */
+	public function query($queryString, $line = '', $file = '', $log = false)
+	{
+		/* No empty queries, please, since PHP4 chokes on them. */
+		/* The empty query string is passed on from the constructor,
         * when calling the class without a query, e.g. in situations
         * like these: '$db = new db_Subclass;'
         */
-        if ($queryString == '') {
-            return 0;
-        }
-        if (!$this->connect()) {
-            return 0;
-            /* we already complained in connect() about that. */
-        }
-        $haltPrev = $this->haltOnError;
-        $this->haltOnError = 'no';
-        // New query, discard previous result.
-        if (is_resource($this->queryId)) {
-            $this->free();
-        }
-        if ($this->Debug) {
-            printf("Debug: query = %s<br>\n", $queryString);
-        }
-        if ($log === true || (isset($GLOBALS['log_queries']) && $GLOBALS['log_queries'] !== false)) {
-            $this->log($queryString, $line, $file);
-        }
-        $tries = 2;
-        $try = 0;
-        $this->queryId = false;
-        while ((null === $this->queryId || $this->queryId === false) && $try <= $tries) {
-            $try++;
-            if ($try > 1) {
-                @mysqli_close($this->linkId);
-                $this->linkId = 0;
-            }
-            $start = microtime(true);
-            $onlyRollback = true;
-            $fails = -1;
-            while ($fails < 30 && (null === $this->queryId || $this->queryId === false)) {
-                $this->connect();
-                $fails++;
-                try {
-                    $this->queryId = @mysqli_query($this->linkId, $queryString, MYSQLI_STORE_RESULT);
-                    if (in_array((int)@mysqli_errno($this->linkId), [1213, 2006, 3101, 1180])) {
-                        //error_log("got ".@mysqli_errno($this->linkId)." sql error fails {$fails} on query {$queryString} from {$line}:{$file}");
-                        usleep(250000); // 0.25 second
-                    } else {
-                        $onlyRollback = false;
-                        if (in_array((int)@mysqli_errno($this->linkId), [1064])) {
-                            $tries = 0;
-                        }
-                        break;
-                    }
-                } catch (\mysqli_sql_exception $e) {
-                    if (in_array((int)$e->getCode(), [1213, 2006, 3101, 1180])) {
-                        //error_log("got ".$e->getCode()." sql error fails {$fails}");
-                        usleep(250000); // 0.25 second
-                    } else {
-                        error_log('Got mysqli_sql_exception code '.$e->getCode().' error '.$e->getMessage().' on query '.$queryString.' from '.$line.':'.$file);
-                        $onlyRollback = false;
-                        if (in_array((int)@mysqli_errno($this->linkId), [1064])) {
-                            $tries = 0;
-                        }
-                        break;
-                    }
-                }
-            }
-            if (!isset($GLOBALS['disable_db_queries'])) {
-                $this->addLog($queryString, microtime(true) - $start, $line, $file);
-            }
-            $this->Row = 0;
-            $this->Errno = @mysqli_errno($this->linkId);
-            $this->Error = @mysqli_error($this->linkId);
-            if ($try == 1 && (null === $this->queryId || $this->queryId === false)) {
-                //$this->emailError($queryString, 'Error #'.$this->Errno.': '.$this->Error, $line, $file);
-            }
-        }
-        $this->haltOnError = $haltPrev;
-        if ($onlyRollback === true && false === $this->queryId) {
-            error_log('Got MySQLi 3101 Rollback Error '.$fails.' Times, Giving Up on '.$queryString.' from '.$line.':'.$file.' on '.__LINE__.':'.__FILE__);
-        }
-        if (null === $this->queryId || $this->queryId === false) {
-            $this->emailError($queryString, 'Error #'.$this->Errno.': '.$this->Error, $line, $file);
-            $this->halt('', $line, $file);
-        }
-
-        // Will return nada if it fails. That's fine.
-        return $this->queryId;
-    }
-
-    /**
-     * @return array|null|object
-     */
-    public function fetchObject()
-    {
-        $this->Record = @mysqli_fetch_object($this->queryId);
-        return $this->Record;
-    }
-
-    /* public: walk result set */
-
-    /**
-     * Db::next_record()
-     *
-     * @param mixed $resultType
-     * @return bool
-     */
-    public function next_record($resultType = MYSQLI_BOTH)
-    {
-        if ($this->queryId === false) {
-            $this->haltmsg('next_record called with no query pending.');
-            return 0;
-        }
-
-        $this->Record = @mysqli_fetch_array($this->queryId, $resultType);
-        ++$this->Row;
-        $this->Errno = mysqli_errno($this->linkId);
-        $this->Error = mysqli_error($this->linkId);
-
-        $stat = is_array($this->Record);
-        if (!$stat && $this->autoFree && is_resource($this->queryId)) {
-            $this->free();
-        }
-        return $stat;
-    }
-
-    /**
-     * switch to position in result set
-     *
-     * @param integer $pos the row numbe starting at 0 to switch to
-     * @return bool whetherit was successfu or not.
-     */
-    public function seek($pos = 0)
-    {
-        $status = @mysqli_data_seek($this->queryId, $pos);
-        if ($status) {
-            $this->Row = $pos;
-        } else {
-            $this->haltmsg("seek({$pos}) failed: result has ".$this->num_rows().' rows', __LINE__, __FILE__);
-            /* half assed attempt to save the day, but do not consider this documented or even desirable behaviour. */
-            $rows = $this->num_rows();
-            @mysqli_data_seek($this->queryId, $rows);
-            $this->Row = $rows;
-            return false;
-        }
-        return true;
-    }
-
-    /**
-     * Initiates a transaction
-     *
-     * @return bool
-     */
-    public function transactionBegin()
-    {
-        if (version_compare(PHP_VERSION, '5.5.0') < 0) {
-            return true;
-        }
-        if (!$this->connect()) {
-            return 0;
-        }
-        return mysqli_begin_transaction($this->linkId);
-    }
-
-    /**
-     * Commits a transaction
-     *
-     * @return bool
-     */
-    public function transactionCommit()
-    {
-        if (version_compare(PHP_VERSION, '5.5.0') < 0 || $this->linkId === 0) {
-            return true;
-        }
-        return mysqli_commit($this->linkId);
-    }
-
-    /**
-     * Rolls back a transaction
-     *
-     * @return bool
-     */
-    public function transactionAbort()
-    {
-        if (version_compare(PHP_VERSION, '5.5.0') < 0 || $this->linkId === 0) {
-            return true;
-        }
-        return mysqli_rollback($this->linkId);
-    }
-
-    /**
-     * This will get the last insert ID created on the current connection.  Should only be called after an insert query is
-     * run on a table that has an auto incrementing field.  $table and $field are required, but unused here since it's
-     * unnecessary for mysql.  For compatibility with pgsql, the params must be supplied.
-     *
-     * @param string $table
-     * @param string $field
-     * @return int|string
-     */
-    public function getLastInsertId($table, $field)
-    {
-        if (!isset($table) || $table == '' || !isset($field) || $field == '') {
-            return -1;
-        }
-
-        return @mysqli_insert_id($this->linkId);
-    }
-
-    /* public: table locking */
-
-    /**
-     * Db::lock()
-     * @param mixed  $table
-     * @param string $mode
-     * @return bool|int|\mysqli_result
-     */
-    public function lock($table, $mode = 'write')
-    {
-        $this->connect();
-        $query = 'lock tables ';
-        if (is_array($table)) {
-            foreach ($table as $key => $value) {
-                if ($key == 'read' && $key != 0) {
-                    $query .= "$value read, ";
-                } else {
-                    $query .= "$value $mode, ";
-                }
-            }
-            $query = mb_substr($query, 0, -2);
-        } else {
-            $query .= "$table $mode";
-        }
-        $res = @mysqli_query($this->linkId, $query);
-        if (!$res) {
-            $this->halt("lock($table, $mode) failed.");
-            return 0;
-        }
-        return $res;
-    }
-
-    /**
-     * Db::unlock()
-     * @param bool $haltOnError optional, defaults to TRUE, whether or not to halt on error
-     * @return bool|int|\mysqli_result
-     */
-    public function unlock($haltOnError = true)
-    {
-        $this->connect();
-
-        $res = @mysqli_query($this->linkId, 'unlock tables');
-        if ($haltOnError === true && !$res) {
-            $this->halt('unlock() failed.');
-            return 0;
-        }
-        return $res;
-    }
-
-    /* public: evaluate the result (size, width) */
-
-    /**
-     * Db::affectedRows()
-     * @return int
-     */
-    public function affectedRows()
-    {
-        return @mysqli_affected_rows($this->linkId);
-    }
-
-    /**
-     * Db::num_rows()
-     * @return int
-     */
-    public function num_rows()
-    {
-        return @mysqli_num_rows($this->queryId);
-    }
-
-    /**
-     * Db::num_fields()
-     * @return int
-     */
-    public function num_fields()
-    {
-        return @mysqli_num_fields($this->queryId);
-    }
-
-    /**
-     * gets an array of the table names in teh current datase
-     *
-     * @return array
-     */
-    public function tableNames()
-    {
-        $return = [];
-        $this->query('SHOW TABLES');
-        $i = 0;
-        while ($info = $this->queryId->fetch_row()) {
-            $return[$i]['table_name'] = $info[0];
-            $return[$i]['tablespace_name'] = $this->database;
-            $return[$i]['database'] = $this->database;
-            ++$i;
-        }
-        return $return;
-    }
+		if ($queryString == '') {
+			return 0;
+		}
+		if (!$this->connect()) {
+			return 0;
+			/* we already complained in connect() about that. */
+		}
+		$haltPrev = $this->haltOnError;
+		$this->haltOnError = 'no';
+		// New query, discard previous result.
+		if (is_resource($this->queryId)) {
+			$this->free();
+		}
+		if ($this->Debug) {
+			printf("Debug: query = %s<br>\n", $queryString);
+		}
+		if ($log === true || (isset($GLOBALS['log_queries']) && $GLOBALS['log_queries'] !== false)) {
+			$this->log($queryString, $line, $file);
+		}
+		$tries = 2;
+		$try = 0;
+		$this->queryId = false;
+		while ((null === $this->queryId || $this->queryId === false) && $try <= $tries) {
+			$try++;
+			if ($try > 1) {
+				@mysqli_close($this->linkId);
+				$this->linkId = 0;
+			}
+			$start = microtime(true);
+			$onlyRollback = true;
+			$fails = -1;
+			while ($fails < 30 && (null === $this->queryId || $this->queryId === false)) {
+				$this->connect();
+				$fails++;
+				try {
+					$this->queryId = @mysqli_query($this->linkId, $queryString, MYSQLI_STORE_RESULT);
+					if (in_array((int)@mysqli_errno($this->linkId), [1213, 2006, 3101, 1180])) {
+						//error_log("got ".@mysqli_errno($this->linkId)." sql error fails {$fails} on query {$queryString} from {$line}:{$file}");
+						usleep(250000); // 0.25 second
+					} else {
+						$onlyRollback = false;
+						if (in_array((int)@mysqli_errno($this->linkId), [1064])) {
+							$tries = 0;
+						}
+						break;
+					}
+				} catch (\mysqli_sql_exception $e) {
+					if (in_array((int)$e->getCode(), [1213, 2006, 3101, 1180])) {
+						//error_log("got ".$e->getCode()." sql error fails {$fails}");
+						usleep(250000); // 0.25 second
+					} else {
+						error_log('Got mysqli_sql_exception code '.$e->getCode().' error '.$e->getMessage().' on query '.$queryString.' from '.$line.':'.$file);
+						$onlyRollback = false;
+						if (in_array((int)@mysqli_errno($this->linkId), [1064])) {
+							$tries = 0;
+						}
+						break;
+					}
+				}
+			}
+			if (!isset($GLOBALS['disable_db_queries'])) {
+				$this->addLog($queryString, microtime(true) - $start, $line, $file);
+			}
+			$this->Row = 0;
+			$this->Errno = @mysqli_errno($this->linkId);
+			$this->Error = @mysqli_error($this->linkId);
+			if ($try == 1 && (null === $this->queryId || $this->queryId === false)) {
+				//$this->emailError($queryString, 'Error #'.$this->Errno.': '.$this->Error, $line, $file);
+			}
+		}
+		$this->haltOnError = $haltPrev;
+		if ($onlyRollback === true && false === $this->queryId) {
+			error_log('Got MySQLi 3101 Rollback Error '.$fails.' Times, Giving Up on '.$queryString.' from '.$line.':'.$file.' on '.__LINE__.':'.__FILE__);
+		}
+		if (null === $this->queryId || $this->queryId === false) {
+			$this->emailError($queryString, 'Error #'.$this->Errno.': '.$this->Error, $line, $file);
+			$this->halt('', $line, $file);
+		}
+
+		// Will return nada if it fails. That's fine.
+		return $this->queryId;
+	}
+
+	/**
+	 * @return array|null|object
+	 */
+	public function fetchObject()
+	{
+		$this->Record = @mysqli_fetch_object($this->queryId);
+		return $this->Record;
+	}
+
+	/* public: walk result set */
+
+	/**
+	 * Db::next_record()
+	 *
+	 * @param mixed $resultType
+	 * @return bool
+	 */
+	public function next_record($resultType = MYSQLI_BOTH)
+	{
+		if ($this->queryId === false) {
+			$this->haltmsg('next_record called with no query pending.');
+			return 0;
+		}
+
+		$this->Record = @mysqli_fetch_array($this->queryId, $resultType);
+		++$this->Row;
+		$this->Errno = mysqli_errno($this->linkId);
+		$this->Error = mysqli_error($this->linkId);
+
+		$stat = is_array($this->Record);
+		if (!$stat && $this->autoFree && is_resource($this->queryId)) {
+			$this->free();
+		}
+		return $stat;
+	}
+
+	/**
+	 * switch to position in result set
+	 *
+	 * @param integer $pos the row numbe starting at 0 to switch to
+	 * @return bool whetherit was successfu or not.
+	 */
+	public function seek($pos = 0)
+	{
+		$status = @mysqli_data_seek($this->queryId, $pos);
+		if ($status) {
+			$this->Row = $pos;
+		} else {
+			$this->haltmsg("seek({$pos}) failed: result has ".$this->num_rows().' rows', __LINE__, __FILE__);
+			/* half assed attempt to save the day, but do not consider this documented or even desirable behaviour. */
+			$rows = $this->num_rows();
+			@mysqli_data_seek($this->queryId, $rows);
+			$this->Row = $rows;
+			return false;
+		}
+		return true;
+	}
+
+	/**
+	 * Initiates a transaction
+	 *
+	 * @return bool
+	 */
+	public function transactionBegin()
+	{
+		if (version_compare(PHP_VERSION, '5.5.0') < 0) {
+			return true;
+		}
+		if (!$this->connect()) {
+			return 0;
+		}
+		return mysqli_begin_transaction($this->linkId);
+	}
+
+	/**
+	 * Commits a transaction
+	 *
+	 * @return bool
+	 */
+	public function transactionCommit()
+	{
+		if (version_compare(PHP_VERSION, '5.5.0') < 0 || $this->linkId === 0) {
+			return true;
+		}
+		return mysqli_commit($this->linkId);
+	}
+
+	/**
+	 * Rolls back a transaction
+	 *
+	 * @return bool
+	 */
+	public function transactionAbort()
+	{
+		if (version_compare(PHP_VERSION, '5.5.0') < 0 || $this->linkId === 0) {
+			return true;
+		}
+		return mysqli_rollback($this->linkId);
+	}
+
+	/**
+	 * This will get the last insert ID created on the current connection.  Should only be called after an insert query is
+	 * run on a table that has an auto incrementing field.  $table and $field are required, but unused here since it's
+	 * unnecessary for mysql.  For compatibility with pgsql, the params must be supplied.
+	 *
+	 * @param string $table
+	 * @param string $field
+	 * @return int|string
+	 */
+	public function getLastInsertId($table, $field)
+	{
+		if (!isset($table) || $table == '' || !isset($field) || $field == '') {
+			return -1;
+		}
+
+		return @mysqli_insert_id($this->linkId);
+	}
+
+	/* public: table locking */
+
+	/**
+	 * Db::lock()
+	 * @param mixed  $table
+	 * @param string $mode
+	 * @return bool|int|\mysqli_result
+	 */
+	public function lock($table, $mode = 'write')
+	{
+		$this->connect();
+		$query = 'lock tables ';
+		if (is_array($table)) {
+			foreach ($table as $key => $value) {
+				if ($key == 'read' && $key != 0) {
+					$query .= "$value read, ";
+				} else {
+					$query .= "$value $mode, ";
+				}
+			}
+			$query = mb_substr($query, 0, -2);
+		} else {
+			$query .= "$table $mode";
+		}
+		$res = @mysqli_query($this->linkId, $query);
+		if (!$res) {
+			$this->halt("lock($table, $mode) failed.");
+			return 0;
+		}
+		return $res;
+	}
+
+	/**
+	 * Db::unlock()
+	 * @param bool $haltOnError optional, defaults to TRUE, whether or not to halt on error
+	 * @return bool|int|\mysqli_result
+	 */
+	public function unlock($haltOnError = true)
+	{
+		$this->connect();
+
+		$res = @mysqli_query($this->linkId, 'unlock tables');
+		if ($haltOnError === true && !$res) {
+			$this->halt('unlock() failed.');
+			return 0;
+		}
+		return $res;
+	}
+
+	/* public: evaluate the result (size, width) */
+
+	/**
+	 * Db::affectedRows()
+	 * @return int
+	 */
+	public function affectedRows()
+	{
+		return @mysqli_affected_rows($this->linkId);
+	}
+
+	/**
+	 * Db::num_rows()
+	 * @return int
+	 */
+	public function num_rows()
+	{
+		return @mysqli_num_rows($this->queryId);
+	}
+
+	/**
+	 * Db::num_fields()
+	 * @return int
+	 */
+	public function num_fields()
+	{
+		return @mysqli_num_fields($this->queryId);
+	}
+
+	/**
+	 * gets an array of the table names in teh current datase
+	 *
+	 * @return array
+	 */
+	public function tableNames()
+	{
+		$return = [];
+		$this->query('SHOW TABLES');
+		$i = 0;
+		while ($info = $this->queryId->fetch_row()) {
+			$return[$i]['table_name'] = $info[0];
+			$return[$i]['tablespace_name'] = $this->database;
+			$return[$i]['database'] = $this->database;
+			++$i;
+		}
+		return $return;
+	}
 }
 
 /**

Braces +24 added lines, -48 removed lines

@@ -17,8 +17,7 @@ 
  *
  * @access public
  */
-class Db extends Generic implements Db_Interface
-{
+class Db extends Generic implements Db_Interface {
     /**
      * @var string
      */
@@ -30,8 +29,7 @@ 
      * @param string $database the name of the database to use
      * @return void
      */
-    public function useDb($database)
-    {
+    public function useDb($database) {
         $this->selectDb($database);
     }
 
@@ -41,8 +39,7 @@ 
      * @param string $database the name of the database to use
      * @return void
      */
-    public function selectDb($database)
-    {
+    public function selectDb($database) {
         $this->connect();
         mysqli_select_db($this->linkId, $database);
     }
@@ -57,8 +54,7 @@ 
      * @param string $password
      * @return int|\mysqli
      */
-    public function connect($database = '', $host = '', $user = '', $password = '', $port = '')
-    {
+    public function connect($database = '', $host = '', $user = '', $password = '', $port = '') {
         /* Handle defaults */
         if ($database == '') {
             $database = $this->database;
@@ -105,8 +101,7 @@ 
      * Db::disconnect()
      * @return bool
      */
-    public function disconnect()
-    {
+    public function disconnect() {
         $return = !is_int($this->linkId) && method_exists($this->linkId, 'close') ? $this->linkId->close() : false;
         $this->linkId = 0;
         return $return;
@@ -116,8 +111,7 @@ 
      * @param $string
      * @return string
      */
-    public function real_escape($string = '')
-    {
+    public function real_escape($string = '') {
         if ((!is_resource($this->linkId) || $this->linkId == 0) && !$this->connect()) {
             return $this->escape($string);
         }
@@ -128,8 +122,7 @@ 
      * discard the query result
      * @return void
      */
-    public function free()
-    {
+    public function free() {
         if (is_resource($this->queryId)) {
             @mysqli_free_result($this->queryId);
         }
@@ -147,8 +140,7 @@ 
      * @param string $file optionally pass __FILE__ calling the query for logging
      * @return mixed FALSE if no rows, if a single row it returns that, if multiple it returns an array of rows, associative responses only
      */
-    public function queryReturn($query, $line = '', $file = '')
-    {
+    public function queryReturn($query, $line = '', $file = '') {
         $this->query($query, $line, $file);
         if ($this->num_rows() == 0) {
             return false;
@@ -174,8 +166,7 @@ 
      * @param string $file optionally pass __FILE__ calling the query for logging
      * @return mixed FALSE if no rows, if a single row it returns that, if multiple it returns an array of rows, associative responses only
      */
-    public function qr($query, $line = '', $file = '')
-    {
+    public function qr($query, $line = '', $file = '') {
         return $this->queryReturn($query, $line, $file);
     }
 
@@ -187,8 +178,7 @@ 
      * @param string $line
      * @param string $file
      */
-    public function prepare($query, $line = '', $file = '')
-    {
+    public function prepare($query, $line = '', $file = '') {
         if (!$this->connect()) {
             return 0;
         }
@@ -213,8 +203,7 @@ 
      * @param bool $log
      * @return mixed 0 if no query or query id handler, safe to ignore this return
      */
-    public function query($queryString, $line = '', $file = '', $log = false)
-    {
+    public function query($queryString, $line = '', $file = '', $log = false) {
         /* No empty queries, please, since PHP4 chokes on them. */
         /* The empty query string is passed on from the constructor,
         * when calling the class without a query, e.g. in situations
@@ -306,8 +295,7 @@ 
     /**
      * @return array|null|object
      */
-    public function fetchObject()
-    {
+    public function fetchObject() {
         $this->Record = @mysqli_fetch_object($this->queryId);
         return $this->Record;
     }
@@ -320,8 +308,7 @@ 
      * @param mixed $resultType
      * @return bool
      */
-    public function next_record($resultType = MYSQLI_BOTH)
-    {
+    public function next_record($resultType = MYSQLI_BOTH) {
         if ($this->queryId === false) {
             $this->haltmsg('next_record called with no query pending.');
             return 0;
@@ -345,8 +332,7 @@ 
      * @param integer $pos the row numbe starting at 0 to switch to
      * @return bool whetherit was successfu or not.
      */
-    public function seek($pos = 0)
-    {
+    public function seek($pos = 0) {
         $status = @mysqli_data_seek($this->queryId, $pos);
         if ($status) {
             $this->Row = $pos;
@@ -366,8 +352,7 @@ 
      *
      * @return bool
      */
-    public function transactionBegin()
-    {
+    public function transactionBegin() {
         if (version_compare(PHP_VERSION, '5.5.0') < 0) {
             return true;
         }
@@ -382,8 +367,7 @@ 
      *
      * @return bool
      */
-    public function transactionCommit()
-    {
+    public function transactionCommit() {
         if (version_compare(PHP_VERSION, '5.5.0') < 0 || $this->linkId === 0) {
             return true;
         }
@@ -395,8 +379,7 @@ 
      *
      * @return bool
      */
-    public function transactionAbort()
-    {
+    public function transactionAbort() {
         if (version_compare(PHP_VERSION, '5.5.0') < 0 || $this->linkId === 0) {
             return true;
         }
@@ -412,8 +395,7 @@ 
      * @param string $field
      * @return int|string
      */
-    public function getLastInsertId($table, $field)
-    {
+    public function getLastInsertId($table, $field) {
         if (!isset($table) || $table == '' || !isset($field) || $field == '') {
             return -1;
         }
@@ -429,8 +411,7 @@ 
      * @param string $mode
      * @return bool|int|\mysqli_result
      */
-    public function lock($table, $mode = 'write')
-    {
+    public function lock($table, $mode = 'write') {
         $this->connect();
         $query = 'lock tables ';
         if (is_array($table)) {
@@ -458,8 +439,7 @@ 
      * @param bool $haltOnError optional, defaults to TRUE, whether or not to halt on error
      * @return bool|int|\mysqli_result
      */
-    public function unlock($haltOnError = true)
-    {
+    public function unlock($haltOnError = true) {
         $this->connect();
 
         $res = @mysqli_query($this->linkId, 'unlock tables');
@@ -476,8 +456,7 @@ 
      * Db::affectedRows()
      * @return int
      */
-    public function affectedRows()
-    {
+    public function affectedRows() {
         return @mysqli_affected_rows($this->linkId);
     }
 
@@ -485,8 +464,7 @@ 
      * Db::num_rows()
      * @return int
      */
-    public function num_rows()
-    {
+    public function num_rows() {
         return @mysqli_num_rows($this->queryId);
     }
 
@@ -494,8 +472,7 @@ 
      * Db::num_fields()
      * @return int
      */
-    public function num_fields()
-    {
+    public function num_fields() {
         return @mysqli_num_fields($this->queryId);
     }
 
@@ -504,8 +481,7 @@ 
      *
      * @return array
      */
-    public function tableNames()
-    {
+    public function tableNames() {
         $return = [];
         $this->query('SHOW TABLES');
         $i = 0;

src/Generic.php

Indentation +383 added lines, -383 removed lines

@@ -14,387 +14,387 @@
  */
 abstract class Generic
 {
-    /* public: connection parameters */
-    public $host = 'localhost';
-    public $database = '';
-    public $user = '';
-    public $password = '';
-    public $port = '';
-
-    /* public: configuration parameters */
-    public $autoStripslashes = false;
-    public $Debug = 0; // Set to 1 for debugging messages.
-    public $haltOnError = 'yes'; // "yes" (halt with message), "no" (ignore errors quietly), "report" (ignore error, but spit a warning)
-
-    public $maxConnectErrors = 5;
-    public $connectionAttempt = 0;
-    public $maxMatches = 10000000;
-
-    public $Type = 'mysql';
-
-    /**
-     * @var int
-     */
-    public $autoFree = 0; // Set to 1 for automatic mysql_free_result()
-
-    /* public: result array and current row number */
-    public $Record = [];
-    public $Row;
-
-    /* public: current error number and error text */
-    public $Errno = 0;
-    public $Error = '';
-
-    /* public: this is an api revision, not a CVS revision. */
-    public $type = 'generic';
-
-    /**
-     * @var int|object
-     */
-    public $linkId = 0;
-    public $queryId = 0;
-
-    public $characterSet = 'utf8mb4';
-    public $collation = 'utf8mb4_unicode_ci';
-
-    /**
-     * Logged queries.
-     * @var array
-     */
-    protected $log = [];
-
-    /**
-     * Constructs the db handler, can optionally specify connection parameters
-     *
-     * @param string $database Optional The database name
-     * @param string $user Optional The username to connect with
-     * @param string $password Optional The password to use
-     * @param string $host Optional The hostname where the server is, or default to localhost
-     * @param string $query Optional query to perform immediately
-     * @param string $port optional port for the connection
-     */
-    public function __construct($database = '', $user = '', $password = '', $host = 'localhost', $query = '', $port = '')
-    {
-        $this->database = $database;
-        $this->user = $user;
-        $this->password = $password;
-        $this->host = $host;
-        $this->port = $port;
-        if ($query != '') {
-            $this->query($query);
-        }
-        $this->connectionAttempt = 0;
-    }
-
-    /**
-     * @param string $message
-     * @param string $line
-     * @param string $file
-     * @return void
-     */
-    public function log($message, $line = '', $file = '', $level = 'info')
-    {
-        error_log('SQL Query '.$line.' '.$file.' '.$message);
-    }
-
-    /**
-     * @return int|object
-     */
-    public function linkId()
-    {
-        return $this->linkId;
-    }
-
-    /**
-     * @return int|object
-     */
-    public function queryId()
-    {
-        return $this->queryId;
-    }
-
-    /**
-     * @param $string
-     * @return string
-     */
-    public function real_escape($string = '')
-    {
-        if ((!is_resource($this->linkId) || $this->linkId == 0) && !$this->connect()) {
-            return $this->escape($string);
-        }
-        return mysqli_real_escape_string($this->linkId, $string);
-    }
-
-    /**
-     * @param $string
-     * @return string
-     */
-    public function escape($string = '')
-    {
-        //if (function_exists('mysql_escape_string'))
-        //return mysql_escape_string($string);
-        return str_replace(['\\', "\0", "\n", "\r", "'", '"', "\x1a"], ['\\\\', '\\0', '\\n', '\\r', "\\'", '\\"', '\\Z'], $string);
-    }
-
-    /**
-     * @param mixed $str
-     * @return string
-     */
-    public function dbAddslashes($str = '')
-    {
-        if (!isset($str) || $str == '') {
-            return '';
-        }
-        return addslashes($str);
-    }
-
-    /**
-     * Db::toTimestamp()
-     * @param mixed $epoch
-     * @return bool|string
-     */
-    public function toTimestamp($epoch)
-    {
-        return date('Y-m-d H:i:s', is_float($epoch) ? intval($epoch) : $epoch);
-    }
-
-    /**
-     * Db::fromTimestamp()
-     * @param mixed $timestamp
-     * @return bool|int|mixed
-     */
-    public function fromTimestamp($timestamp)
-    {
-        if (preg_match('/([0-9]{4})-([0-9]{2})-([0-9]{2}) ([0-9]{2}):([0-9]{2}):([0-9]{2})/', $timestamp, $parts)) {
-            $time = mktime($parts[4], $parts[5], $parts[6], $parts[2], $parts[3], $parts[1]);
-        } elseif (preg_match('/([0-9]{4})([0-9]{2})([0-9]{2})([0-9]{2})([0-9]{2})([0-9]{2})/', $timestamp, $parts)) {
-            $time = mktime($parts[4], $parts[5], $parts[6], $parts[2], $parts[3], $parts[1]);
-        } elseif (preg_match('/([0-9]{4})([0-9]{2})([0-9]{2})/', $timestamp, $parts)) {
-            $time = mktime(1, 1, 1, $parts[2], $parts[3], $parts[1]);
-        } elseif (is_numeric($timestamp) && $timestamp >= 943938000) {
-            $time = $timestamp;
-        } else {
-            $this->log('Cannot Match Timestamp from '.$timestamp, __LINE__, __FILE__);
-            $time = false;
-        }
-        return $time;
-    }
-
-    /**
-     * perform a query with limited result set
-     *
-     * @param string $queryString
-     * @param string|int $numRows
-     * @param int $offset
-     * @param string|int $line
-     * @param string $file
-     * @return mixed
-     */
-    public function limitQuery($queryString, $numRows = '', $offset = 0, $line = '', $file = '')
-    {
-        if (!$numRows) {
-            $numRows = $this->maxMatches;
-        }
-        if ($offset == 0) {
-            $queryString .= ' LIMIT '.(int) $numRows;
-        } else {
-            $queryString .= ' LIMIT '.(int) $offset.','.(int) $numRows;
-        }
-
-        if ($this->Debug) {
-            printf("Debug: limitQuery = %s<br>offset=%d, num_rows=%d<br>\n", $queryString, $offset, $numRows);
-        }
-
-        return $this->query($queryString, $line, $file);
-    }
-
-    /**
-     * db:qr()
-     *
-     *  alias of queryReturn()
-     *
-     * @param mixed $query SQL Query to be used
-     * @param string $line optionally pass __LINE__ calling the query for logging
-     * @param string $file optionally pass __FILE__ calling the query for logging
-     * @return mixed FALSE if no rows, if a single row it returns that, if multiple it returns an array of rows, associative responses only
-     */
-    public function qr($query, $line = '', $file = '')
-    {
-        return $this->queryReturn($query, $line, $file);
-    }
-
-    /**
-     * gets a field
-     *
-     * @param mixed  $name
-     * @param string $stripSlashes
-     * @return string
-     */
-    public function f($name, $stripSlashes = '')
-    {
-        if (is_null($this->Record)) {
-            return null;
-        } elseif ($stripSlashes || ($this->autoStripslashes && !$stripSlashes)) {
-            return stripslashes($this->Record[$name]);
-        } else {
-            return $this->Record[$name];
-        }
-    }
-
-    /**
-     * error handling
-     *
-     * @param mixed $msg
-     * @param string $line
-     * @param string $file
-     * @return void
-     */
-    public function halt($msg, $line = '', $file = '')
-    {
-        $this->unlock(false);
-        /* Just in case there is a table currently locked */
-
-        //$this->Error = @$this->linkId->error;
-        //$this->Errno = @$this->linkId->errno;
-        if ($this->haltOnError == 'no') {
-            return true;
-        }
-        if ($msg != '') {
-            $this->haltmsg($msg, $line, $file);
-        }
-        if ($this->haltOnError != 'report') {
-            echo '<p><b>Session halted.</b>';
-            //if (isset($GLOBALS['tf']))
-            //$GLOBALS['tf']->terminate();
-            die();
-        }
-        return true;
-    }
-
-    /**
-     * @param mixed $msg
-     * @param string $line
-     * @param string $file
-     * @return mixed|void
-     */
-    public function logBackTrace($msg, $line = '', $file = '')
-    {
-        $backtrace = (function_exists('debug_backtrace') ? debug_backtrace() : []);
-        $this->log(
-            ('' !== getenv('REQUEST_URI') ? ' '.getenv('REQUEST_URI') : '').
-            ((isset($_POST) && count($_POST)) ? ' POST='.json_encode($_POST) : '').
-            ((isset($_GET) && count($_GET)) ? ' GET='.json_encode($_GET) : '').
-            ((isset($_FILES) && count($_FILES)) ? ' FILES='.json_encode($_FILES) : '').
-            ('' !== getenv('HTTP_USER_AGENT') ? ' AGENT="'.getenv('HTTP_USER_AGENT').'"' : '').
-            (isset($_SERVER['REQUEST_METHOD']) ? ' METHOD="'.$_SERVER['REQUEST_METHOD'].'"'.
-                ($_SERVER['REQUEST_METHOD'] === 'POST' ? ' POST="'.json_encode($_POST).'"' : '') : ''),
-            $line,
-            $file,
-            'error'
-        );
-        for ($level = 1, $levelMax = count($backtrace); $level < $levelMax; $level++) {
-            $message = (isset($backtrace[$level]['file']) ? 'File: '.$backtrace[$level]['file'] : '').
-                (isset($backtrace[$level]['line']) ? ' Line: '.$backtrace[$level]['line'] : '').
-                ' Function: '.(isset($backtrace[$level] ['class']) ? '(class '.$backtrace[$level] ['class'].') ' : '').
-                (isset($backtrace[$level] ['type']) ? $backtrace[$level] ['type'].' ' : '').
-                $backtrace[$level] ['function'].'(';
-            if (isset($backtrace[$level] ['args'])) {
-                for ($argument = 0, $argumentMax = count($backtrace[$level]['args']); $argument < $argumentMax; $argument++) {
-                    $message .= ($argument > 0 ? ', ' : '').
-                        (is_object($backtrace[$level]['args'][$argument]) ? 'class '.get_class($backtrace[$level]['args'][$argument]) : json_encode($backtrace[$level]['args'][$argument]));
-                }
-            }
-            $message .= ')';
-            $this->log($message, $line, $file, 'error');
-        }
-    }
-
-    public function emailError($queryString, $error, $line, $file)
-    {
-        $subject = php_uname('n').' MySQLi Error '.$queryString;
-        if (class_exists('\\TFSmarty')) {
-            $smarty = new \TFSmarty();
-            $smarty->assign([
-                'type' => $this->type,
-                'queryString' => $queryString,
-                'error' => $error,
-                'line' => $line,
-                'file' => $file,
-                'request' => $_REQUEST,
-                'server' => $_SERVER,
-            ]);
-            if (isset($GLOBALS['tf'])) {
-                $smarty->assign('account_id', $GLOBALS['tf']->session->account_id);
-            }
-            $email = $smarty->fetch('email/admin/sql_error.tpl');
-            (new \MyAdmin\Mail())->adminMail($subject, $email, 'john@interserver.net', '');
-            (new \MyAdmin\Mail())->adminMail($subject, $email, 'detain@interserver.net', '');
-        }
-        $this->haltmsg('Invalid SQL: '.$queryString, $line, $file);
-    }
-
-    /**
-     * @param mixed $msg
-     * @param string $line
-     * @param string $file
-     * @return mixed|void
-     */
-    public function haltmsg($msg, $line = '', $file = '')
-    {
-        $email = "DB Error {$msg} {$file}:{$line}";
-        if (class_exists('\\MyAdmin\Mail')) {
-            \MyAdmin\Mail::failsafeMail($email, $email, ['detain@interserver.net', 'john@interserver.net']);
-            return;
-        }
-        $this->log("Database error: $msg", $line, $file, 'error');
-        if ($this->Errno != '0' || !in_array($this->Error, ['', '()'])) {
-            $sqlstate = mysqli_sqlstate($this->linkId);
-            $this->log("MySQLi SQLState: {$sqlstate}. Error: ".$this->Errno.' ('.$this->Error.')', $line, $file, 'error');
-        }
-        $this->logBackTrace($msg, $line, $file);
-    }
-
-    /**
-     * @return array
-     */
-    public function indexNames()
-    {
-        return [];
-    }
-
-
-    /**
-     * Add query to logged queries.
-     * @param string $statement
-     * @param float $time Elapsed seconds with microseconds
-     * @param string|int $line Line Number
-     * @param string $file File Name
-     */
-    public function addLog($statement, $time, $line = '', $file = '')
-    {
-        $query = [
-            'statement' => $statement,
-            'time' => $time * 1000
-        ];
-        if ($line != '') {
-            $query['line'] = $line;
-        }
-        if ($file != '') {
-            $query['file'] = $file;
-        }
-        if (!isset($GLOBALS['db_queries'])) {
-            $GLOBALS['db_queries'] = [];
-        }
-        $GLOBALS['db_queries'][] = $query;
-        array_push($this->log, $query);
-    }
-
-    /**
-     * Return logged queries.
-     * @return array Logged queries
-     */
-    public function getLog()
-    {
-        return $this->log;
-    }
+	/* public: connection parameters */
+	public $host = 'localhost';
+	public $database = '';
+	public $user = '';
+	public $password = '';
+	public $port = '';
+
+	/* public: configuration parameters */
+	public $autoStripslashes = false;
+	public $Debug = 0; // Set to 1 for debugging messages.
+	public $haltOnError = 'yes'; // "yes" (halt with message), "no" (ignore errors quietly), "report" (ignore error, but spit a warning)
+
+	public $maxConnectErrors = 5;
+	public $connectionAttempt = 0;
+	public $maxMatches = 10000000;
+
+	public $Type = 'mysql';
+
+	/**
+	 * @var int
+	 */
+	public $autoFree = 0; // Set to 1 for automatic mysql_free_result()
+
+	/* public: result array and current row number */
+	public $Record = [];
+	public $Row;
+
+	/* public: current error number and error text */
+	public $Errno = 0;
+	public $Error = '';
+
+	/* public: this is an api revision, not a CVS revision. */
+	public $type = 'generic';
+
+	/**
+	 * @var int|object
+	 */
+	public $linkId = 0;
+	public $queryId = 0;
+
+	public $characterSet = 'utf8mb4';
+	public $collation = 'utf8mb4_unicode_ci';
+
+	/**
+	 * Logged queries.
+	 * @var array
+	 */
+	protected $log = [];
+
+	/**
+	 * Constructs the db handler, can optionally specify connection parameters
+	 *
+	 * @param string $database Optional The database name
+	 * @param string $user Optional The username to connect with
+	 * @param string $password Optional The password to use
+	 * @param string $host Optional The hostname where the server is, or default to localhost
+	 * @param string $query Optional query to perform immediately
+	 * @param string $port optional port for the connection
+	 */
+	public function __construct($database = '', $user = '', $password = '', $host = 'localhost', $query = '', $port = '')
+	{
+		$this->database = $database;
+		$this->user = $user;
+		$this->password = $password;
+		$this->host = $host;
+		$this->port = $port;
+		if ($query != '') {
+			$this->query($query);
+		}
+		$this->connectionAttempt = 0;
+	}
+
+	/**
+	 * @param string $message
+	 * @param string $line
+	 * @param string $file
+	 * @return void
+	 */
+	public function log($message, $line = '', $file = '', $level = 'info')
+	{
+		error_log('SQL Query '.$line.' '.$file.' '.$message);
+	}
+
+	/**
+	 * @return int|object
+	 */
+	public function linkId()
+	{
+		return $this->linkId;
+	}
+
+	/**
+	 * @return int|object
+	 */
+	public function queryId()
+	{
+		return $this->queryId;
+	}
+
+	/**
+	 * @param $string
+	 * @return string
+	 */
+	public function real_escape($string = '')
+	{
+		if ((!is_resource($this->linkId) || $this->linkId == 0) && !$this->connect()) {
+			return $this->escape($string);
+		}
+		return mysqli_real_escape_string($this->linkId, $string);
+	}
+
+	/**
+	 * @param $string
+	 * @return string
+	 */
+	public function escape($string = '')
+	{
+		//if (function_exists('mysql_escape_string'))
+		//return mysql_escape_string($string);
+		return str_replace(['\\', "\0", "\n", "\r", "'", '"', "\x1a"], ['\\\\', '\\0', '\\n', '\\r', "\\'", '\\"', '\\Z'], $string);
+	}
+
+	/**
+	 * @param mixed $str
+	 * @return string
+	 */
+	public function dbAddslashes($str = '')
+	{
+		if (!isset($str) || $str == '') {
+			return '';
+		}
+		return addslashes($str);
+	}
+
+	/**
+	 * Db::toTimestamp()
+	 * @param mixed $epoch
+	 * @return bool|string
+	 */
+	public function toTimestamp($epoch)
+	{
+		return date('Y-m-d H:i:s', is_float($epoch) ? intval($epoch) : $epoch);
+	}
+
+	/**
+	 * Db::fromTimestamp()
+	 * @param mixed $timestamp
+	 * @return bool|int|mixed
+	 */
+	public function fromTimestamp($timestamp)
+	{
+		if (preg_match('/([0-9]{4})-([0-9]{2})-([0-9]{2}) ([0-9]{2}):([0-9]{2}):([0-9]{2})/', $timestamp, $parts)) {
+			$time = mktime($parts[4], $parts[5], $parts[6], $parts[2], $parts[3], $parts[1]);
+		} elseif (preg_match('/([0-9]{4})([0-9]{2})([0-9]{2})([0-9]{2})([0-9]{2})([0-9]{2})/', $timestamp, $parts)) {
+			$time = mktime($parts[4], $parts[5], $parts[6], $parts[2], $parts[3], $parts[1]);
+		} elseif (preg_match('/([0-9]{4})([0-9]{2})([0-9]{2})/', $timestamp, $parts)) {
+			$time = mktime(1, 1, 1, $parts[2], $parts[3], $parts[1]);
+		} elseif (is_numeric($timestamp) && $timestamp >= 943938000) {
+			$time = $timestamp;
+		} else {
+			$this->log('Cannot Match Timestamp from '.$timestamp, __LINE__, __FILE__);
+			$time = false;
+		}
+		return $time;
+	}
+
+	/**
+	 * perform a query with limited result set
+	 *
+	 * @param string $queryString
+	 * @param string|int $numRows
+	 * @param int $offset
+	 * @param string|int $line
+	 * @param string $file
+	 * @return mixed
+	 */
+	public function limitQuery($queryString, $numRows = '', $offset = 0, $line = '', $file = '')
+	{
+		if (!$numRows) {
+			$numRows = $this->maxMatches;
+		}
+		if ($offset == 0) {
+			$queryString .= ' LIMIT '.(int) $numRows;
+		} else {
+			$queryString .= ' LIMIT '.(int) $offset.','.(int) $numRows;
+		}
+
+		if ($this->Debug) {
+			printf("Debug: limitQuery = %s<br>offset=%d, num_rows=%d<br>\n", $queryString, $offset, $numRows);
+		}
+
+		return $this->query($queryString, $line, $file);
+	}
+
+	/**
+	 * db:qr()
+	 *
+	 *  alias of queryReturn()
+	 *
+	 * @param mixed $query SQL Query to be used
+	 * @param string $line optionally pass __LINE__ calling the query for logging
+	 * @param string $file optionally pass __FILE__ calling the query for logging
+	 * @return mixed FALSE if no rows, if a single row it returns that, if multiple it returns an array of rows, associative responses only
+	 */
+	public function qr($query, $line = '', $file = '')
+	{
+		return $this->queryReturn($query, $line, $file);
+	}
+
+	/**
+	 * gets a field
+	 *
+	 * @param mixed  $name
+	 * @param string $stripSlashes
+	 * @return string
+	 */
+	public function f($name, $stripSlashes = '')
+	{
+		if (is_null($this->Record)) {
+			return null;
+		} elseif ($stripSlashes || ($this->autoStripslashes && !$stripSlashes)) {
+			return stripslashes($this->Record[$name]);
+		} else {
+			return $this->Record[$name];
+		}
+	}
+
+	/**
+	 * error handling
+	 *
+	 * @param mixed $msg
+	 * @param string $line
+	 * @param string $file
+	 * @return void
+	 */
+	public function halt($msg, $line = '', $file = '')
+	{
+		$this->unlock(false);
+		/* Just in case there is a table currently locked */
+
+		//$this->Error = @$this->linkId->error;
+		//$this->Errno = @$this->linkId->errno;
+		if ($this->haltOnError == 'no') {
+			return true;
+		}
+		if ($msg != '') {
+			$this->haltmsg($msg, $line, $file);
+		}
+		if ($this->haltOnError != 'report') {
+			echo '<p><b>Session halted.</b>';
+			//if (isset($GLOBALS['tf']))
+			//$GLOBALS['tf']->terminate();
+			die();
+		}
+		return true;
+	}
+
+	/**
+	 * @param mixed $msg
+	 * @param string $line
+	 * @param string $file
+	 * @return mixed|void
+	 */
+	public function logBackTrace($msg, $line = '', $file = '')
+	{
+		$backtrace = (function_exists('debug_backtrace') ? debug_backtrace() : []);
+		$this->log(
+			('' !== getenv('REQUEST_URI') ? ' '.getenv('REQUEST_URI') : '').
+			((isset($_POST) && count($_POST)) ? ' POST='.json_encode($_POST) : '').
+			((isset($_GET) && count($_GET)) ? ' GET='.json_encode($_GET) : '').
+			((isset($_FILES) && count($_FILES)) ? ' FILES='.json_encode($_FILES) : '').
+			('' !== getenv('HTTP_USER_AGENT') ? ' AGENT="'.getenv('HTTP_USER_AGENT').'"' : '').
+			(isset($_SERVER['REQUEST_METHOD']) ? ' METHOD="'.$_SERVER['REQUEST_METHOD'].'"'.
+				($_SERVER['REQUEST_METHOD'] === 'POST' ? ' POST="'.json_encode($_POST).'"' : '') : ''),
+			$line,
+			$file,
+			'error'
+		);
+		for ($level = 1, $levelMax = count($backtrace); $level < $levelMax; $level++) {
+			$message = (isset($backtrace[$level]['file']) ? 'File: '.$backtrace[$level]['file'] : '').
+				(isset($backtrace[$level]['line']) ? ' Line: '.$backtrace[$level]['line'] : '').
+				' Function: '.(isset($backtrace[$level] ['class']) ? '(class '.$backtrace[$level] ['class'].') ' : '').
+				(isset($backtrace[$level] ['type']) ? $backtrace[$level] ['type'].' ' : '').
+				$backtrace[$level] ['function'].'(';
+			if (isset($backtrace[$level] ['args'])) {
+				for ($argument = 0, $argumentMax = count($backtrace[$level]['args']); $argument < $argumentMax; $argument++) {
+					$message .= ($argument > 0 ? ', ' : '').
+						(is_object($backtrace[$level]['args'][$argument]) ? 'class '.get_class($backtrace[$level]['args'][$argument]) : json_encode($backtrace[$level]['args'][$argument]));
+				}
+			}
+			$message .= ')';
+			$this->log($message, $line, $file, 'error');
+		}
+	}
+
+	public function emailError($queryString, $error, $line, $file)
+	{
+		$subject = php_uname('n').' MySQLi Error '.$queryString;
+		if (class_exists('\\TFSmarty')) {
+			$smarty = new \TFSmarty();
+			$smarty->assign([
+				'type' => $this->type,
+				'queryString' => $queryString,
+				'error' => $error,
+				'line' => $line,
+				'file' => $file,
+				'request' => $_REQUEST,
+				'server' => $_SERVER,
+			]);
+			if (isset($GLOBALS['tf'])) {
+				$smarty->assign('account_id', $GLOBALS['tf']->session->account_id);
+			}
+			$email = $smarty->fetch('email/admin/sql_error.tpl');
+			(new \MyAdmin\Mail())->adminMail($subject, $email, 'john@interserver.net', '');
+			(new \MyAdmin\Mail())->adminMail($subject, $email, 'detain@interserver.net', '');
+		}
+		$this->haltmsg('Invalid SQL: '.$queryString, $line, $file);
+	}
+
+	/**
+	 * @param mixed $msg
+	 * @param string $line
+	 * @param string $file
+	 * @return mixed|void
+	 */
+	public function haltmsg($msg, $line = '', $file = '')
+	{
+		$email = "DB Error {$msg} {$file}:{$line}";
+		if (class_exists('\\MyAdmin\Mail')) {
+			\MyAdmin\Mail::failsafeMail($email, $email, ['detain@interserver.net', 'john@interserver.net']);
+			return;
+		}
+		$this->log("Database error: $msg", $line, $file, 'error');
+		if ($this->Errno != '0' || !in_array($this->Error, ['', '()'])) {
+			$sqlstate = mysqli_sqlstate($this->linkId);
+			$this->log("MySQLi SQLState: {$sqlstate}. Error: ".$this->Errno.' ('.$this->Error.')', $line, $file, 'error');
+		}
+		$this->logBackTrace($msg, $line, $file);
+	}
+
+	/**
+	 * @return array
+	 */
+	public function indexNames()
+	{
+		return [];
+	}
+
+
+	/**
+	 * Add query to logged queries.
+	 * @param string $statement
+	 * @param float $time Elapsed seconds with microseconds
+	 * @param string|int $line Line Number
+	 * @param string $file File Name
+	 */
+	public function addLog($statement, $time, $line = '', $file = '')
+	{
+		$query = [
+			'statement' => $statement,
+			'time' => $time * 1000
+		];
+		if ($line != '') {
+			$query['line'] = $line;
+		}
+		if ($file != '') {
+			$query['file'] = $file;
+		}
+		if (!isset($GLOBALS['db_queries'])) {
+			$GLOBALS['db_queries'] = [];
+		}
+		$GLOBALS['db_queries'][] = $query;
+		array_push($this->log, $query);
+	}
+
+	/**
+	 * Return logged queries.
+	 * @return array Logged queries
+	 */
+	public function getLog()
+	{
+		return $this->log;
+	}
 }

Braces +20 added lines, -40 removed lines

@@ -12,8 +12,7 @@ 
 /**
  * Class Generic
  */
-abstract class Generic
-{
+abstract class Generic {
     /* public: connection parameters */
     public $host = 'localhost';
     public $database = '';
@@ -73,8 +72,7 @@ 
      * @param string $query Optional query to perform immediately
      * @param string $port optional port for the connection
      */
-    public function __construct($database = '', $user = '', $password = '', $host = 'localhost', $query = '', $port = '')
-    {
+    public function __construct($database = '', $user = '', $password = '', $host = 'localhost', $query = '', $port = '') {
         $this->database = $database;
         $this->user = $user;
         $this->password = $password;
@@ -92,24 +90,21 @@ 
      * @param string $file
      * @return void
      */
-    public function log($message, $line = '', $file = '', $level = 'info')
-    {
+    public function log($message, $line = '', $file = '', $level = 'info') {
         error_log('SQL Query '.$line.' '.$file.' '.$message);
     }
 
     /**
      * @return int|object
      */
-    public function linkId()
-    {
+    public function linkId() {
         return $this->linkId;
     }
 
     /**
      * @return int|object
      */
-    public function queryId()
-    {
+    public function queryId() {
         return $this->queryId;
     }
 
@@ -117,8 +112,7 @@ 
      * @param $string
      * @return string
      */
-    public function real_escape($string = '')
-    {
+    public function real_escape($string = '') {
         if ((!is_resource($this->linkId) || $this->linkId == 0) && !$this->connect()) {
             return $this->escape($string);
         }
@@ -129,8 +123,7 @@ 
      * @param $string
      * @return string
      */
-    public function escape($string = '')
-    {
+    public function escape($string = '') {
         //if (function_exists('mysql_escape_string'))
         //return mysql_escape_string($string);
         return str_replace(['\\', "\0", "\n", "\r", "'", '"', "\x1a"], ['\\\\', '\\0', '\\n', '\\r', "\\'", '\\"', '\\Z'], $string);
@@ -140,8 +133,7 @@ 
      * @param mixed $str
      * @return string
      */
-    public function dbAddslashes($str = '')
-    {
+    public function dbAddslashes($str = '') {
         if (!isset($str) || $str == '') {
             return '';
         }
@@ -153,8 +145,7 @@ 
      * @param mixed $epoch
      * @return bool|string
      */
-    public function toTimestamp($epoch)
-    {
+    public function toTimestamp($epoch) {
         return date('Y-m-d H:i:s', is_float($epoch) ? intval($epoch) : $epoch);
     }
 
@@ -163,8 +154,7 @@ 
      * @param mixed $timestamp
      * @return bool|int|mixed
      */
-    public function fromTimestamp($timestamp)
-    {
+    public function fromTimestamp($timestamp) {
         if (preg_match('/([0-9]{4})-([0-9]{2})-([0-9]{2}) ([0-9]{2}):([0-9]{2}):([0-9]{2})/', $timestamp, $parts)) {
             $time = mktime($parts[4], $parts[5], $parts[6], $parts[2], $parts[3], $parts[1]);
         } elseif (preg_match('/([0-9]{4})([0-9]{2})([0-9]{2})([0-9]{2})([0-9]{2})([0-9]{2})/', $timestamp, $parts)) {
@@ -190,8 +180,7 @@ 
      * @param string $file
      * @return mixed
      */
-    public function limitQuery($queryString, $numRows = '', $offset = 0, $line = '', $file = '')
-    {
+    public function limitQuery($queryString, $numRows = '', $offset = 0, $line = '', $file = '') {
         if (!$numRows) {
             $numRows = $this->maxMatches;
         }
@@ -218,8 +207,7 @@ 
      * @param string $file optionally pass __FILE__ calling the query for logging
      * @return mixed FALSE if no rows, if a single row it returns that, if multiple it returns an array of rows, associative responses only
      */
-    public function qr($query, $line = '', $file = '')
-    {
+    public function qr($query, $line = '', $file = '') {
         return $this->queryReturn($query, $line, $file);
     }
 
@@ -230,8 +218,7 @@ 
      * @param string $stripSlashes
      * @return string
      */
-    public function f($name, $stripSlashes = '')
-    {
+    public function f($name, $stripSlashes = '') {
         if (is_null($this->Record)) {
             return null;
         } elseif ($stripSlashes || ($this->autoStripslashes && !$stripSlashes)) {
@@ -249,8 +236,7 @@ 
      * @param string $file
      * @return void
      */
-    public function halt($msg, $line = '', $file = '')
-    {
+    public function halt($msg, $line = '', $file = '') {
         $this->unlock(false);
         /* Just in case there is a table currently locked */
 
@@ -277,8 +263,7 @@ 
      * @param string $file
      * @return mixed|void
      */
-    public function logBackTrace($msg, $line = '', $file = '')
-    {
+    public function logBackTrace($msg, $line = '', $file = '') {
         $backtrace = (function_exists('debug_backtrace') ? debug_backtrace() : []);
         $this->log(
             ('' !== getenv('REQUEST_URI') ? ' '.getenv('REQUEST_URI') : '').
@@ -309,8 +294,7 @@ 
         }
     }
 
-    public function emailError($queryString, $error, $line, $file)
-    {
+    public function emailError($queryString, $error, $line, $file) {
         $subject = php_uname('n').' MySQLi Error '.$queryString;
         if (class_exists('\\TFSmarty')) {
             $smarty = new \TFSmarty();
@@ -339,8 +323,7 @@ 
      * @param string $file
      * @return mixed|void
      */
-    public function haltmsg($msg, $line = '', $file = '')
-    {
+    public function haltmsg($msg, $line = '', $file = '') {
         $email = "DB Error {$msg} {$file}:{$line}";
         if (class_exists('\\MyAdmin\Mail')) {
             \MyAdmin\Mail::failsafeMail($email, $email, ['detain@interserver.net', 'john@interserver.net']);
@@ -357,8 +340,7 @@ 
     /**
      * @return array
      */
-    public function indexNames()
-    {
+    public function indexNames() {
         return [];
     }
 
@@ -370,8 +352,7 @@ 
      * @param string|int $line Line Number
      * @param string $file File Name
      */
-    public function addLog($statement, $time, $line = '', $file = '')
-    {
+    public function addLog($statement, $time, $line = '', $file = '') {
         $query = [
             'statement' => $statement,
             'time' => $time * 1000
@@ -393,8 +374,7 @@ 
      * Return logged queries.
      * @return array Logged queries
      */
-    public function getLog()
-    {
+    public function getLog() {
         return $this->log;
     }
 }