<?php /* @author dhtmlx.com @license GPL, see license.txt */ require_once("db_common.php"); /*! Implementation of DataWrapper for PDO if you plan to use it for Oracle - use Oracle connection type instead **/ class PHPCI2DBDataWrapper extends DBDataWrapper{ private $last_result;//!< store result or last operation public function query($sql){ LogMaster::log($sql); $res=$this->connection->query($sql); if ($res===false) { throw new Exception("CI - sql execution failed"); } if (is_object($res)) return new PHPCIResultSet($res); return new ArrayQueryWrapper(array()); } public function get_next($res){ $data = $res->next(); return $data; } public function get_new_id(){ return $this->connection->insert_id(); } public function escape($str){ return $this->connection->escape_str($str); } public function escape_name($data){ return $this->connection->protect_identifiers($data); } } class PHPCIResultSet{ private $res; private $start; private $count; public function __construct($res){ $this->res = $res; $this->start = $res->current_row; $this->count = $res->num_rows; } public function next(){ if ($this->start != $this->count){ return $this->res->row($this->start++,'array'); } else { $this->res->free_result(); return null; } } } ?>