加载中...

7.5 添加模型文件

模型是ZF2对数据库操作的核心内容，也是进行数据过滤、数据交换的功能专区。

7.5.1 添加 Album.php

此文件包括数据交换、表单数据过滤功能；添加 /module/Album/src/Album/Model/Album.php 内容如下：

  1. namespace Album\Model;
  2. use Zend\InputFilter\Factory as InputFactory;
  3. use Zend\InputFilter\InputFilter;
  4. use Zend\InputFilter\InputFilterAwareInterface;
  5. use Zend\InputFilter\InputFilterInterface;
  6. class Album implements InputFilterAwareInterface {
  7.     public $id;
  8.     public $artist;
  9.     public $title;
  10.     protected $inputFilter;
  11.     public function exchangeArray($data){
  12.         $this->id       = (isset($data['id'])) ? $data['id'] : null;
  13.         $this->artist   = (isset($data['artist'])) ? $data['artist'] : null;
  14.         $this->title    = (isset($data['title'])) ? $data['title'] : null;
  15.     }
  17.     public function getArrayCopy(){
  18.         return get_object_vars($this);
  19.     }
  21.     public function getInputFilter() {
  22.         if(!$this->inputFilter){
  23.             $this->inputFilter = new InputFilter();
  24.             $factory           = new InputFactory();
  25.             $this->inputFilter->add($factory->createInput(array(
  26.                 'name'=>'id',
  27.                 'required'=>true,
  28.                 'filters'=>array(
  29.                     array('name'=>'Int'),
  30.                 ),
  31.             )));
  33.             $this->inputFilter->add($factory->createInput(array(
  34.                 'name'=>'artist',
  35.                 'required'=>true,
  36.                 'filters'=>array(
  37.                     array('name'=>'StripTags'),
  38.                     array('name'=>'StringTrim'),
  39.                 ),
  40.                 'validators'=>array(
  41.                     array(
  42.                         'name'=>'StringLength',
  43.                         'options'=>array(
  44.                             'encoding'=>'UTF-8',
  45.                             'min'=>5,
  46.                             'max'=>100,
  47.                         ),
  48.                     ),
  49.                 ),
  50.             )));
  52.             $this->inputFilter->add($factory->createInput(array(
  53.                 'name'=>'title',
  54.                 'required'=>true,
  55.                 'filters'=>array(
  56.                     array('name'=>'StripTags'),
  57.                     array('name'=>'StringTrim'),
  58.                 ),
  59.                 'validators'=>array(
  60.                     array(
  61.                         'name'=>'StringLength',
  62.                     'options'=>array(
  63.                         'encoding'=>'UTF-8',
  64.                         'min'=>5,
  65.                         'max'=>100,
  66.                     ),
  67.                     ),
  68.                 ),
  69.             )));
  70.         }
  71.         return $this->inputFilter;
  72.     }
  74.     public function setInputFilter(InputFilterInterface $inputFilter) {
  75.         throw new \Exception('Not used');
  76.     }
  78. }

代码解释：

public function exchangeArray($data){} 数据转换

public function getArrayCopy(){} 克隆对象内属性

public function getInputFilter() {} 过滤器

7.5.2 添加AlbumTable.php

此文件为数据库操作网关，实现对数据库的一系列操作；添加文件：/module/Album/src/Album/Model/AlbumTable.php，具体内容如下：

  1. namespace Album\Model;
  2. use Zend\Db\TableGateway\TableGateway;
  3. use Zend\Db\ResultSet\ResultSet;
  4. use Zend\Db\Sql\Select;
  5. use Zend\Paginator\Adapter\DbSelect;
  6. use Zend\Paginator\Paginator;
  7. class AlbumTable {
  8.     protected $tableGateway;
  9.     public function __construct(TableGateway $tg)
  10.     {
  11.         $this->tableGateway = $tg;
  12.     }
  14.     public function fetchAll($paginated=false)
  15.     {
  16.         if($paginated){// 分页
  17.             $select = new Select('album');
  19.             $rs = new ResultSet();
  20.             $rs->setArrayObjectPrototype(new Album());
  22.             $pageAdapter = new DbSelect($select,$this->tableGateway->getAdapter(),$rs);
  24.             $paginator = new Paginator($pageAdapter);
  25.             return $paginator;
  26.         }
  27.         $resultSet  = $this->tableGateway->select();
  28.         return $resultSet;
  29.     }
  31.     public function getAlbum($id)
  32.     {
  33.         $id = (int) $id;
  34.         $rowset = $this->tableGateway->select(array('id'=>$id));
  35.         $row = $rowset->current();
  37.         if(!$row){
  38.             throw new \Exception("Could not find row {$id}");
  39.         }
  40.         return $row;
  41.     }
  43.     public function saveAlbum(Album $album)
  44.     {
  45.         $data = array(
  46.             'artist' =>$album->artist,
  47.             'title' =>$album->title
  48.         );
  50.         $id = (int) $album->id;
  52.         if($id == 0){
  53.             $this->tableGateway->insert($data);
  54.         }else{
  55.             if($this->getAlbum($id)){
  56.                 $this->tableGateway->update($data,array('id'=>$id));
  57.             }else{
  58.                 throw new \Exception("Could not find row {$id}");
  59.             }
  60.         }
  62.     }
  64.     public function deleteAlbum($id)
  65.     {
  66.         $this->tableGateway->delete(array('id'=>$id));
  67.     }
  68. }

代码解释：

public function fetchAll($paginated=false){} 获取数据表中的所有记录

public function getAlbum($id){} 获取指定ID的记录行

public function saveAlbum(Album $album){} 保存数据到数据库

public function deleteAlbum($id){} 删除指定ID的记录行

还没有评论.