• 欢迎访问搞代码网站，推荐使用最新版火狐浏览器和Chrome浏览器访问本网站！
  • 如果您觉得本站非常有看点，那么赶紧使用Ctrl+D 收藏搞代码吧
> 后端 > php > 一步步编写PHP的Framework(十七)_php

一步步编写PHP的Framework(十七)_php

php 搞代码 7年前 (2018-06-21) 179次浏览 已收录 0个评论

 

 由于模型中D这一部分是比较基础的，所以我们先把D这一部分做了。

D中最重要的是驱动类的编写，所以我们就先写驱动类，由于在驱动类中需要用到日志，所以我们先做一个简单的Logger类，这个类只有一个log的静态方法，如果debug开启，那么直接在浏览器上面输出信息，否则记录到日志中。

01 <?php
02 class Logger extends Base {
03     public static function log($param) {
04         if(is_object($param)) {
05             if(true === C('debug')) {
06                 throw $param;
07             } else {
08                 file_put_contents(APP_PATH . '/log',$param,FILE_APPEND);
09             }
10         } elseif(is_string($param)) {
11             if(true === C('debug')) {
12                 echo $param;
13             } else {
14                 file_put_contents(APP_PATH . '/log',$param,FILE_APPEND);
15             }
16         } else {}
17     }
18 }

 

现在假设通过Logger::log传递的参数是对象，则代表是抛出了异常，如果是字符串，那么则可能是程序需要输出的警告或者Error信息，如果是其他类型，则不处理。

出于简化代码的目的，所以整个类代码非常少，只是判定了一下是否debug开启了，如果开启，则记录到日志，否则，直接打印出来。

如果你们对这个有兴趣，可以自己尝试做一个功能强大的日志系统，我这儿就不说了啊。。。

日志类写完之后，马上就开始编写驱动类吧，在写驱动类之前，我们还是按照上一次讲的将契约编写了，契约代码如下：

01 <?php
02 interface IDbDriver {
03     function execute($sql);
04     function connect();
05     function close();
06     function getAllByObject();
07     function getAllByAssoArray();
08     function getAllByArray();
09     function beginTrans();
10     function commit();
11     function rollback();
12 }

 

因为马上我将用PDO来做驱动类，为了让大家能够习惯PDO这种预处理，还有就是简化这个接口，因为我写这个的时间有限，所以将这个契约修改成为如下：

01 <?php
02 interface IDbDriver {
03     function prepare($sql);
04     function execute(Array $arr);
05     function connect();
06     function close();
07     function getAllByAssocArray();
08     function beginTrans();
09     function commit();
10     function rollback();
11 }

如果你学过java的JDBC，你会对PDO这种方式非常习惯，当然，如果你习惯使用mysql_*这种接口，那么你可能需要转变观点了，当然，你如果还是要用msyql_*这种来做驱动类，那么不好意思，你要自己做prepare了，因为mysql_*没有提供这种机制。

 

            然后我们就是编写PDO的驱动类，代码如下：

 

01 <?php
02 class PdoDriver extends Base implements IDbDriver {
03     private $_db = null;
04     private $_pstmt = null;
05     public function __construct() {
06         $this->connect();
07     }
08     public function connect() {
09         try {
10             $this->_db = newPDO(C('db=>dsn'),C('db=>user'),C('db=>pwd'),array(PDO::MYSQL_ATTR_INIT_COMMAND=>'SET NAMES "UTF8";'));
11             if(null !== $this->_db) {
12                 Logger::log('[Notice]connect success!');
13             } else {
14                 Logger::log('[Error]:connect failed');
15             }
16         } catch(PDOException $e) {
17             Logger::log( $e);
18         }
19     }
20     public function close() {
21         if(null !== $this->_db) {
22             unset($this->_db);
23         }
24     }
25     public function prepare($sql) {
26         if(null !== $this->_pstmt) {
27             $this->_pstmt = null;
28         }
29         $this->_pstmt = $this->_db->prepare($sql);
30     }
31     public function execute(Array $arr) {
32         if(null === $this->_pstmt) {
33             Logger::log('[Error]not prepared statement');
34         } else {
35             if(false === $this->_pstmt->execute($arr)) {
36                 Logger::log('[Error]sql error,error info is : ' . $this->_ptstmt->errorInfo());
37             } else {
38                 Logger::log('[Notice]:execute success');
39             }
40         }
41     }
42     public function getAllByAssocArray() {
43         return $this->_pstmt->fetchAll(PDO::FETCH_ASSOC);
44     }
45     public function beginTrans() {
46         $this->_db->beginTransaction();
47     }
48     public function commit() {
49         $this->_db->commit();
50     }
51     public function rollback() {
52         $this->_db->rollback();
53     }
54 }

