<?php /** * @todo Build in Stored Procedures, and clean up. * @author Josh Team <jteam@creditsolutions.com> * @package Model * @version 1.0 */ class MySQL implements DBInterface { public $dbObj; public $host; public $user; public $pass; public $database; public function __construct($host, $user, $pass, $database){ $this->connect($host, $user, $pass, $database); } private function connect($host,$user,$pass,$database){ $this->dbObj = new mysqli($host,$user,$pass,$database); } public function query($query) { if($this->dbObj->query( $query )) { return $this->dbObj->affected_rows; } else { throw new Exception($this->dbObj->error); } } public function getAll($query) { if($result = $this->dbObj->query($query)){ while($row = $result->fetch_assoc()) { $resultset[] = $row; } } else { throw new Exception($this->dbObj->error); } return $resultset; } public function getRow($query) { if ($result = $this->dbObj->query($query)) { $rs = $result->fetch_assoc(); } else { throw new Exception($this->dbObj->error); } return $rs; } public function getField($query) { if ($result = $this->dbObj->query($query)) { $rs = $result->fetch_array(); return $rs[0]; } else { throw new Exception($this->dbObj->error); } } public function getThreadID() { $rs = $this->dbObj->thread_id; return $rs; } public function getNumRows() { return $this->dbObj->affected_rows; } public function cleanString($string) { $stringresult = $this->dbObj->real_escape_string($string); return $stringresult; } public function storedProc($sp, $params='') { return $this->dbObj->insert_id; } public function getLastID() { return $this->dbObj->insert_id; } }?>