日期:2014-05-17 浏览次数:20583 次
Mapper类中的findById($id)可以从数据库中取出指定id的一条数据,映射成一个对象返回。很多时候我们需要返回一个数据集合(findAll),那我们就需要一种数据结构来保存这些数据,在需要时映射成对象。既然一条数据映射成一个对象,那么一个数据集合就需要一个对象集合。可以把数据集合和对象集合放在一个类中,这样就方便处理数据到对象的映射了。我们把这个类命名为Collection,为了能更好好的访问集合对象,Collection子类都实现了Iterator接口,使用foreach可以方便访问。
Collection的类结构:
\demo\mapper\Collection:
namespace demo\mapper; use demo\base\AppException; use demo\domain\DomainObject; use demo\mapper\Mapper; abstract class Collection { // 保存数据库取出的行数据 protected $raws; // 保存已映射的对象 protected $objects = array(); // 用于$raws[]到$objects的映射 protected $mapper; // 当前指针 private $pointer = 0; // 对象数组总数 private $total = 0; /** * @param array $raws 未处理过的数据库数据 * @param Mapper $mapper 用于把$raws映射成对象(createObject) */ public function __construct(array $raws = null, Mapper $mapper = null) { if (!is_null($raws) && !is_null($mapper)) { $this->raws = $raws; $this->total = count($raws); } $this->mapper = $mapper; } /** * 返回指定$num的数据对象 * @param int $num */ public function getRow($num) { if ($num < 0 || $num >= $this->total) { return null; } // 延迟加载 $this->notifyAccess(); if (isset($this->objects[$num])) { return $this->objects[$num]; } if (isset($this->raws[$num])) { $obj = $this->mapper->createObject($this->raws[$num]); $this->objects[$num] = $obj; return $obj; } return null; } /** * 添加对象 * @param DomainObject $obj * @throws AppException */ public function add(DomainObject $obj) { // 类型安全检查 $targetClass = $this->getTargetClass(); if (!($obj instanceof $targetClass)) { throw new AppException("Object must be {$targetClass}"); } // $this->notifyAccess(); $this->objects[$this->pointer++] = $obj; } public function current() { return $this->getRow($this->pointer); } public function next() { $obj = $this->getRow($this->pointer); if (!is_null($obj)) { $this->pointer++; } return $obj; } public function key() { return $this->pointer; } public function rewind() { $this->pointer = 0; } public function valid() { return !is_null($this->current()); } /** * 延迟加载 */ protected function notifyAccess() { // 暂时留空 } protected abstract function getTargetClass(); }
\demo\domain:
namespace demo\domain; use \demo\domain\DomainObject; interface ClassroomCollection extends \Iterator { public function add(DomainObject $obj); } interface StudentCollection extends \Iterator { public function add(DomainObject $obj); } interface ScoreCollection extends \Iterator { public function add(DomainObject $obj); }\demo\mapper:
namespace demo\mapper; class ClassroomCollection extends Collection implements \demo\domain\ClassroomCollection { protected function getTargetClass() { return '\demo\domain\Classroom'; } } class StudentCollection extends Collection implements \demo\domain\StudentCollection { protected function getTargetClass() { return '\demo\domain\Student'; } } class ScoreCollection extends Collection implements \demo\domain\ScoreCollection { protected function getTargetClass() { return '\demo\domain\Score'; } }为什么需要为domain包还需要一个Collection接口呢?因为domain包需要用到Collection来保存数据,为了让domain包不依赖于mapper包的Collection,所以创建了一个接口。而\demo\domain\mapper\Collection则会实现这个接口。