detain / db_abstraction

src/Mysqli/Db.php

Indentation +534 added lines, -534 removed lines

@@ -19,543 +19,543 @@
 */
 class Db extends Generic implements Db_Interface
 {
-    /**
-    * @var string
-    */
-    public $type = 'mysqli';
-    public $statement;
-    public $statement_query;
-    public $statement_vars;
-
-    /**
-    * 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}");
-                exit;
-            }
-            if ($this->connectionAttempt >= $this->maxConnectErrors) {
-                $this->halt("connect($host, $user, \$password) failed. ".(is_object($this->linkId) && isset( $this->linkId->connect_error) ? $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. ".(is_object($this->linkId) && isset( $this->linkId->connect_error) ? $this->linkId->connect_error : ''));
-                return 0;
-            }
-            $this->linkId->set_charset($this->characterSet);
-            if ($this->linkId->connect_errno) {
-                $this->halt("connect($host, $user, \$password) failed. ".(is_object($this->linkId) && isset( $this->linkId->connect_error) ? $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 false|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);
-        $this->statement = mysqli_prepare($this->linkId, $query);
-        if (!isset($GLOBALS['disable_db_queries'])) {
-            $this->statement_query = $query;
-            $this->addLog($query, microtime(true) - $start, $line, $file);
-        }
-        return $this->statement;
-    }
-
-    /**
-    * Binds variables to a prepared statement as parameters
-    * 
-    * @param string $types A string that contains one or more characters which specify the types for the corresponding bind variables: (i)nt, (d)ecimal, (s)tring, (b)inary 
-    * @param mixed $vars
-    * @return bool indicates success
-    */
-    public function bind_param($types, &...$vars) {
-        $params = [$this->statement, $types];
-        foreach ($vars as &$var) {
-            $params[] = &$var; // Ensure they stay references
-        }
-        $this->statement_vars &= $vars;
-        return call_user_func_array('mysqli_stmt_bind_param', $params);
-    }
-
-    /**
-    * Executes a prepared statement
-    * 
-    * @return bool success
-    */
-    public function execute($line = '', $file = '') {
-        $start = microtime(true);
-        $return = mysqli_stmt_execute($this->statement);
-        if (!isset($GLOBALS['disable_db_queries'])) {
-            $vars = $this->statement_vars;
-            $query = $result = preg_replace_callback('/\?/', function () use (&$vars) {
-                return array_shift($vars);
-                }, $this->statement_query);
-            $this->addLog($query, microtime(true) - $start, $line, $file);
-        }
-        return $return;
-    }
-
-    /**
-    * 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';
+	public $statement;
+	public $statement_query;
+	public $statement_vars;
+
+	/**
+	 * 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}");
+				exit;
+			}
+			if ($this->connectionAttempt >= $this->maxConnectErrors) {
+				$this->halt("connect($host, $user, \$password) failed. ".(is_object($this->linkId) && isset( $this->linkId->connect_error) ? $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. ".(is_object($this->linkId) && isset( $this->linkId->connect_error) ? $this->linkId->connect_error : ''));
+				return 0;
+			}
+			$this->linkId->set_charset($this->characterSet);
+			if ($this->linkId->connect_errno) {
+				$this->halt("connect($host, $user, \$password) failed. ".(is_object($this->linkId) && isset( $this->linkId->connect_error) ? $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 false|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);
+		$this->statement = mysqli_prepare($this->linkId, $query);
+		if (!isset($GLOBALS['disable_db_queries'])) {
+			$this->statement_query = $query;
+			$this->addLog($query, microtime(true) - $start, $line, $file);
+		}
+		return $this->statement;
+	}
+
+	/**
+	 * Binds variables to a prepared statement as parameters
+	 * 
+	 * @param string $types A string that contains one or more characters which specify the types for the corresponding bind variables: (i)nt, (d)ecimal, (s)tring, (b)inary 
+	 * @param mixed $vars
+	 * @return bool indicates success
+	 */
+	public function bind_param($types, &...$vars) {
+		$params = [$this->statement, $types];
+		foreach ($vars as &$var) {
+			$params[] = &$var; // Ensure they stay references
+		}
+		$this->statement_vars &= $vars;
+		return call_user_func_array('mysqli_stmt_bind_param', $params);
+	}
+
+	/**
+	 * Executes a prepared statement
+	 * 
+	 * @return bool success
+	 */
+	public function execute($line = '', $file = '') {
+		$start = microtime(true);
+		$return = mysqli_stmt_execute($this->statement);
+		if (!isset($GLOBALS['disable_db_queries'])) {
+			$vars = $this->statement_vars;
+			$query = $result = preg_replace_callback('/\?/', function () use (&$vars) {
+				return array_shift($vars);
+				}, $this->statement_query);
+			$this->addLog($query, microtime(true) - $start, $line, $file);
+		}
+		return $return;
+	}
+
+	/**
+	 * 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;
+	}
 }
 
 /**

Spacing +8 added lines, -8 removed lines

@@ -86,19 +86,19 @@ 
                 exit;
             }
             if ($this->connectionAttempt >= $this->maxConnectErrors) {
-                $this->halt("connect($host, $user, \$password) failed. ".(is_object($this->linkId) && isset( $this->linkId->connect_error) ? $this->linkId->connect_error : ''));
+                $this->halt("connect($host, $user, \$password) failed. ".(is_object($this->linkId) && isset($this->linkId->connect_error) ? $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. ".(is_object($this->linkId) && isset( $this->linkId->connect_error) ? $this->linkId->connect_error : ''));
+                $this->halt("connect($host, $user, \$password) failed. ".(is_object($this->linkId) && isset($this->linkId->connect_error) ? $this->linkId->connect_error : ''));
                 return 0;
             }
             $this->linkId->set_charset($this->characterSet);
             if ($this->linkId->connect_errno) {
-                $this->halt("connect($host, $user, \$password) failed. ".(is_object($this->linkId) && isset( $this->linkId->connect_error) ? $this->linkId->connect_error : ''));
+                $this->halt("connect($host, $user, \$password) failed. ".(is_object($this->linkId) && isset($this->linkId->connect_error) ? $this->linkId->connect_error : ''));
                 return 0;
             }
         }
@@ -233,7 +233,7 @@ 
         $return = mysqli_stmt_execute($this->statement);
         if (!isset($GLOBALS['disable_db_queries'])) {
             $vars = $this->statement_vars;
-            $query = $result = preg_replace_callback('/\?/', function () use (&$vars) {
+            $query = $result = preg_replace_callback('/\?/', function() use (&$vars) {
                 return array_shift($vars);
                 }, $this->statement_query);
             $this->addLog($query, microtime(true) - $start, $line, $file);
@@ -295,24 +295,24 @@ 
                 $fails++;
                 try {
                     $this->queryId = @mysqli_query($this->linkId, $queryString, MYSQLI_STORE_RESULT);
-                    if (in_array((int)@mysqli_errno($this->linkId), [1213, 2006, 3101, 1180])) {
+                    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])) {
+                        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])) {
+                    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])) {
+                        if (in_array((int) @mysqli_errno($this->linkId), [1064])) {
                             $tries = 0;
                         }
                         break;

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
     */
@@ -33,8 +32,7 @@ 
     * @param string $database the name of the database to use
     * @return void
     */
-    public function useDb($database)
-    {
+    public function useDb($database) {
         $this->selectDb($database);
     }
 
@@ -44,8 +42,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);
     }
