지역 사회 배우다 도구 라이브러리 여가
찾다
한국어
집 > 백엔드 개발 > PHP 튜토리얼 > PHP 객체 지향의 선택 팩토리 및 업데이트 팩토리 정보

PHP 객체 지향의 선택 팩토리 및 업데이트 팩토리 정보

炎欲天舞
풀어 주다： 2023-03-14 16:30:01
원래의
1259명이 탐색했습니다.


/*
选择工厂和更新工厂模式，这个模式的类(UpdateFactory和SelectionFactory类)就是用来创建SQL语句的.
因为涉及到之前学习的内容比较多，这里就尽量将之前相关模式的示例代码放在一起来进行学习和回顾了。
以下的代码都是代码片段而且涉及到连接数据库，无法进行整体的调试(某些部分单独拿出来的话就可以)，因此重在理解。
*/



//更新工厂
abstract class UpdateFactory{
    
    abstract function newUpdate(\woo\domain\DomainObject $obj);
    
    //拼接更新或插入的sql语句
    protected function buildStatement($table,array $fields ,array $condition = null){
        $terms = array(); //SQL语句中占位符所代表的实际值
        if(!is_null($condition)){        //有条件则拼接更新语句，无条件则拼接插入语句
            $query = "UPDATE {$table} SET";
            $query .= implode(" = ? " ,array_keys($fields)) . " = ? ";
            $terms = array_values($fields);
            $cond = array();
            $query .= " WHERE ";
            foreach($condition as $key=>$val){
                $cond[] = " $key = ? ";
                $terms[] = $val;
            }
            $query .= implode(" AND ",$cond);
        } else {
            $query = " INSERT INTO {$table} (";
            $query .= implode(",",array_keys($fields));
            $query .= " ) VALUES ( ";
            foreach($fields as $name => $value){
                $terms[] = $value;
                $qs[] = "?";
            }
            $query .= implode(",",$qs);
            $query .=" ) ";
        }
        return array($query,$terms);
    }
}

//通过领域模型生成SQL语句
class VenueUpdateFactory extends UpdateFactory{
    function newUpdate(\woo\domain\DomainObject $obj){
        $id = $obj->getId();
        $cond = null;
        $values['name'] = $obj->getName();
        if($id > -1 ){
            $cond["id"] = $id;
        }
        return $this->buildStatement("venue",$values,$cond);
    }
}


//选择工厂
abstract class SelectionFactory{
    abstract function newSelection(IdentityObject $obj);
    
    //通过标识对象拼接sql语句的where条件语句
    function buildWhere (IdentityObject $obj){
        if($obj->isVoid){
            return array("",array());
        }
        $compstrings = array();
        $values = array();
        foreach($obj->getComps() as $comp){
            $compstrings[] = "{$comp['name']} {$comp['operator']} ?";
            $values[] = $comp['value'];
        }
        $where =  " WHERE " . implode(" AND ",$compstrings);
        return array($where,$values);
    }
}

//拼接select语句
class VenuSelectionFactory extends SelectionFactory {
    function newSelection(IdentityObject $obj){
        $field = implode(',',$obj->getObjectFields());
        $core = "SELECT $fields FROM venue";
        list($where,$values) = $this->buildWhere($obj);
        return array($core." ".$where,$values);
    }
}

//现在来回顾一下之前学习过的相关知识
//字段对象
class Field {
    protected $name = null;          //字段名称
    protected $operator = null;         //操作符    
    protected $comps = array();         //存放条件的数组    
    protected $incomplete = false;     //检查条件数组是否有值
    
    function __construct ($name){
        $this->name= $name;
    }
    
    //添加where 条件
    function addTest($operator,$value){
        $this->comps[] = array('name'=>$this->name,'operator'=>$operator,'value'=>$value);
    }
    
    //获取存放条件的数组
    function getComps(){
        return $this->comps;
    }
    
    function isIncomplete(){
        return empty($this->comps);
    }
}

//标识对象,主要功能就是拼接where条件语句
class IdentityObject {
    protected $currentfield = null;        //当前操作的字段对象
    protected $fields = array();        //字段对象集合
    private $and = null;
    private $enforce = array();            //限定的合法字段        
    
    function __construct($field = null, array $enforce = null){
        if(!is_null($enforce)){
            $this->enforce = $enforce;
        }
        if(!is_null($field)){
            $this->field($field);
        }
    }
    
    //获取限定的合法字段
    function getObjectFields(){
        return $this->enforce;
    }
    
