[ORM篇]
什么是ORM,百度的解释:
对象关系映射(英语:(Object Relational Mapping,简称ORM,或O/RM,或O/R mapping),是一种程序技术,用于实现面向对象编程语言里不同类型系统的数据之间的转换[1] 。从效果上说,它其实是创建了一个可在编程语言里使用的--“虚拟对象数据库”。
说了一大堆,不懂。简单来如果用在我们数据库呢就是,让Model(数据库所有的操作对象)与数据表产生对应关系(关联)的一种方法,或者说一种思想,比如你来了个User.php就是对User表的操作
我们现在开始吧,首先我们更改原本的文件路径,把Home、Back里面的Model抽出来,放到App下取名为Entity,以后这个Entity就是我们的Model目录,意思就是Model不分前后台,区别只要同一个Model区分不同的方法名即可。
Entity就是实体的意思。现在开始创建父类模型,Core/Orm.php。 我们实现类名与表名的对应关系的方法是通过父类Orm.php在其构造方法里获取有谁继承了的类名,PHP自带了一个方法可以获取继承类的类名----
get_called_class(); //App\Entity\Users
这样就获取了包含命名空间的类名,现在我们要处理这个包含命名空间的类名,让其仅仅剩下Users
<?php/** * * Orm.php * User: kalvin * Date: 2018/2/1 * Time: 下午3:02 */namespace Core;/** * Class Orm * @package Core * ORM 父类方法 */class Orm{ private $className; private $server; private $type; private $username; private $password; private $port; private $dbname; private $charset; private $_pdo; public function __construct() { $holeClassName=get_called_class(); //App\Entity\Users $arr=explode('\\',$holeClassName); $this->className=strtolower($arr[count($arr)-1]); //根据配置文件项连接数据库 $this->server=$GLOBALS['conf']['mysql']['server']; $this->type=$GLOBALS['conf']['mysql']['type']; $this->username=$GLOBALS['conf']['mysql']['username']; $this->password=$GLOBALS['conf']['mysql']['password']; $this->port=$GLOBALS['conf']['mysql']['port']; $this->dbname=$GLOBALS['conf']['mysql']['dbname']; $this->charset=$GLOBALS['conf']['mysql']['charset']; $this->connect(); } public function connect(){ $dsn="$this->type:host=$this->server;dbname=$this->dbname;port=$this->port;charset=$this->charset"; $this->_pdo=new \PDO($dsn,$this->username,$this->password); } }
这样就能连接了,现在我们只要把上面私有化的变量拼接到sql语句中即可
<?php/** * * Orm.php * User: kalvin * Date: 2018/2/1 * Time: 下午3:02 */namespace Core;/** * Class Orm * @package Core * ORM 父类方法 */class Orm{ private $className; private $server; private $type; private $username; private $password; private $port; private $dbname; private $charset; private $_pdo; public function __construct() { $holeClassName=get_called_class(); //App\Entity\Users $arr=explode('\\',$holeClassName); $this->className=strtolower($arr[count($arr)-1]); //根据配置文件项连接数据库 $this->server=$GLOBALS['conf']['mysql']['server']; $this->type=$GLOBALS['conf']['mysql']['type']; $this->username=$GLOBALS['conf']['mysql']['username']; $this->password=$GLOBALS['conf']['mysql']['password']; $this->port=$GLOBALS['conf']['mysql']['port']; $this->dbname=$GLOBALS['conf']['mysql']['dbname']; $this->charset=$GLOBALS['conf']['mysql']['charset']; $this->connect(); } public function connect(){ $dsn="$this->type:host=$this->server;dbname=$this->dbname;port=$this->port;charset=$this->charset"; $this->_pdo=new \PDO($dsn,$this->username,$this->password); $this->_pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION); } public function select() { $sql='select * from '.$this->className; $res=$this->query($sql); return $res->fetchAll(\PDO::FETCH_ASSOC); } public function query($sql) { try{ $resObj=$this->_pdo->query($sql); }catch (\PDOException $e){ $resObj=$this->errors($e,$sql); } return $resObj; } public function errors($e,$sql) { echo '错误信息为:'.$e->getMessage().'<br/>';// echo '错误代码为:'.$e->errorCode() ().'<br/>'; echo '错误语句为:'.$sql.'<br/>'; return false; } }
上面的select方法就是拼接了继承的类名的方法
[连贯操作]
我们在使用其他框架的时候发现我们存在着一些连贯操作,那么这个连贯操作怎么实现呢?
比如说laravel有个
我们可以动手试试,无论tp还是laravel,他们的连贯操作还有一个关键点,就是如果只有$Useres->where(.....),返回值是什么?一般这个返回值是对象,也就是保留了某些操作的对象。我们看看怎么实现吧。
我们首先先定义
private $where=’ 1 ‘;
用于存放拼接好的字符串
/** * @return mixed * 连贯操作的 get方法 */public function get(){ $sql='select * from '.$this->className.' where'; $sql.=$this->where; $res=$this->query($sql); return $res->fetchAll(\PDO::FETCH_ASSOC); }
注意:$this->className后面需要拼接一个空格以防与where语句连接在一起
重头戏来了我们开始写where方法用于连贯操作!
/** * @param $field 字段名 * @param $operator 符号,> < = >= eq等等。。 * @param $condition 数值或字符串 * 用户连贯操作的where方法 */public function where($field,$operator,$condition){ $this->where.=' '.$field.' '.$operator.' '.$condition.' '; return $this; }
关键在于return
但是我们使用中发现,where只能用一次,如果我有多个where条件就不行了。会报语法错误!
我们继续完善
结果
<?php/** * * Orm.php * User: kalvin * Date: 2018/2/1 * Time: 下午3:02 */namespace Core;/** * Class Orm * @package Core * ORM 父类方法 */class Orm{ private $className; private $server; private $type; private $username; private $password; private $port; private $dbname; private $charset; private $_pdo; private $where=' 1 '; private $limit=''; public function __construct() { $holeClassName=get_called_class(); //App\Entity\Users $arr=explode('\\',$holeClassName); $this->className=strtolower($arr[count($arr)-1]); //根据配置文件项连接数据库 $this->server=$GLOBALS['conf']['mysql']['server']; $this->type=$GLOBALS['conf']['mysql']['type']; $this->username=$GLOBALS['conf']['mysql']['username']; $this->password=$GLOBALS['conf']['mysql']['password']; $this->port=$GLOBALS['conf']['mysql']['port']; $this->dbname=$GLOBALS['conf']['mysql']['dbname']; $this->charset=$GLOBALS['conf']['mysql']['charset']; $this->connect(); } public function connect(){ $dsn="$this->type:host=$this->server;dbname=$this->dbname;port=$this->port;charset=$this->charset"; $this->_pdo=new \PDO($dsn,$this->username,$this->password); $this->_pdo->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION); } public function select() { $sql='select * from '.$this->className; $res=$this->query($sql); return $res->fetchAll(\PDO::FETCH_ASSOC); } public function query($sql) { try{ $resObj=$this->_pdo->query($sql); }catch (\PDOException $e){ $resObj=$this->errors($e,$sql); } return $resObj; } public function errors($e,$sql) { echo '错误信息为:'.$e->getMessage().'<br/>';// echo '错误代码为:'.$e->errorCode() ().'<br/>'; echo '错误语句为:'.$sql.'<br/>'; return false; } /** * @return mixed * 连贯操作的 get方法 */ public function get() { $sql='select * from '.$this->className.' where'; $sql.=$this->where; $res=$this->query($sql); return $res->fetchAll(\PDO::FETCH_ASSOC); } /** * @param $field 字段名 * @param $operator 符号,> < = >= eq等等。。 * @param $condition 数值或字符串 * 用户连贯操作的where方法 */ public function where($field,$operator,$condition) { //如果strlen==3 就是说 之前无where 条件不然就直接 if (strlen($this->where)==3){ $this->where=' '.$field.' '.$operator.' '.$condition.' '; return $this; } $this->where.=' and '.$field.' '.$operator.' '.$condition.' '; return $this; } }
我们在上面做where做了判断,为什么长度为3因为前后各有一个空格加上数字就是三,如果是第一次where就直接覆盖之前定义的$this->where=’ 1 ‘
如果不是就是拼接上 and 以及条件。我们这章的orm就结束了,如果有什么疑惑可以在评论中留言,详细代码也可以查看我的码云上会有哦
作者:秋名山吴师傅
链接:https://www.jianshu.com/p/398b0feb7883