Loading Please wait...

base.php

Go to the documentation of this file.

<?php
include_once(ZIGROOT.DRS.MOD_KEY_NAME_EXPLICIT.DRS."orm".DRS."core.php");
class zOrm_base extends zOrm_core{
  function limit($l_query){
    $this->lex['limit'] = trim($l_query);
  }
  function group_by($g_query){
    $this->lex['group'] = trim($g_query);
  }
  function having($h_query){
    $this->lex['having'] = trim($h_query);
  }
  function order($colAlias, $way=ZIGORM_ORDER_ASC){
    if(!$realColName = $this->alias2Real($colAlias)){
      perror("<code>zigmoyd.orm.order()</code><br />Invalid Column Alias Name $colAlias");
      return false;
    }
    switch($way){
      case ZIGORM_ORDER_ASC:
          $drc = 'ASC';
        break;
      case ZIGORM_ORDER_DESC:
          $drc = 'DESC';
        break;
      default:
        perror("<code>zigmoyd.orm.order()</code><br />Invalid Order the second Argument must be one of these two predefined Constants ZIGORM_ORDER_ASC or ZIGORM_ORDER_DESC");
        return false;
    }
    $this->lex['order'][] = array('col' => $realColName, 'way' => $drc);
  }
  function distinct($flag = true){
    $distinctFlag = $flag ? "Distinct" : "UnDistinct";
    zLogger::debug("$distinctFlag Query", 'orm.table.'.$this->realTableName);
    $this->lex['distinct'] = $flag;
  }
  function insert($cleanUp=true){
    if(method_exists($this, 'onInsert')){
      $ret = array();
      foreach($this->lex['attributes'] as $realColName => $val){
        $ret[$this->real2Alias($realColName)] = $val;
      }
      $this->onInsert(&$ret);
      foreach($ret as $colAliasName => $val){
        $this->lex['attributes'][$this->alias2Real($colAliasName)] = $val;
      }
      $this->trgInsert = true;
    }
    foreach($this->lex['attributes'] as $realColName => $val){
      if(method_exists($this, 'onInsert'.$this->real2Alias($realColName))){
        call_user_func(array(&$this, 'onInsert'.$this->real2Alias($realColName)), &$val);
        $this->lex['attributes'][$realColName] = $val;
        $this->trgInsertCol[$this->real2Alias($realColName)] = true;
      }
    }
    if($this->isValidEntry()){
      zLogger::debug("Insertingh Rows successful on Table $this->realTableName (data validatied before insert)", 'orm.insert');
      $this->queryType(ZIGORM_Q_INSERT);
      return $this->exec($cleanUp);
    }else{
      zLogger::debug("Inserting Row(s) failed on Table $this->realTableName due to invalid data entry", 'orm.insert');
      return false;
    }
  }
  function remove($cleanUp=true){
    if(method_exists($this, 'onDelete')){
      $this->onDelete();
    }
    $this->queryType(ZIGORM_Q_REMOVE);
    zLogger::debug("Removing Row(s) on Table $this->realTableName", 'orm.remove');
    return $this->exec($cleanUp);
  }
  function update($cleanUp=true){
    if(method_exists($this, 'onUpdate')){
      $ret = array();
      foreach($this->lex['attributes'] as $realColName => $val){
        $ret[$this->real2Alias($realColName)] = $val;
      }
      $this->onUpdate(&$ret);
      foreach($ret as $colAliasName => $val){
        $this->lex['attributes'][$this->alias2Real($colAliasName)] = $val;
      }
      $this->trgUpdate = true;
    }
    foreach($this->lex['attributes'] as $realColName => $val){
      if(method_exists($this, 'onUpdate'.$this->real2Alias($realColName))){
        call_user_func(array(&$this, 'onUpdate'.$this->real2Alias($realColName)), &$val);
        $this->lex['attributes'][$realColName] = $val;
        $this->trgUpdateCol[$this->real2Alias($realColName)] = true;
      }
    }
    if($this->isValidUpdate()){
      zLogger::debug("Updating Row(s) successful on Table $this->realTableName (data validatied before update)", 'orm.update');
      $this->queryType(ZIGORM_Q_UPDATE);
      return $this->exec($cleanUp);
    }else{
      zLogger::debug("Updating Row(s) failed on Table $this->realTableName due to invalid data entry", 'orm.update');
      $this->initLex();
      return false;
    }
  }
  function delete($cleanUp=true){
    if(method_exists($this, 'onDelete')){
      $this->onDelete();
    }
    $this->queryType(ZIGORM_Q_REMOVE);
    zLogger::debug("Removing Row(s) on Table $this->realTableName", 'orm.remove');
    return $this->exec($cleanUp);
  }
  function isValidEntry(){
    load_module('validation');//Load the validation module
    $data = array();
    $rulesDict = array();
    foreach($this->lex['attributes'] as $realColName => $val){
      $data[$this->real2alias($realColName)] = $val;
      $this->lex['attributes'][$realColName] = ($this->colQuote[$realColName]==ZIGORM_QUOTE) ? "'$val'" : $val;//add Quotes to the Columns
      $rulesDict[$this->real2alias($realColName)] = array();
      if(isset($this->__struct->Attributes[$realColName]->criteria) && is_array($this->__struct->Attributes[$realColName]->criteria)){
        foreach($this->__struct->Attributes[$realColName]->criteria as $ruleName => $errMsg){
          $rulesDict[$this->real2alias($realColName)][$ruleName] = $errMsg;
        }
      }
    }
    $ormVld = new validation($data);
    foreach($rulesDict as $colAliasName => $ruleArray){
      $ormVld->addCriteria($colAliasName, $ruleArray);
    }
    $this->validation->isValid = $ormVld->isValid();//Check wheather or not every column's value is valid
    foreach($data as $colAliasName => $dummyValue){
      if(isset($this->__struct->Attributes[$this->alias2real($colAliasName)]->criteria)){
        $this->validation->{$colAliasName} = new zRom_fields($dummyValue, $ormVld->errtext($colAliasName), $ormVld->isValid($colAliasName), $ormVld->validationStatus($colAliasName));
        if(!$this->validation->{$colAliasName}->isValid())$this->validation->errCols[$colAliasName] = $this->validation->{$colAliasName}->errMsg();
      }else{
        $this->validation->{$colAliasName} = new zRom_fields($data[$dummyValue], true, true, true);
      }
    }
    return $this->validation->isValid;
  }
  function isValidUpdate(){
    load_module('validation');
    $data = array();
    $rulesDict = array();
    foreach($this->lex['attributes'] as $realColName => $val){
      if(!(is_bool($val) && !$val)){
        $colAlias = $this->real2Alias($realColName);
        $data[$colAlias] = $val;
        if(isset($this->__struct->Attributes[$realColName]->criteria) && is_array($this->__struct->Attributes[$realColName]->criteria)){
          $rulesDict[$colAlias] = array();
          foreach($this->__struct->Attributes[$realColName]->criteria as $ruleName => $errMsg){
            $rulesDict[$colAlias][$ruleName] = $errMsg;
          }
        }
        $this->lex['attributes'][$realColName] = ($this->colQuote[$realColName]==ZIGORM_QUOTE) ? "'$val'" : $val;//add Quotes to the Columns
      }
    }
    $ormVld = new validation($data);
    foreach($rulesDict as $colAliasName => $ruleArray){
      zLogger::udebug("Adding Rules for Column $colAliasName");
      $ormVld->addCriteria($colAliasName, $ruleArray);
    }
    $this->validation->isValid = $ormVld->isValid();//Check wheather or not every column's value is valid
    $this->validation->errCols = array();
    foreach($data as $colAliasName => $dummyValue){
      if(isset($this->__struct->Attributes[$this->alias2real($colAliasName)]->criteria)){
        $this->validation->{$colAliasName} = new zRom_fields($dummyValue, $ormVld->errtext($colAliasName), $ormVld->isValid($colAliasName), $ormVld->validationStatus($colAliasName));
        if(!$this->validation->{$colAliasName}->isValid())$this->validation->errCols[$colAliasName] = $this->validation->{$colAliasName}->errMsg();
      }else{
        $this->validation->{$colAliasName} = new zRom_fields($data[$dummyValue], true, true, true);
      }
    }
    return $this->validation->isValid;
  }
  function index($colAlias){
    zLogger::debug("indexing export data with $colAlias Column", 'orm.export.index');
    $this->__indexKey = $colAlias;
  }
  function export($cleanUp=true){
    zLogger::debug("Exporting result set", 'orm.export');
    if(!$this->__rdbmsJoin){
      $this->queryType(ZIGORM_Q_SELECT);
    }else{
      zLogger::debug("issuing Join before exporting", 'orm.export');
      $this->join();
      $this->queryType(ZIGORM_Q_JOIN);
    }
    $this->exec(false);
    if(method_exists($this, 'onExport')){
      $this->onExport(&$this->rawExported);
    }
    $rowSetClassName = get_class($this).'RowSet';
    $ret = array();
    if(!is_array($this->rawExported)){
      $this->__indexKey = null;
      $this->initLex();
      return false;
    }
    foreach($this->rawExported as $rowId => $rowObj){
      if(strlen(trim($this->__indexKey))){
        if(!isset($rowObj->colList[$this->__indexKey])){
          perror("<code>zigmoyd.orm.export.index</code><br />Invalid Index $this->__indexKey<br />Its worth to mention that you also need to fetch the Index column");
          return false;
        }
        $indx = $rowObj->colList[$this->__indexKey];
      }else{
        $indx = $rowId;
      }
      $ret[$indx] = new $rowSetClassName;
      foreach($rowObj->colList as $colAlias => $val){
        if(method_exists($this, 'onExport'.$colAlias)){
           call_user_func(array(&$this, 'onExport'.$colAlias), &$rowObj->colList[$colAlias]);
        }
      }
      $ret[$indx]->colList = $rowObj->colList;
      //$ret[$indx]->handle = &$this;//for PHP5
      unset($rowObj);
    }
    if($cleanUp){
      $this->__indexKey = null;
      $this->initLex();
    }
    return $ret;
  }
}
?>

---