>  기사  >  php教程  >  一步步编写PHP的Framework(十七)

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

WBOY
WBOY원래의
2016-06-21 08:50:431074검색

 

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

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

01

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

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

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

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

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

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不支持的,这些接口也搞不定了。



성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.