@@ -60,8 +57,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;
@@ -109,8 +105,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;
@@ -120,8 +115,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);
         }
@@ -132,8 +126,7 @@ 
     * discard the query result
     * @return void
     */
-    public function free()
-    {
+    public function free() {
         if (is_resource($this->queryId)) {
             @mysqli_free_result($this->queryId);
         }
@@ -151,8 +144,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;
@@ -178,8 +170,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);
     }
 
@@ -191,8 +182,7 @@ 
     * @param string $line
     * @param string $file
     */
-    public function prepare($query, $line = '', $file = '')
-    {
+    public function prepare($query, $line = '', $file = '') {
         if (!$this->connect()) {
             return 0;
         }
@@ -252,8 +242,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
@@ -345,8 +334,7 @@ 
     /**
     * @return array|null|object
     */
-    public function fetchObject()
-    {
+    public function fetchObject() {
         $this->Record = @mysqli_fetch_object($this->queryId);
         return $this->Record;
     }
@@ -359,8 +347,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;
@@ -384,8 +371,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;
@@ -405,8 +391,7 @@ 
     *
     * @return bool
     */
-    public function transactionBegin()
-    {
+    public function transactionBegin() {
         if (version_compare(PHP_VERSION, '5.5.0') < 0) {
             return true;
         }
@@ -421,8 +406,7 @@ 
     *
     * @return bool
     */
-    public function transactionCommit()
-    {
+    public function transactionCommit() {
         if (version_compare(PHP_VERSION, '5.5.0') < 0 || $this->linkId === 0) {
             return true;
         }
@@ -434,8 +418,7 @@ 
     *
     * @return bool
     */
-    public function transactionAbort()
-    {
+    public function transactionAbort() {
         if (version_compare(PHP_VERSION, '5.5.0') < 0 || $this->linkId === 0) {
             return true;
         }
@@ -451,8 +434,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;
         }
@@ -468,8 +450,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)) {
@@ -497,8 +478,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');
@@ -515,8 +495,7 @@ 
     * Db::affectedRows()
     * @return int
     */
-    public function affectedRows()
-    {
+    public function affectedRows() {
         return @mysqli_affected_rows($this->linkId);
     }
 
@@ -524,8 +503,7 @@ 
     * Db::num_rows()
     * @return int
     */
-    public function num_rows()
-    {
+    public function num_rows() {
         return @mysqli_num_rows($this->queryId);
     }
 
@@ -533,8 +511,7 @@ 
     * Db::num_fields()
     * @return int
     */
-    public function num_fields()
-    {
+    public function num_fields() {
         return @mysqli_num_fields($this->queryId);
     }
 
@@ -543,8 +520,7 @@ 
     *
     * @return array
     */
-    public function tableNames()
-    {
+    public function tableNames() {
         $return = [];
         $this->query('SHOW TABLES');
         $i = 0;