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

由于模型中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不支持的，这些接口也搞不定了。