ActiveRecord.php

浏览该文件的文档。

<?php
// FleaPHP Framework
//
// Copyright (c) 2005 - 2008 QeeYuan China Inc. (http://www.qeeyuan.com)
//
// 许可协议，请查看源代码中附带的 LICENSE.txt 文件，
// 或者访问 http://www.fleaphp.org/ 获得详细信息。

class FLEA_Db_ActiveRecord
{
    var $_aggregation = array();

    var $_table;

    var $_idname;

    var $init = false;

    var $_mapping = false;

    function define()
    {
    }

    function FLEA_Db_ActiveRecord($conditions = null)
    {
        $this->init();
        $this->load($conditions);
    }

    function init()
    {
        if ($this->init) { return; }
        $this->init = true;

        $myclass = get_class($this);
        $options = call_user_func(array($myclass, 'define'));
        $tableClass = $options['tableClass'];

        $objid = "{$myclass}_tdg";
        if (FLEA::isRegistered($objid)) {
            $this->_table =& FLEA::registry($objid);
        } else {
            FLEA::loadClass($tableClass);
            $this->_table =& new $tableClass(array('skipCreateLinks' => true));
            FLEA::register($this->_table, $objid);
        }

        if (!empty($options['propertiesMapping'])) {
            $this->_mapping = array(
                'p2f' => $options['propertiesMapping'],
                'f2p' => array_flip($options['propertiesMapping']),
            );
            $this->_idname = $this->_mapping['f2p'][$this->_table->primaryKey];
        } else {
            $this->_mapping = array('p2f' => array(), 'f2p' => array());
            foreach ($this->_table->meta as $field) {
                $this->_mapping['p2f'][$field['name']] = $field['name'];
                $this->_mapping['f2p'][$field['name']] = $field['name'];
            }
            $this->_idname = $this->_table->primaryKey;
        }

        if (!isset($options['aggregation']) || !is_array($options['aggregation'])) {
            $options['aggregation'] = array();
        }
        foreach ($options['aggregation'] as $offset => $define) {
            if (!isset($define['mappingName'])) {
                $define['mappingName'] = substr(strtolower($define['tableClass']), 0, 1) . substr($define['tableClass'], 1);
            }
            if ($define['mappingType'] == HAS_MANY || $define['mappingType'] == MANY_TO_MANY) {
                $this->{$define['mappingName']} = array();
            } else {
                $this->{$define['mappingName']} = null;
            }

            FLEA::loadClass($define['class']);
            $options = call_user_func(array($define['class'], 'define'));

            $link = array(
                'tableClass' => $options['tableClass'],
                'mappingName' => $define['mappingName'],
                'foreignKey' => isset($define['foreignKey']) ? $define['foreignKey'] : null,
            );

            if ($define['mappingType'] == MANY_TO_MANY) {
                $link['joinTable'] = isset($define['joinTable']) ? $define['joinTable'] : null;
                $link['assocForeignKey'] = isset($define['assocForeignKey']) ? $define['assocForeignKey'] : null;
            }

            $this->_table->createLink($link, $define['mappingType']);
            $define['link'] =& $this->_table->getLink($link['mappingName']);
            $this->_aggregation[$offset] = $define;
        }
    }

    function load($conditions)
    {
        $row = $this->_table->find($conditions);
        if (is_array($row)) { $this->attach($row); }
    }

    function save()
    {
        $row =& $this->toArray();
        $this->_table->save($row);
    }

    function delete()
    {
        $this->_table->removeByPkv($this->getId());
    }

    function setId($id)
    {
        $this->{$this->_idname} = $id;
    }

    function getId()
    {
        return $this->{$this->_idname};
    }

    function toArray()
    {
        $arr = array();
        foreach ($this->_mapping['p2f'] as $prop => $field) {
            $arr[$field] = $this->{$prop};
        }
        return $arr;
    }

    function attach(& $row)
    {
        foreach ($this->_mapping['f2p'] as $field => $prop) {
            if (isset($row[$field])) {
                $this->{$prop} = $row[$field];
            }
        }

        foreach ($this->_aggregation as $define) {
            $mn = $define['link']->mappingName;
            if (!isset($row[$mn])) { continue; }
            if ($define['link']->oneToOne) {
                $this->{$mn} =& new $define['class']($row[$mn]);
            } else {
                $this->{$mn}[] =& new $define['class']($row[$mn]);
            }
        }
    }

}

---