    //主要功能为设置当前需要操作的字段对象
    function field($fieldname){
        if(!$this->isVoid()&& $this->currentfield->isIncomplete()){
            throw new \Exception("Incomplete field");
        }
        $this->enforceField($fieldname);
        if(isset($this->fields[$fieldname]){
            $this->currentfield = $this->fields[$fieldname];
        } else {
            $this->currentfield = new Field($fieldname);
            $this->fields[$fieldname] = $this->currentfield;
        }
        return $this;                    //采用连贯语法
    }
    
    //字段集合是否为空
    function isVoid(){
        return empty($this->fields);
    }
    
    //检查字段是否合法
    function enforceField ($fieldname){
        if(!in_array($fieldname,$this->enforce) && !empty($this->enforce)){
            $forcelist = implode(',',$this->enforce);
            throw new \Exception("{$fieldname} not a legal field {$forcelist}");
        }
    }
    
    
    //向字段对象添加where条件
    function eq($value){
        return $this->operator("=",$value);
    }
    
    function lt($value){
        return $this->operator("<",$value);
    }
    
    function gt($value){
        return $this->operator(">",$value);
    }
    
    //向字段对象添加where条件
    private function operator($symbol,$value){
        if($this->isVoid){
            throw new \Exception("no object field defined");
        }
        $this->currentfield->addTest($symbol,$value);
        return $this;                                     //采用连贯语法
    }
    
    //获取此类中所有字段对象集合的where条件数组
    function getComps(){
        $ret = array();
        foreach($this->fields as $key => $field){
            $ret = array_merge($ret,$field->getComps());
        }
        return $ret;
    }
}


//数据映射器

class DomainObjectAssembler {
    protected static $PDO;
    
    //PersistenceFactory本例中并未实现，按原书的说法读者自己完成
    //其主要功能就是生成相应类型的选择工厂类、更新工厂类或Collection对象
    //在初始化的时候根据传入的PersistenceFactory对象决定了这个类是映射那个数据库表和领域模型的
    function __construct (PersistenceFactory $factory){
        $this->factory = $factory;
        if(!isset(self::$PDO)){
            $dsn = \woo\base\ApplicationRegistry::getDSN();
            if(is_null($dsn)){
                throw new \woo\base\AppException("NO DSN");
            }
            self::$PDO = new \PDO ($dsn);
            self::$PDO->setAttribute(\PDO::ATTR_ERRMODE,\PDO::ERRMODE_EXCEPTION);
        }
    }
    
    //获取预处理对象，用sql语句本身做为对象数组的键
    function getStatement($str){
        if(!isset($this->statements[$str])){
            $this->statements[$str] = self::$PDO->prepare($str);
        }
        return $this->statements[$str];
    }
    
    //根据where条件返回一条数据
    function findOne(IdentityObject $idobj){
        $collection = $this->find($idobj);
        return $collection->next();
    }
    
    //根据where条件返回一个数据集合
    function find(IdentityObject $idobj){
        $selfact = $this->factory->getSelectionFactory();             //获取选择工厂对象
        list($selection,$values) = $selfact->newSelection($idobj);    //获取sql语句
        $stmt = $this->getStatement($selection);                    //获取预处理对象
        $stmt->execute($values);                    
        $raw = $stmt->fetchAll();
        return $this->factory->getCollection($raw);                    //还记得Collection对象吗，下面粘出代码回顾一下
    }
    
    //根据where条件插入或更新一条数据
    function insert(\woo\domain\DomainObject $obj){
        $upfact = $this->factory->getUpdateFactory();        //获取更新工厂对象
        list($update,$values) = $upfact->newUpdate($obj);    //获取sql语句
        $stmt = $this->getStatement($update);                //获取预处理对象
        $stmt->execute($values);
        if($obj->getId()<0){                                    
            $obj->setId(self::$PDO->lastInsertId);
        }
        $obj->markClean();
    }
    
    
}

/*
这里在回顾一下Collection类,当然这个类和上面使用的Collection类是有差别的,因为至少这里的Mapper类与之前相比发生了一些变化
Iterator接口定义的方法:
rewind()            指向列表开头    
current()            返回当前指针处的元素
key()                返回当前的键（比如，指针的指）
next()                
valid()

下面这个类是处理多行记录的，传递数据库中取出的原始数据和映射器进去，然后通过数据映射器在获取数据时将其创建成对象

*/
abstract class Collection implements \Iterator{
    protected $mapper;            //数据映射器
    protected $total = 0;        //集合元素总数量
    protected $raw = array();    //原始数据
    
    private $result;
    private $pointer = 0;        //指针
    private $objects = array();    //对象集合
    
