class.arConnectorSession.php

Go to the documentation of this file.

<?php
require_once('class.arConnector.php');
require_once(dirname(__FILE__) . '/../Exception/class.arException.php');

class arConnectorSession extends arConnector {

        const AR_CONNECTOR_SESSION = 'arConnectorSession';


        public static function resetSession() {
                $_SESSION[self::AR_CONNECTOR_SESSION] = array();
        }


        public static function getSession() {
                if (!$_SESSION[self::AR_CONNECTOR_SESSION]) {
                        self::resetSession();
                }

                return $_SESSION[self::AR_CONNECTOR_SESSION];
        }


        public static function getSessionForActiveRecord(ActiveRecord $ar) {
                $session = self::getSession();
                $ar_session = $session[$ar::returnDbTableName()];
                if (!is_array($ar_session)) {
                        $ar_session = array();
                }

                return $ar_session;
        }


        public function checkConnection(ActiveRecord $ar) {
                return is_array(self::getSession());
        }


        public function nextID(ActiveRecord $ar) {
                return count(self::getSessionForActiveRecord($ar)) + 1;
        }


        public function installDatabase(ActiveRecord $ar, $fields) {
                return self::resetDatabase($ar);
        }


        public function updateDatabase(ActiveRecord $ar) {
                return true;
        }


        public function resetDatabase(ActiveRecord $ar) {
                $_SESSION[self::AR_CONNECTOR_SESSION][$ar::returnDbTableName()] = array();

                return true;
        }


        public function truncateDatabase(ActiveRecord $ar) {
                return self::resetDatabase($ar);
        }


        public function checkTableExists(ActiveRecord $ar) {
                return is_array(self::getSessionForActiveRecord($ar));
        }


        public function checkFieldExists(ActiveRecord $ar, $field_name) {
                $session = self::getSessionForActiveRecord($ar);

                return array_key_exists($field_name, $session[0]);
        }


        public function removeField(ActiveRecord $ar, $field_name) {
                return true;
        }


        public function renameField(ActiveRecord $ar, $old_name, $new_name) {
                return true;
        }


        public function create(ActiveRecord $ar) {
                $_SESSION[self::AR_CONNECTOR_SESSION][$ar::returnDbTableName()][$ar->getPrimaryFieldValue()] = $ar->__asStdClass();
        }


        public function read(ActiveRecord $ar) {
                $session = self::getSessionForActiveRecord($ar);

                return array( $session[$ar->getPrimaryFieldValue()] );
        }


        public function update(ActiveRecord $ar) {
                self::create($ar);
        }


        public function delete(ActiveRecord $ar) {
                unset($_SESSION[self::AR_CONNECTOR_SESSION][$ar::returnDbTableName()][$ar->getPrimaryFieldValue()]);
        }


        public function readSet(ActiveRecordList $arl) {
                $session = self::getSessionForActiveRecord($arl->getAR());
                foreach ($session as $i => $s) {
                        $session[$i] = (array)$s;
                }
                foreach ($arl->getArWhereCollection()->getWheres() as $w) {
                        $fieldname = $w->getFieldname();
                        $v = $w->getValue();
                        $operator = $w->getOperator();

                        foreach ($session as $i => $s) {
                                $session[$i] = (array)$s;
                                switch ($operator) {
                                        case '=':
                                                if ($s[$fieldname] != $v) {
                                                        unset($session[$i]);
                                                }
                                                break;
                                }
                        }
                }

                return $session;
        }


        public function affectedRows(ActiveRecordList $arl) {
                return count($this->readSet($arl));
        }


        public function quote($value, $type) {
                return $value;
        }


        public function updateIndices(ActiveRecord $ar) {
                // TODO: Implement updateIndices() method.
        }
}

?>