@@ -71,7 +71,7 @@ discard block |
||
| 71 | 71 | if ($this->connectionAttempt > 1) |
| 72 | 72 | error_log("MySQLi Connection Attempt #{$this->connectionAttempt}/{$this->maxConnectErrors}"); |
| 73 | 73 | if ($this->connectionAttempt >= $this->maxConnectErrors) { |
| 74 | - $this->halt("connect($host, $user, \$password) failed. " . $mysqli->connect_error); |
|
| 74 | + $this->halt("connect($host, $user, \$password) failed. ".$mysqli->connect_error); |
|
| 75 | 75 | return 0; |
| 76 | 76 | } |
| 77 | 77 | //$this->linkId = new mysqli($host, $user, $password, $database); |
@@ -87,7 +87,7 @@ discard block |
||
| 87 | 87 | * } |
| 88 | 88 | */ |
| 89 | 89 | if ($this->linkId->connect_errno) { |
| 90 | - $this->halt("connect($host, $user, \$password) failed. " . $mysqli->connect_error); |
|
| 90 | + $this->halt("connect($host, $user, \$password) failed. ".$mysqli->connect_error); |
|
| 91 | 91 | return 0; |
| 92 | 92 | } |
| 93 | 93 | /*if ($this->characterSet != '') { |
@@ -255,7 +255,7 @@ discard block |
||
| 255 | 255 | $this->Errno = @mysqli_errno($this->linkId); |
| 256 | 256 | $this->Error = @mysqli_error($this->linkId); |
| 257 | 257 | if ($try == 1 && (null === $this->queryId || $this->queryId === FALSE)) { |
| 258 | - $email = "MySQLi Error<br>\n".'Query: '.$queryString . "<br>\n".'Error #'.$this->Errno.': '.$this->Error . "<br>\n".'Line: '.$line . "<br>\n".'File: '.$file . "<br>\n" . (isset($GLOBALS['tf']) ? 'User: '.$GLOBALS['tf']->session->account_id . "<br>\n" : ''); |
|
| 258 | + $email = "MySQLi Error<br>\n".'Query: '.$queryString."<br>\n".'Error #'.$this->Errno.': '.$this->Error."<br>\n".'Line: '.$line."<br>\n".'File: '.$file."<br>\n".(isset($GLOBALS['tf']) ? 'User: '.$GLOBALS['tf']->session->account_id."<br>\n" : ''); |
|
| 259 | 259 | $email .= '<br><br>Request Variables:<br>'.print_r($_REQUEST, TRUE); |
| 260 | 260 | $email .= '<br><br>Server Variables:<br>'.print_r($_SERVER, TRUE); |
| 261 | 261 | $subject = $_SERVER['HOSTNAME'].' MySQLi Error'; |
@@ -322,7 +322,7 @@ discard block |
||
| 322 | 322 | if ($status) { |
| 323 | 323 | $this->Row = $pos; |
| 324 | 324 | } else { |
| 325 | - $this->halt("seek($pos) failed: result has " . $this->num_rows().' rows'); |
|
| 325 | + $this->halt("seek($pos) failed: result has ".$this->num_rows().' rows'); |
|
| 326 | 326 | /* half assed attempt to save the day, |
| 327 | 327 | * but do not consider this documented or even |
| 328 | 328 | * desirable behaviour. |
@@ -380,7 +380,7 @@ discard block |
||
| 380 | 380 | */ |
| 381 | 381 | public function getLastInsertId($table, $field) { |
| 382 | 382 | if (!isset($table) || $table == '' || !isset($field) || $field == '') |
| 383 | - return - 1; |
|
| 383 | + return -1; |
|
| 384 | 384 | |
| 385 | 385 | return @mysqli_insert_id($this->linkId); |
| 386 | 386 | } |
@@ -514,22 +514,22 @@ discard block |
||
| 514 | 514 | * @param int|string $field |
| 515 | 515 | * @return bool |
| 516 | 516 | */ |
| 517 | -function mysqli_result($result, $row, $field=0) { |
|
| 518 | - if ($result===false) return FALSE; |
|
| 519 | - if ($row>=mysqli_num_rows($result)) return FALSE; |
|
| 517 | +function mysqli_result($result, $row, $field = 0) { |
|
| 518 | + if ($result === false) return FALSE; |
|
| 519 | + if ($row >= mysqli_num_rows($result)) return FALSE; |
|
| 520 | 520 | if (is_string($field) && !(mb_strpos($field, '.') === FALSE)) { |
| 521 | - $tField=explode('.', $field); |
|
| 522 | - $field=-1; |
|
| 523 | - $tFields=mysqli_fetch_fields($result); |
|
| 524 | - for ($id=0, $idMax = mysqli_num_fields($result);$id<$idMax;$id++) { |
|
| 525 | - if ($tFields[$id]->table==$tField[0] && $tFields[$id]->name==$tField[1]) { |
|
| 526 | - $field=$id; |
|
| 521 | + $tField = explode('.', $field); |
|
| 522 | + $field = -1; |
|
| 523 | + $tFields = mysqli_fetch_fields($result); |
|
| 524 | + for ($id = 0, $idMax = mysqli_num_fields($result); $id < $idMax; $id++) { |
|
| 525 | + if ($tFields[$id]->table == $tField[0] && $tFields[$id]->name == $tField[1]) { |
|
| 526 | + $field = $id; |
|
| 527 | 527 | break; |
| 528 | 528 | } |
| 529 | 529 | } |
| 530 | - if ($field==-1) return FALSE; |
|
| 530 | + if ($field == -1) return FALSE; |
|
| 531 | 531 | } |
| 532 | 532 | mysqli_data_seek($result, $row); |
| 533 | - $line=mysqli_fetch_array($result); |
|
| 534 | - return isset($line[$field])?$line[$field]:false; |
|
| 533 | + $line = mysqli_fetch_array($result); |
|
| 534 | + return isset($line[$field]) ? $line[$field] : false; |
|
| 535 | 535 | } |
@@ -17,8 +17,7 @@ |
||
| 17 | 17 | * |
| 18 | 18 | * @access public |
| 19 | 19 | */ |
| 20 | -class Db extends Generic implements Db_Interface |
|
| 21 | -{ |
|
| 20 | +class Db extends Generic implements Db_Interface { |
|
| 22 | 21 | /** |
| 23 | 22 | * @var string |
| 24 | 23 | */ |
@@ -244,7 +244,7 @@ discard block |
||
| 244 | 244 | $tries = 3; |
| 245 | 245 | $try = 0; |
| 246 | 246 | $this->queryId = FALSE; |
| 247 | - while ((null === $this->queryId || $this->queryId === FALSE) && $try <= $tries) { |
|
| 247 | + while ((NULL === $this->queryId || $this->queryId === FALSE) && $try <= $tries) { |
|
| 248 | 248 | $try++; |
| 249 | 249 | if ($try > 1) { |
| 250 | 250 | @mysqli_close($this->linkId); |
@@ -254,7 +254,7 @@ discard block |
||
| 254 | 254 | $this->Row = 0; |
| 255 | 255 | $this->Errno = @mysqli_errno($this->linkId); |
| 256 | 256 | $this->Error = @mysqli_error($this->linkId); |
| 257 | - if ($try == 1 && (null === $this->queryId || $this->queryId === FALSE)) { |
|
| 257 | + if ($try == 1 && (NULL === $this->queryId || $this->queryId === FALSE)) { |
|
| 258 | 258 | $email = "MySQLi Error<br>\n".'Query: '.$queryString . "<br>\n".'Error #'.$this->Errno.': '.$this->Error . "<br>\n".'Line: '.$line . "<br>\n".'File: '.$file . "<br>\n" . (isset($GLOBALS['tf']) ? 'User: '.$GLOBALS['tf']->session->account_id . "<br>\n" : ''); |
| 259 | 259 | $email .= '<br><br>Request Variables:<br>'.print_r($_REQUEST, TRUE); |
| 260 | 260 | $email .= '<br><br>Server Variables:<br>'.print_r($_SERVER, TRUE); |
@@ -270,7 +270,7 @@ discard block |
||
| 270 | 270 | } |
| 271 | 271 | } |
| 272 | 272 | $this->haltOnError = $haltPrev; |
| 273 | - if (null === $this->queryId || $this->queryId === FALSE) |
|
| 273 | + if (NULL === $this->queryId || $this->queryId === FALSE) |
|
| 274 | 274 | $this->halt('', $line, $file); |
| 275 | 275 | |
| 276 | 276 | // Will return nada if it fails. That's fine. |
@@ -341,7 +341,7 @@ discard block |
||
| 341 | 341 | */ |
| 342 | 342 | public function transactionBegin() { |
| 343 | 343 | if (version_compare(PHP_VERSION, '5.5.0') < 0) |
| 344 | - return true; |
|
| 344 | + return TRUE; |
|
| 345 | 345 | if (!$this->connect()) |
| 346 | 346 | return 0; |
| 347 | 347 | return mysqli_begin_transaction($this->linkId); |
@@ -354,7 +354,7 @@ discard block |
||
| 354 | 354 | */ |
| 355 | 355 | public function transactionCommit() { |
| 356 | 356 | if (version_compare(PHP_VERSION, '5.5.0') < 0) |
| 357 | - return true; |
|
| 357 | + return TRUE; |
|
| 358 | 358 | return mysqli_commit($this->linkId); |
| 359 | 359 | } |
| 360 | 360 | |
@@ -365,7 +365,7 @@ discard block |
||
| 365 | 365 | */ |
| 366 | 366 | public function transactionAbort() { |
| 367 | 367 | if (version_compare(PHP_VERSION, '5.5.0') < 0) |
| 368 | - return true; |
|
| 368 | + return TRUE; |
|
| 369 | 369 | return mysqli_rollback($this->linkId); |
| 370 | 370 | } |
| 371 | 371 | |
@@ -515,7 +515,7 @@ discard block |
||
| 515 | 515 | * @return bool |
| 516 | 516 | */ |
| 517 | 517 | function mysqli_result($result, $row, $field=0) { |
| 518 | - if ($result===false) return FALSE; |
|
| 518 | + if ($result===FALSE) return FALSE; |
|
| 519 | 519 | if ($row>=mysqli_num_rows($result)) return FALSE; |
| 520 | 520 | if (is_string($field) && !(mb_strpos($field, '.') === FALSE)) { |
| 521 | 521 | $tField=explode('.', $field); |
@@ -531,5 +531,5 @@ discard block |
||
| 531 | 531 | } |
| 532 | 532 | mysqli_data_seek($result, $row); |
| 533 | 533 | $line=mysqli_fetch_array($result); |
| 534 | - return isset($line[$field])?$line[$field]:false; |
|
| 534 | + return isset($line[$field])?$line[$field]:FALSE; |
|
| 535 | 535 | } |
@@ -1,11 +1,11 @@ |
||
| 1 | 1 | <?php |
| 2 | 2 | /** |
| 3 | - * Generic SQL Driver Related Functionality |
|
| 4 | - * by [email protected] |
|
| 5 | - * @copyright 2018 |
|
| 6 | - * @package MyAdmin |
|
| 7 | - * @category SQL |
|
| 8 | - */ |
|
| 3 | + * Generic SQL Driver Related Functionality |
|
| 4 | + * by [email protected] |
|
| 5 | + * @copyright 2018 |
|
| 6 | + * @package MyAdmin |
|
| 7 | + * @category SQL |
|
| 8 | + */ |
|
| 9 | 9 | |
| 10 | 10 | namespace MyDb; |
| 11 | 11 | /** |
@@ -13,8 +13,7 @@ |
||
| 13 | 13 | * |
| 14 | 14 | * @package MyDb |
| 15 | 15 | */ |
| 16 | -interface Db_Interface |
|
| 17 | -{ |
|
| 16 | +interface Db_Interface { |
|
| 18 | 17 | |
| 19 | 18 | /** |
| 20 | 19 | * Db_Interface constructor. |
@@ -198,18 +198,18 @@ discard block |
||
| 198 | 198 | $this->queryId = $this->linkId->prepare($queryString); |
| 199 | 199 | $success = $this->queryId->execute(); |
| 200 | 200 | $this->Rows = $this->queryId->fetchAll(); |
| 201 | - $this->log("PDO Query $queryString (S:$success) - " . count($this->Rows).' Rows', __LINE__, __FILE__); |
|
| 201 | + $this->log("PDO Query $queryString (S:$success) - ".count($this->Rows).' Rows', __LINE__, __FILE__); |
|
| 202 | 202 | $this->Row = 0; |
| 203 | 203 | if ($success === FALSE) { |
| 204 | - $email = "MySQL Error<br>\n".'Query: '.$queryString . "<br>\n".'Error #'.print_r($this->queryId->errorInfo(), TRUE) . "<br>\n".'Line: '.$line . "<br>\n".'File: '.$file . "<br>\n" . (isset($GLOBALS['tf']) ? 'User: '.$GLOBALS['tf']->session->account_id . "<br>\n" : ''); |
|
| 204 | + $email = "MySQL Error<br>\n".'Query: '.$queryString."<br>\n".'Error #'.print_r($this->queryId->errorInfo(), TRUE)."<br>\n".'Line: '.$line."<br>\n".'File: '.$file."<br>\n".(isset($GLOBALS['tf']) ? 'User: '.$GLOBALS['tf']->session->account_id."<br>\n" : ''); |
|
| 205 | 205 | |
| 206 | 206 | $email .= '<br><br>Request Variables:<br>'; |
| 207 | 207 | foreach ($_REQUEST as $key => $value) |
| 208 | - $email .= $key.': '.$value . "<br>\n"; |
|
| 208 | + $email .= $key.': '.$value."<br>\n"; |
|
| 209 | 209 | |
| 210 | 210 | $email .= '<br><br>Server Variables:<br>'; |
| 211 | 211 | foreach ($_SERVER as $key => $value) |
| 212 | - $email .= $key.': '.$value . "<br>\n"; |
|
| 212 | + $email .= $key.': '.$value."<br>\n"; |
|
| 213 | 213 | $subject = $_SERVER['HOSTNAME'].' MySQLi Error'; |
| 214 | 214 | $headers = ''; |
| 215 | 215 | $headers .= 'MIME-Version: 1.0'.PHP_EOL; |
@@ -259,7 +259,7 @@ discard block |
||
| 259 | 259 | if (isset($this->Rows[$pos])) { |
| 260 | 260 | $this->Row = $pos; |
| 261 | 261 | } else { |
| 262 | - $this->halt("seek($pos) failed: result has " . count($this->Rows).' rows'); |
|
| 262 | + $this->halt("seek($pos) failed: result has ".count($this->Rows).' rows'); |
|
| 263 | 263 | /* half assed attempt to save the day, |
| 264 | 264 | * but do not consider this documented or even |
| 265 | 265 | * desirable behaviour. |
@@ -301,7 +301,7 @@ discard block |
||
| 301 | 301 | */ |
| 302 | 302 | public function getLastInsertId($table, $field) { |
| 303 | 303 | if (!isset($table) || $table == '' || !isset($field) || $field == '') |
| 304 | - return - 1; |
|
| 304 | + return -1; |
|
| 305 | 305 | return $this->linkId->lastInsertId(); |
| 306 | 306 | } |
| 307 | 307 | |
@@ -17,8 +17,7 @@ discard block |
||
| 17 | 17 | * |
| 18 | 18 | * @access public |
| 19 | 19 | */ |
| 20 | -class Db extends Generic implements Db_Interface |
|
| 21 | -{ |
|
| 20 | +class Db extends Generic implements Db_Interface { |
|
| 22 | 21 | /* public: connection parameters */ |
| 23 | 22 | public $driver = 'mysql'; |
| 24 | 23 | public $Rows = []; |
@@ -76,11 +75,9 @@ discard block |
||
| 76 | 75 | if ($this->characterSet != '') |
| 77 | 76 | $dSN .= ';charset='.$this->characterSet; |
| 78 | 77 | if ($this->linkId === FALSE) { |
| 79 | - try |
|
| 80 | - { |
|
| 78 | + try { |
|
| 81 | 79 | $this->linkId = new \PDO($dSN, $user, $password); |
| 82 | - } |
|
| 83 | - catch (\PDOException $e) { |
|
| 80 | + } catch (\PDOException $e) { |
|
| 84 | 81 | $this->halt('Connection Failed '.$e->getMessage()); |
| 85 | 82 | return 0; |
| 86 | 83 | } |
@@ -164,9 +164,9 @@ discard block |
||
| 164 | 164 | public function limit($start = 0) { |
| 165 | 165 | echo '<b>Warning: limit() is no longer used, use limitQuery()</b>'; |
| 166 | 166 | if ($start == 0) { |
| 167 | - $s = 'limit '.(int)$this->maxMatches; |
|
| 167 | + $s = 'limit '.(int) $this->maxMatches; |
|
| 168 | 168 | } else { |
| 169 | - $s = 'limit '.(int)$start.','.(int)$this->maxMatches; |
|
| 169 | + $s = 'limit '.(int) $start.','.(int) $this->maxMatches; |
|
| 170 | 170 | } |
| 171 | 171 | return $s; |
| 172 | 172 | } |
@@ -185,9 +185,9 @@ discard block |
||
| 185 | 185 | if (!$numRows) |
| 186 | 186 | $numRows = $this->maxMatches; |
| 187 | 187 | if ($offset == 0) { |
| 188 | - $queryString .= ' LIMIT '.(int)$numRows; |
|
| 188 | + $queryString .= ' LIMIT '.(int) $numRows; |
|
| 189 | 189 | } else { |
| 190 | - $queryString .= ' LIMIT '.(int)$offset.','.(int)$numRows; |
|
| 190 | + $queryString .= ' LIMIT '.(int) $offset.','.(int) $numRows; |
|
| 191 | 191 | } |
| 192 | 192 | |
| 193 | 193 | if ($this->Debug) |
@@ -258,26 +258,26 @@ discard block |
||
| 258 | 258 | * @return mixed|void |
| 259 | 259 | */ |
| 260 | 260 | public function logBackTrace($msg, $line = '', $file = '') { |
| 261 | - $backtrace=(function_exists('debug_backtrace') ? debug_backtrace() : []); |
|
| 261 | + $backtrace = (function_exists('debug_backtrace') ? debug_backtrace() : []); |
|
| 262 | 262 | $this->log( |
| 263 | 263 | ('' !== getenv('REQUEST_URI') ? ' '.getenv('REQUEST_URI') : ''). |
| 264 | 264 | ((isset($_POST) && count($_POST)) ? ' POST='.json_encode($_POST) : ''). |
| 265 | 265 | ((isset($_GET) && count($_GET)) ? ' GET='.json_encode($_GET) : ''). |
| 266 | 266 | ((isset($_FILES) && count($_FILES)) ? ' FILES='.json_encode($_FILES) : ''). |
| 267 | 267 | ('' !== getenv('HTTP_USER_AGENT') ? ' AGENT="'.getenv('HTTP_USER_AGENT').'"' : ''). |
| 268 | - (isset($_SERVER[ 'REQUEST_METHOD' ]) ?' METHOD="'. $_SERVER['REQUEST_METHOD']. '"'. |
|
| 269 | - ($_SERVER['REQUEST_METHOD'] === 'POST' ? ' POST="'. json_encode($_POST). '"' : '') : ''), $line, $file, 'error'); |
|
| 270 | - for($level=1, $levelMax = count($backtrace);$level < $levelMax;$level++) { |
|
| 271 | - $message=(isset($backtrace[$level]['file']) ? 'File: '. $backtrace[$level]['file'] : ''). |
|
| 272 | - (isset($backtrace[$level]['line']) ? ' Line: '. $backtrace[$level]['line'] : ''). |
|
| 273 | - ' Function: '.(isset($backtrace[$level] ['class']) ? '(class '. $backtrace[$level] ['class'].') ' : '') . |
|
| 268 | + (isset($_SERVER['REQUEST_METHOD']) ? ' METHOD="'.$_SERVER['REQUEST_METHOD'].'"'. |
|
| 269 | + ($_SERVER['REQUEST_METHOD'] === 'POST' ? ' POST="'.json_encode($_POST).'"' : '') : ''), $line, $file, 'error'); |
|
| 270 | + for ($level = 1, $levelMax = count($backtrace); $level < $levelMax; $level++) { |
|
| 271 | + $message = (isset($backtrace[$level]['file']) ? 'File: '.$backtrace[$level]['file'] : ''). |
|
| 272 | + (isset($backtrace[$level]['line']) ? ' Line: '.$backtrace[$level]['line'] : ''). |
|
| 273 | + ' Function: '.(isset($backtrace[$level] ['class']) ? '(class '.$backtrace[$level] ['class'].') ' : ''). |
|
| 274 | 274 | (isset($backtrace[$level] ['type']) ? $backtrace[$level] ['type'].' ' : ''). |
| 275 | 275 | $backtrace[$level] ['function'].'('; |
| 276 | - if(isset($backtrace[$level] ['args'])) |
|
| 277 | - for($argument = 0, $argumentMax = count($backtrace[$level]['args']); $argument < $argumentMax; $argument++) |
|
| 276 | + if (isset($backtrace[$level] ['args'])) |
|
| 277 | + for ($argument = 0, $argumentMax = count($backtrace[$level]['args']); $argument < $argumentMax; $argument++) |
|
| 278 | 278 | $message .= ($argument > 0 ? ', ' : ''). |
| 279 | 279 | (is_object($backtrace[$level]['args'][$argument]) ? 'class '.get_class($backtrace[$level]['args'][$argument]) : json_encode($backtrace[$level]['args'][$argument])); |
| 280 | - $message.=')'; |
|
| 280 | + $message .= ')'; |
|
| 281 | 281 | $this->log($message, $line, $file, 'error'); |
| 282 | 282 | } |
| 283 | 283 | } |
@@ -292,7 +292,7 @@ discard block |
||
| 292 | 292 | $this->log("Database error: $msg", $line, $file, 'error'); |
| 293 | 293 | if ($this->Errno != '0' || !in_array($this->Error, '', '()')) { |
| 294 | 294 | $sqlstate = mysqli_sqlstate($this->linkId); |
| 295 | - $this->log("MySQLi SQLState: {$sqlstate}. Error: " . $this->Errno . ' (' . $this->Error . ')', $line, $file, 'error'); |
|
| 295 | + $this->log("MySQLi SQLState: {$sqlstate}. Error: ".$this->Errno.' ('.$this->Error.')', $line, $file, 'error'); |
|
| 296 | 296 | } |
| 297 | 297 | $this->logBackTrace($msg, $line, $file); |
| 298 | 298 | } |
@@ -12,8 +12,7 @@ |
||
| 12 | 12 | /** |
| 13 | 13 | * Class Generic |
| 14 | 14 | */ |
| 15 | -abstract class Generic |
|
| 16 | -{ |
|
| 15 | +abstract class Generic { |
|
| 17 | 16 | /* public: connection parameters */ |
| 18 | 17 | public $host = 'localhost'; |
| 19 | 18 | public $database = ''; |
@@ -234,7 +234,7 @@ |
||
| 234 | 234 | * @return void |
| 235 | 235 | */ |
| 236 | 236 | public function halt($msg, $line = '', $file = '') { |
| 237 | - $this->unlock(false); |
|
| 237 | + $this->unlock(FALSE); |
|
| 238 | 238 | /* Just in case there is a table currently locked */ |
| 239 | 239 | |
| 240 | 240 | //$this->Error = @$this->linkId->error; |
@@ -36,10 +36,10 @@ discard block |
||
| 36 | 36 | public function quote($text = '', $type = 'text') { |
| 37 | 37 | switch ($type) { |
| 38 | 38 | case 'text': |
| 39 | - return "'" . mysqli_real_escape_string($this->linkId, $text) . "'"; |
|
| 39 | + return "'".mysqli_real_escape_string($this->linkId, $text)."'"; |
|
| 40 | 40 | break; |
| 41 | 41 | case 'integer': |
| 42 | - return (int)$text; |
|
| 42 | + return (int) $text; |
|
| 43 | 43 | break; |
| 44 | 44 | default: |
| 45 | 45 | return $text; |
@@ -138,7 +138,7 @@ discard block |
||
| 138 | 138 | if ($this->connectionAttempt > 1) |
| 139 | 139 | error_log("MySQLi Connection Attempt #{$this->connectionAttempt}/{$this->maxConnectErrors}"); |
| 140 | 140 | if ($this->connectionAttempt >= $this->maxConnectErrors) { |
| 141 | - $this->halt("connect($host, $user, \$password) failed. " . $mysqli->connect_error); |
|
| 141 | + $this->halt("connect($host, $user, \$password) failed. ".$mysqli->connect_error); |
|
| 142 | 142 | return 0; |
| 143 | 143 | } |
| 144 | 144 | $this->linkId = mysqli_init(); |
@@ -146,7 +146,7 @@ discard block |
||
| 146 | 146 | $this->linkId->real_connect($host, $user, $password, $database); |
| 147 | 147 | $this->linkId->set_charset($this->characterSet); |
| 148 | 148 | if ($this->linkId->connect_errno) { |
| 149 | - $this->halt("connect($host, $user, \$password) failed. " . $mysqli->connect_error); |
|
| 149 | + $this->halt("connect($host, $user, \$password) failed. ".$mysqli->connect_error); |
|
| 150 | 150 | return 0; |
| 151 | 151 | } |
| 152 | 152 | } |
@@ -292,8 +292,8 @@ discard block |
||
| 292 | 292 | } |
| 293 | 293 | $this->haltOnError = $haltPrev; |
| 294 | 294 | if ($this->queryId === FALSE) { |
| 295 | - $email = "MySQLi Error<br>\n".'Query: '.$queryString . "<br>\n".'Error #'.$this->Errno.': '.$this->Error . "<br>\n".'Line: '.$line . "<br>\n".'File: '.$file . "<br>\n" . (isset($GLOBALS['tf']) ? |
|
| 296 | - 'User: '.$GLOBALS['tf']->session->account_id . "<br>\n" : ''); |
|
| 295 | + $email = "MySQLi Error<br>\n".'Query: '.$queryString."<br>\n".'Error #'.$this->Errno.': '.$this->Error."<br>\n".'Line: '.$line."<br>\n".'File: '.$file."<br>\n".(isset($GLOBALS['tf']) ? |
|
| 296 | + 'User: '.$GLOBALS['tf']->session->account_id."<br>\n" : ''); |
|
| 297 | 297 | |
| 298 | 298 | $email .= '<br><br>Request Variables:<br>'.print_r($_REQUEST, TRUE); |
| 299 | 299 | $email .= '<br><br>Server Variables:<br>'.print_r($_SERVER, TRUE); |
@@ -348,7 +348,7 @@ discard block |
||
| 348 | 348 | if ($status) { |
| 349 | 349 | $this->Row = $pos; |
| 350 | 350 | } else { |
| 351 | - $this->halt("seek($pos) failed: result has " . $this->num_rows().' rows'); |
|
| 351 | + $this->halt("seek($pos) failed: result has ".$this->num_rows().' rows'); |
|
| 352 | 352 | /* half assed attempt to save the day, |
| 353 | 353 | * but do not consider this documented or even |
| 354 | 354 | * desirable behaviour. |
@@ -398,7 +398,7 @@ discard block |
||
| 398 | 398 | */ |
| 399 | 399 | |
| 400 | 400 | if (!isset($table) || $table == '' || !isset($field) || $field == '') |
| 401 | - return - 1; |
|
| 401 | + return -1; |
|
| 402 | 402 | |
| 403 | 403 | return @mysqli_insert_id($this->linkId); |
| 404 | 404 | } |
@@ -17,8 +17,7 @@ |
||
| 17 | 17 | * |
| 18 | 18 | * @access public |
| 19 | 19 | */ |
| 20 | -class Db extends Generic implements Db_Interface |
|
| 21 | -{ |
|
| 20 | +class Db extends Generic implements Db_Interface { |
|
| 22 | 21 | public $host = 'localhost'; |
| 23 | 22 | public $user = 'pdns'; |
| 24 | 23 | public $password = ''; |
@@ -13,8 +13,7 @@ |
||
| 13 | 13 | * |
| 14 | 14 | * @package MyDb |
| 15 | 15 | */ |
| 16 | -class Loader |
|
| 17 | -{ |
|
| 16 | +class Loader { |
|
| 18 | 17 | /* public: connection parameters */ |
| 19 | 18 | public $Type = 'mysqli'; |
| 20 | 19 | public $host = 'localhost'; |
@@ -149,7 +149,7 @@ |
||
| 149 | 149 | * @return void |
| 150 | 150 | */ |
| 151 | 151 | public function halt($msg, $line = '', $file = '') { |
| 152 | - $this->unlock(false); |
|
| 152 | + $this->unlock(FALSE); |
|
| 153 | 153 | |
| 154 | 154 | if ($this->haltOnError == 'no') |
| 155 | 155 | return; |
@@ -177,16 +177,16 @@ discard block |
||
| 177 | 177 | $this->queryId = $this->linkId->Execute($queryString); |
| 178 | 178 | } |
| 179 | 179 | catch (exception $e) { |
| 180 | - $email = "MySQL Error<br>\n".'Query: '.$queryString . "<br>\n".'Error #'.print_r($e, TRUE) . "<br>\n".'Line: '.$line . "<br>\n".'File: '.$file . "<br>\n" . (isset($GLOBALS['tf']) ? |
|
| 181 | - 'User: '.$GLOBALS['tf']->session->account_id . "<br>\n" : ''); |
|
| 180 | + $email = "MySQL Error<br>\n".'Query: '.$queryString."<br>\n".'Error #'.print_r($e, TRUE)."<br>\n".'Line: '.$line."<br>\n".'File: '.$file."<br>\n".(isset($GLOBALS['tf']) ? |
|
| 181 | + 'User: '.$GLOBALS['tf']->session->account_id."<br>\n" : ''); |
|
| 182 | 182 | |
| 183 | 183 | $email .= '<br><br>Request Variables:<br>'; |
| 184 | 184 | foreach ($_REQUEST as $key => $value) |
| 185 | - $email .= $key.': '.$value . "<br>\n"; |
|
| 185 | + $email .= $key.': '.$value."<br>\n"; |
|
| 186 | 186 | |
| 187 | 187 | $email .= '<br><br>Server Variables:<br>'; |
| 188 | 188 | foreach ($_SERVER as $key => $value) |
| 189 | - $email .= $key.': '.$value . "<br>\n"; |
|
| 189 | + $email .= $key.': '.$value."<br>\n"; |
|
| 190 | 190 | $subject = $_SERVER['HOSTNAME'].' MySQLi Error'; |
| 191 | 191 | $headers = ''; |
| 192 | 192 | $headers .= 'MIME-Version: 1.0'.PHP_EOL; |
@@ -196,7 +196,7 @@ discard block |
||
| 196 | 196 | admin_mail($subject, $email, $headers, FALSE, 'admin/sql_error.tpl'); |
| 197 | 197 | $this->halt('Invalid SQL: '.$queryString, $line, $file); |
| 198 | 198 | } |
| 199 | - $this->log("ADOdb Query $queryString (S:$success) - " . count($this->Rows).' Rows', __LINE__, __FILE__); |
|
| 199 | + $this->log("ADOdb Query $queryString (S:$success) - ".count($this->Rows).' Rows', __LINE__, __FILE__); |
|
| 200 | 200 | $this->Row = 0; |
| 201 | 201 | |
| 202 | 202 | // Will return nada if it fails. That's fine. |
@@ -232,7 +232,7 @@ discard block |
||
| 232 | 232 | if (isset($this->Rows[$pos])) { |
| 233 | 233 | $this->Row = $pos; |
| 234 | 234 | } else { |
| 235 | - $this->halt("seek($pos) failed: result has " . count($this->Rows).' rows'); |
|
| 235 | + $this->halt("seek($pos) failed: result has ".count($this->Rows).' rows'); |
|
| 236 | 236 | /* half assed attempt to save the day, |
| 237 | 237 | * but do not consider this documented or even |
| 238 | 238 | * desirable behaviour. |
@@ -374,7 +374,7 @@ discard block |
||
| 374 | 374 | public function haltmsg($msg, $line = '', $file = '') { |
| 375 | 375 | $this->log("Database error: $msg", $line, $file, 'error'); |
| 376 | 376 | if ($this->linkId->ErrorNo() != '0' && $this->linkId->ErrorMsg() != '') |
| 377 | - $this->log('ADOdb SQL Error: ' . $this->linkId->ErrorMsg(), $line, $file, 'error'); |
|
| 377 | + $this->log('ADOdb SQL Error: '.$this->linkId->ErrorMsg(), $line, $file, 'error'); |
|
| 378 | 378 | $this->logBackTrace($msg, $line, $file); |
| 379 | 379 | } |
| 380 | 380 | |
@@ -17,8 +17,7 @@ discard block |
||
| 17 | 17 | * |
| 18 | 18 | * @access public |
| 19 | 19 | */ |
| 20 | -class Db extends Generic implements Db_Interface |
|
| 21 | -{ |
|
| 20 | +class Db extends Generic implements Db_Interface { |
|
| 22 | 21 | public $driver = 'mysql'; |
| 23 | 22 | public $Rows = []; |
| 24 | 23 | public $type = 'adodb'; |
@@ -172,11 +171,9 @@ discard block |
||
| 172 | 171 | |
| 173 | 172 | } |
| 174 | 173 | |
| 175 | - try |
|
| 176 | - { |
|
| 174 | + try { |
|
| 177 | 175 | $this->queryId = $this->linkId->Execute($queryString); |
| 178 | - } |
|
| 179 | - catch (exception $e) { |
|
| 176 | + } catch (exception $e) { |
|
| 180 | 177 | $email = "MySQL Error<br>\n".'Query: '.$queryString . "<br>\n".'Error #'.print_r($e, TRUE) . "<br>\n".'Line: '.$line . "<br>\n".'File: '.$file . "<br>\n" . (isset($GLOBALS['tf']) ? |
| 181 | 178 | 'User: '.$GLOBALS['tf']->session->account_id . "<br>\n" : ''); |
| 182 | 179 | |
@@ -32,7 +32,7 @@ discard block |
||
| 32 | 32 | */ |
| 33 | 33 | public function ifadd($add, $me) { |
| 34 | 34 | if ('' != $add) |
| 35 | - return ' '.$me . $add; |
|
| 35 | + return ' '.$me.$add; |
|
| 36 | 36 | return ''; |
| 37 | 37 | } |
| 38 | 38 | |
@@ -82,7 +82,7 @@ discard block |
||
| 82 | 82 | */ |
| 83 | 83 | public function connect() { |
| 84 | 84 | if (0 == $this->linkId) { |
| 85 | - $connectString = 'dbname='.$this->database . $this->ifadd($this->host, 'host=') . $this->ifadd($this->port, 'port=') . $this->ifadd($this->user, 'user=') . $this->ifadd("'" . $this->password . "'", 'password='); |
|
| 85 | + $connectString = 'dbname='.$this->database.$this->ifadd($this->host, 'host=').$this->ifadd($this->port, 'port=').$this->ifadd($this->user, 'user=').$this->ifadd("'".$this->password."'", 'password='); |
|
| 86 | 86 | $this->linkId = pg_pconnect($connectString); |
| 87 | 87 | |
| 88 | 88 | if (!$this->linkId) { |
@@ -262,21 +262,21 @@ discard block |
||
| 262 | 262 | * conditional code to the apps. |
| 263 | 263 | */ |
| 264 | 264 | if (!isset($table) || $table == '' || !isset($field) || $field == '') |
| 265 | - return - 1; |
|
| 265 | + return -1; |
|
| 266 | 266 | |
| 267 | 267 | $oid = pg_getlastoid($this->queryId); |
| 268 | 268 | if ($oid == -1) |
| 269 | - return - 1; |
|
| 269 | + return -1; |
|
| 270 | 270 | |
| 271 | 271 | $result = @pg_exec($this->linkId, "select $field from $table where oid=$oid"); |
| 272 | 272 | if (!$result) |
| 273 | - return - 1; |
|
| 273 | + return -1; |
|
| 274 | 274 | |
| 275 | 275 | $Record = @pg_fetch_array($result, 0); |
| 276 | 276 | @pg_freeresult($result); |
| 277 | 277 | if (!is_array($Record)) /* OID not found? */ |
| 278 | 278 | { |
| 279 | - return - 1; |
|
| 279 | + return -1; |
|
| 280 | 280 | } |
| 281 | 281 | |
| 282 | 282 | return $Record[0]; |
@@ -17,8 +17,7 @@ |
||
| 17 | 17 | * |
| 18 | 18 | * @access public |
| 19 | 19 | */ |
| 20 | -class Db extends Generic implements Db_Interface |
|
| 21 | -{ |
|
| 20 | +class Db extends Generic implements Db_Interface { |
|
| 22 | 21 | /* public: this is an api revision, not a CVS revision. */ |
| 23 | 22 | public $type = 'pgsql'; |
| 24 | 23 | public $port = '5432'; |