    function __construct (array $raw = null,Mapper $mapper= null){
        if(!is_null($raw)&& !is_null($mapper)){
            $this->raw = $raw;
            $this->total = count($raw);
        }
        $this->mapper = $mapper;
    }
    
    function add(\woo\domain\DmainObject $object){    //这里是直接添加对象
        $class = $this->targetClass();
        if(!($object instanceof $class)){
            throw new Exception("This is a {$class} collection");
        }
        $this->notifyAccess();
        $this->objects[$this->total] = $object;
        $this->total ++;
    }
    
    abstract function targetClass();    //子类中实现用来在插入对象时检查类型的
    
    protected function notifyAccess(){    //不知道干嘛的
        
    }
    
    private function getRow($num){        //获取集合中的单条数据，就是这里通过数据映射器将数据创建成对象
        $this->notifyAccess();
        if($num >= $this->total || $num < 0){
            return null;
        }
        if(isset($this->objects[$num]){
            return $this->objects[$num];
        }
        if(isset($this->raw[$num]){
            $this->objects[$num] = $this->mapper->createObject($this->raw[$num]);
            return $this->objects[$num];
        }
    }
    
    public function rewind(){            //重置指针
        $this->pointer = 0;
    }
    
    public function current(){            //获取当前指针对象
        return $this->getRow($this->pointer);
    }
    
    public function key(){                //获取当前指针
        return $this->pointer;
    }
    
    public function next(){            //获取当前指针对象,并将指针下移    
        $row = $this->getRow($this->pointer);
        if($row){$this->pointer ++}
        return $row;
    }
    
    public function valid(){        //验证
        return (!is_null($this->current()));
    }
    
}

//子类
class VenueColletion extends Collection implements \woo\domain\VenueCollection{
    function targetClass(){
        return "\woo\domain\Venue";
    }
}



//客户端
//初始化一个能够获取venue类型的选择工厂类、更新工厂类或Collection对象的超级工厂类
$factory = \woo\mapper\PersistenceFactory::getFactory("woo\\domain\\Venue");    
$finder = new \woo\mapper\DomainObjectAssembler($factory);        //数据映射器
$idobj = $factory->getIdentityObject()->field(&#39;name&#39;)->eq(&#39;The Eyeball Inn&#39;);    //设置where条件语句
$collection = $finder->find($idobj);                    //根据where条件查找一个数据集合(一个Collection对象)
foreach($collection as $venue){                            
    print $venue->getName()."\n";
}
로그인 후 복사

 

위 내용은 PHP 객체 지향의 선택 팩토리 및 업데이트 팩토리 정보의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

관련 라벨：
php 공장 선택하다
원천：php.cn
이전 기사：PHP에서 배열 길이를 계산하는 방법은 무엇입니까? 다음 기사：PHP 배열 사용 방법 요약
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
저자별 최신 기사
최신 이슈
URL 매개변수에서 얻은 PHP 배열이 예상대로 작동하지 않습니다. 카테고리 ID가 포함된 URL 매개변수가 있고 이를 다음과 같은 배열로 처리하려고 합니다. http://example.com?cat[]=3,9,13 PHP에서는 ...
에서 2024-04-06 22:09:02
0
1
1428
Apache에서 CustomLog 지시문을 어디에 배치해야 합니까? 저는 php:7.2-apachedocker를 사용하고 있습니다. 상태 확인 URL 로그인 액세스 로그를 비활성화해야 합니다. 이 링크를 기반으로 Customlog...
에서 2024-04-06 22:03:59
0
1
990
반환 값의 변수 형식은 무엇입니까? 저는 PHP를 처음 배우는 사람입니다. 코드 조각을 찾았습니다: if($x<time()){return[false,'error'];} 논리나 변수는 중요하지 ...
에서 2024-04-06 21:55:20
0
1
778
opentbs를 사용하여 odt 파일을 생성할 때 발생하는 문제: 동일한 키의 값이 별도의 열이 아닌 동일한 행에 표시됩니다. PHP를 사용하여 odt를 만들기 위해 OpenTbs라는 라이브러리를 사용하고 있는데, 열과 행이 동적으로 생성되기 때문에 사용하고 있습니다. 행과 열을 만드는 ...
에서 2024-04-06 20:18:18
0
1
483
루프 오버를 위해 ID별로 MySQL 결과 그룹화 mysql에 비행 데이터가 포함된 테이블이 있습니다. codeigniter3 travel_idair_idFlightDurationout_or_inflightdur...
에서 2024-04-06 17:27:56
0
1
406
관련 주제
더>
인기 추천
인기 튜토리얼
더>
관련 튜토리얼
인기 추천
최신 강좌
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