Loading Please wait...

zquery.php

Go to the documentation of this file.

<?php
class zQuery extends zCore{
  var $handle;
  var $conAlias;
  var $num_rows;
  var $affected_rows;
  var $raw_exported;
  var $lex;

  function zQuery($conAlias){
    $this->__construct($conAlias);
  }
  function __construct($conAlias){
    global $__ZigOrm;
    if(!defined('ZIGORM_Q_SELECT')){define('ZIGORM_Q_SELECT', 's');}
    if(!defined('ZIGORM_Q_INSERT')){define('ZIGORM_Q_INSERT', 'i');}
    if(!defined('ZIGORM_Q_UPDATE')){define('ZIGORM_Q_UPDATE', 'u');}
    if(!defined('ZIGORM_Q_REMOVE')){define('ZIGORM_Q_REMOVE', 'r');}
    if(!defined('ZIGORM_Q_SQL')){define('ZIGORM_Q_SQL', 'q');}
    if(!defined('ZIGORM_Q_TRUNCATE')){define('ZIGORM_Q_TRUNCATE', 't');}
    if(!defined('ZIGORM_NO_FLUSH')){define('ZIGORM_NO_FLUSH', false);}
    if(!defined('ZIGORM_FLUSH')){define('ZIGORM_FLUSH', true);}
    if(!defined('ZIGORM_NO_QUOTE'))define('ZIGORM_NO_QUOTE', false);
    if(!defined('ZIGORM_QUOTE'))define('ZIGORM_QUOTE', true);
    if(!defined('ZIGORM_Q_JOIN')){define('ZIGORM_Q_JOIN', 'j');}
    if(!defined('ZIGORM_Q_AUTOJOIN')){define('ZIGORM_Q_AUTOJOIN', 'aj');}
    if(!defined('ZIGORM_JOIN_CROSS'))define('ZIGORM_JOIN_CROSS', 'jc');
    if(!defined('ZIGORM_JOIN_LEFT'))define('ZIGORM_JOIN_LEFT', 'jl');
    if(!defined('ZIGORM_JOIN_RIGHT'))define('ZIGORM_JOIN_RIGHT', 'jr');
    if(!defined('ZIGORM_JOIN_FULL'))define('ZIGORM_JOIN_FULL', 'jf');
    if(!defined('ZIGORM_JOIN_INNER'))define('ZIGORM_JOIN_INNER', 'ji');
    if(!defined('ZIGORM_JOIN_NATURAL'))define('ZIGORM_JOIN_NATURAL', 'jn');
    if(!defined('ZIGORM_OP_EQUALS'))define('ZIGORM_OP_EQUALS', '=');
    if(!defined('ZIGORM_OP_GREATER'))define('ZIGORM_OP_GREATER', '>');
    if(!defined('ZIGORM_OP_LESS'))define('ZIGORM_OP_LESS', '<');
    if(!defined('ZIGORM_OP_GREATER_EQUALS'))define('ZIGORM_OP_GREATER_EQUALS', '>=');
    if(!defined('ZIGORM_OP_LESS_EQUALS'))define('ZIGORM_OP_LESS_EQUALS', '<=');
    if(!defined('ZIGORM_OP_NOT_EQUALS'))define('ZIGORM_OP_NOT_EQUALS', '<>');
    if(!strlen($this->conAlias))$this->conAlias = $conAlias;
    $path = ZIGROOT.DRS.Z_DIR_PROJECTS.DRS.Z_PROJECT_DIR.DRS.ZIGSETTINGSDIR.DRS.Z_DIR_ETC_CONF.DRS.$conAlias.".con.ini.php";
    if(!file_exists($path)){
      perror('<code>zigmoyd.dynamicOrm.init</code><br />Failed to parse the connection file '.$conAlias.' as  the file doesn\'t exist');
      exit;
    }
    $conData = parse_ini_file($path);
    if(!is_object($this->handle)){//-- Experimental Line (If else Conditional Integreety)
      switch(trim($conData['driver'])){
        case 'mysql':
            zLogger::debug("Using Orm driver mysql", 'orm');
            include_once(ZIGROOT.DRS.MOD_KEY_NAME_EXPLICIT.DRS.'orm'.DRS.'driver'.DRS.'mysql.php');
            $this->handle = new OrmDriver_mysql();
          break;
        default:
          zLogger::error("Using Invalid Driver ".$__ZigOrm->connections[$this->conAlias]->driver, 'orm.');
          perror('Invalid Driver '.$__ZigOrm->connections[$this->conAlias]->driver." seleced");
      }
    }
  }
  function init(){
    $this->num_rows = null;
    $this->affected_rows = null;
    $this->raw_exported = null;
  }
  function exec($sqlQuery){
    $this->init();
    $this->handle->connAlias($this->conAlias);
    $this->handle->setCaller(&$this);
    $this->handle->sql = $sqlQuery;
    $this->handle->connect();
    $this->handle->qType(ZIGORM_Q_SQL);
    $ret = $this->handle->execute();
    $this->num_rows = $this->handle->numRows();
    $this->affected_rows = $this->handle->affectedRows();
    $this->raw_exported = $this->handle->exportRaw();
    return $ret;
  }
  function export(){
    $rowSetClassName = get_class($this).'RowSet';
    $ret = array();
    if(!is_array($this->raw_exported))return false;
    foreach($this->raw_exported as $rowId => $rowObj){
      $indx = $rowId;
      $ret[$indx] = new $rowSetClassName;
      $ret[$indx]->colList = $rowObj->colList;
      //$ret[$indx]->handle = &$this;//for PHP5
      unset($rowObj);
    }
    return $ret;
  }
  function numRows(){
    return $this->num_rows;
  }
  function affectedRows(){
    return $this->affected_rows;
  }
}
class zQueryRowSet extends zigRowSet{
  function zQueryRowSet(){
    if(function_exists('overload'))overload(get_class($this));
  }
}
?>

---