detain / db_abstraction

src/Mysqli/Db.php

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

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;
     }
 }