首先，当实例化这个类的时候，它就自动连接DB，也就是调用connect方法。

PDO连接DB是使用了DSN这种方式，当然，如果你还是习惯普通的使用数组搞定，那么你可能需要编写一些额外的代码，我这儿就不说了啊，我就直接使用DSN这种方式来做了。

大家看到的

1 C('db=>dsn'),C('db=>user'),C('db=>pwd')

 

这个我之前讲过，实际上读取的是配置文件中的内容，配置文件的内容如下：

01 <?php
02 return array(
03     'defaultController' => 'Index',
04     'defaultAction' => 'index',
05     'debug' => true,
06     'errorReporting' => -1,
07     'timeZone' => 'PRC',
08     'db' => array(
09         'dsn' => 'mysql:dbname=test;host=localhost',
10         'user' => 'test',
11         'pwd' => 'test',
12  
13     )
14 );

C函数负责将这个文件的配置项读取出来，非常方便，熟悉Thinkphp的童鞋可能对这个也很熟悉 ！！

PDO::MYSQL_ATTR_INIT_COMMAND=>'SET NAMES "UTF8";'这一句是有问题的，这句话是解决的mysql的中文乱码问题，由于PDO实际上提供的是统一的接口，本来我是需要判定数据库是那种类型，如果是mysql然后才使用这句话，但是为了简便，我就直接这么搞了，你们只要清楚这样是不行的就OK！！！

实际上刚才这句话还有一个问题，这里我完全将编码方式写死了，必须是utf-8,但是实际上如果我们写在配置文件中更好！！

由于下面这几个函数都是调用了PDO自己的接口，所以我就不怎么具体讲了，具体的内容可参照PHP手册的PDO这一部分。

刚才这个PDO的驱动类只能完成mysql的操作，如果换成其他数据库，可能存在一定问题，就比如PDO::MYSQL_ATTR_INIT_COMMAND=>'SET NAMES "UTF8";'，实际上我们也可以不修改这段代码，而针对其他数据库做一个适配器，具体的你可以网上百度一下。

写完驱动类之后，我们需要测试一下，我们在控制器中来测一下：

01 <?php
02 class TestController extends Controller {
03     public function test() {
04         $test = new PdoDriver();
05         $test->prepare('select * from test where id > :id');
06         $test->execute(array(
07             'id' => '2'
08         ));
09         var_dump($test->getAllByAssocArray());
10     }
11 }

注意：在模型这一块儿写完之后，就不能直接这么调用了，因为外部控制器直接能访问的部分是E，E调用C和F的内容，C又调用D的内容。

刚才我们说了怎么用PDO来实现驱动类，如果针对mysql，也可以使用mysql_*或者mysqli，我这儿稍微说一下mysql_*,实际上对于mysql_*,实现上面的接口也没有什么难度，也就是调用mysql_*这种接口而已，在prepare这一块儿可能需要你们自己好好想想该怎么做，其实最简单的方式就可以在执行execute的时候使用：

str_replace(array_keys($arr),array_values($arr),$sql);

$sql是调用prepare传递进去的字符串，$arr是execute传递的数组，但是注意，这里的数组的key需要处理一下，因为prepare时SQL参数占位符是如:id这种形式，而execute传递进来的直接入'id' => 2这种形式，所以首先需要将数组每个key添加字符:，然后给每个value进行字符串转义，然后再执行str_replace。

当然，我这种方式是最弱的方式，你可以自己用其他方式实现。

还有一个可能大家不太会的，就是mysql_*怎么处理Mysql事务呢，实际上非常简单，如果大家用过mysql的终端，就会熟悉mysql中有这样几条命令：begin,commit,rollback,所以，我们可以使用mysql_query来执行一条命令，如mysql_query('begin',$this->_db)，这样就开启了一个事务，实际上这些接口都是按照mysql的功能来做的，所以，mysql支持的这些接口才支持，mysql不支持的，这些接口也搞不定了。

欢迎大家阅读《一步步编写PHP的Framework(十七)_php》,跪求各位点评,若觉得好的话请收藏本文，by 搞代码

搞代码网（gaodaima.com）提供的所有资源部分来自互联网，如果有侵犯您的版权或其他权益，请说明详细缘由并提供版权或权益证明然后发送到邮箱[email protected]‍，我们会在看到邮件的第一时间内为您处理，或直接联系QQ：872152909。本网站采用BY-NC-SA协议进行授权
转载请注明原文链接：一步步编写PHP的Framework(十七)_php

喜欢 (0)赏
[搞代码]
分享 (0)
发表我的评论
取消评论

表情 贴图 加粗 删除线 居中 斜体 签到

Hi，您需要填写昵称和邮箱！

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址