SDAO.php

Go to the documentation of this file.

<?php
namespace Ubiquity\orm;
 
use Ubiquity\db\Database;
use Ubiquity\db\SqlUtils;
use Ubiquity\events\DAOEvents;
use Ubiquity\events\EventsManager;
use Ubiquity\log\Logger;
use Ubiquity\orm\parser\ConditionParser;
use Ubiquity\orm\parser\Reflexion;
 
class SDAO extends DAO {
 
    protected static function _getOne(Database $db, $className, ConditionParser $conditionParser, $included, $useCache) {
        $conditionParser->limitOne();
        $object = null;
 
        $metaDatas = OrmUtils::getModelMetadata($className);
        $tableName = $metaDatas['#tableName'];
 
        $query = $db->prepareAndExecute($tableName, SqlUtils::checkWhere($conditionParser->getCondition()), self::_getFieldList($tableName, $metaDatas), $conditionParser->getParams(), $useCache, true);
        if ($query) {
            $object = self::sloadObjectFromRow($query, $className);
            EventsManager::trigger(DAOEvents::GET_ONE, $object, $className);
        }
        return $object;
    }
 
    protected static function _getAll(Database $db, $className, ConditionParser $conditionParser, $included = true, $useCache = NULL) {
        $objects = array();
 
        $metaDatas = OrmUtils::getModelMetadata($className);
        $tableName = $metaDatas['#tableName'];
 
        $query = $db->prepareAndExecute($tableName, SqlUtils::checkWhere($conditionParser->getCondition()), self::_getFieldList($tableName, $metaDatas), $conditionParser->getParams(), $useCache);
 
        foreach ($query as $row) {
            $objects[] = self::sloadObjectFromRow($row, $className);
        }
        EventsManager::trigger(DAOEvents::GET_ALL, $objects, $className);
        return $objects;
    }
 
    private static function sloadObjectFromRow($row, $className) {
        $o = new $className();
        foreach ($row as $k => $v) {
            $o->$k = $v;
        }
        $o->_rest = $row;
        return $o;
    }
 
    public static function update($instance, $updateMany = false) {
        EventsManager::trigger('dao.before.update', $instance);
        $className = \get_class($instance);
        $db = self::getDb($className);
        $quote = $db->quote;
        $tableName = OrmUtils::getTableName($className);
        $ColumnskeyAndValues = Reflexion::getPropertiesAndValues($instance);
        $keyFieldsAndValues = OrmUtils::getKeyFieldsAndValues($instance);
        $sql = "UPDATE {$quote}{$tableName}{$quote} SET " . SqlUtils::getUpdateFieldsKeyAndParams($ColumnskeyAndValues) . ' WHERE ' . SqlUtils::getWhere($keyFieldsAndValues);
        $statement = $db->getUpdateStatement($sql);
        try {
            $result = $statement->execute($ColumnskeyAndValues);
            EventsManager::trigger(DAOEvents::AFTER_UPDATE, $instance, $result);
            if (Logger::isActive()) {
                Logger::info("DAOUpdates", $sql, "update");
                Logger::info("DAOUpdates", \json_encode($ColumnskeyAndValues), "Key and values");
            }
            $instance->_rest = \array_merge($instance->_rest, $ColumnskeyAndValues);
            return $result;
        } catch (\Exception $e) {
            Logger::warn("DAOUpdates", $e->getMessage(), "update");
        }
        return false;
    }
}