【工厂模式】设计模式之工厂模式【原创】

摘要：主要是参考列旭松、陈文著的《PHP核心技术与最佳实践》的2.1节。

1.1 简介

工厂模式是我们最常用的实例化对象模式了，是用工厂方法代替new操作的一种模式。工厂模式（Factory）允许你在代码执行时实例化对象。之所以被称为工厂模式是因为它只负责‘生产’对象。以数据库为例，工厂需要的是根据不同的参数，生产不同的实例化对象。最简单的工厂模式就是根据传入的类型名实例化对象，比如传入Mysql，就调用Mysql的类并实例化，比如传入SQLite，则调用SQLite的类并实例化，甚至可以处理TXT、EXCEL等‘类数据库’。工厂类就是这样的类，只负责生产对象，而不负责对象的具体内容。

工厂方法让具体的对象解脱了出来，使其并不再依赖具体的类，而是抽象。

1.2 优点

工厂模式的优点在于创建对象上。建立一个工厂（一个函数或一个类方法）来制造新的对象,它的任务就是把对象的创建过程都封装起来，创建对象不是使用new的形式了。而是定义一个方法，用于创建对象实例。

通俗的说，以前创建一个对象要使用new，现在把这个过程封装起来了。

假设不使用工厂模式：那么很多地方调用类a，代码就会这样子创建一个实例：new a(),假设某天需要把a类的名称修改，意味着很多调用的代码都要修改。

1.3 简单的工厂模式例子

代码是参考百度百科的：

https://baike.baidu.com/item/%E5%B7%A5%E5%8E%82%E6%A8%A1%E5%BC%8F/9852061?fr=aladdin

<?php
    interface abstracted
    {
        public function realCreate();
    }
    //女人类
    class Woman
    {
        public function action()
        {
            echo '这是女人';
        }
    }
    //男人类
    class Man
    {
        public function action()
        {
            echo '这是男人';
        }
    }
    //创建女人
    class WomanCreator implements abstracted 
    {
        public $chromosome;//染色体
        public function realCreate(){
            if ($this->chromosome == "xx") {
                return new Woman();
            }
        }
    }
    //创建男人
    class ManCreator implements abstracted 
    {
        public $chromosome;
        public function realCreate()
        {
            if ($this->chromosome == "xy" || $this->chromosome == "xyy") {
                return new Man();
            }
        }
    }
    //人类工厂
    class PersonFactory
    {
        public function create($what){
            $create = $what."Creator";
            return $create = new $create();
        }
    }
    $create = new PersonFactory();
    $instance = $create->create('Woman');
    $instance->chromosome = "xx";
    $instance->realCreate()->action();

1.4 数据库适配器

使用工厂模式定义数据库适配器，根据不同的数据库参数实例化不同的数据库类。

定义一个数据库适配器接口，规定一些通用的方法：

2_DriversDb_Adapter.php：

<?php
/**
 * Db的适配器
 */

interface Db_Adapter
{
    /**
     * 数据库连接
     * @param array $config 数据库配置
     * @return resource
     */
    public function connect($config);

    /**
     * 执行数据库查询
     * @param string $query 数据库查询SQL字符串
     * @return resource
     */
    public function query($query);
}

定义一个Mysql数据库的操作类（简化版），实现了数据库适配器接口：

2_DriversDb_Adapter_Mysqli.php：

<?php
/**
 * 定义MySql数据库的操作类
 */
require_once 'Db_Adapter.php';
class Db_Adapter_Mysqli implements Db_Adapter
{
    // 数据库连接字符串标示
    private $_dbLink;
    /**
     * 数据库连接函数
     * @param array $config 数据库配置
     * @return mysqli
     */
    public function connect($config)
    {
        $this->_dbLink = @mysqli_connect($config['host'] . (empty($config['port']) ? '' : ':' . $config['port']), $config['user'], $config['password']);
        if ($this->_dbLink) {
            if (@mysqli_select_db($this->_dbLink, $config['database'])) {
                if (isset($config['charset'])) {
                    mysqli_query($this->_dbLink, "SET NAMES '{$config['charset']}'");
                }
                return $this->_dbLink;
            }
        }
        // 数据库异常
        throw new mysqli_sql_exception(@mysqli_error($this->_dbLink));
    }
    /**
     * 执行数据库查询
     * @param string $query 数据库查询SQL字符串
     * @return bool|mysqli_result
     */
    public function query($query)
    {
        $handle = $this->_dbLink;
        $resource = @mysqli_query($handle, $query);
        if ($resource) {
            return $resource;
        } else {
            return false;
        }
    }
}

接下来是SQLite数据库的操作类（简化版），同样实现了数据库适配器接口：

2_DriversDb_Adapter_Sqlite.php：

<?php
/**
 * 定义SQLite数据库的操作类
 */

require_once 'Db_Adapter.php';

class Db_Adapter_Sqlite implements Db_Adapter
{
    // 数据库连接字符串标示
    private $_dbLink;

    /**
     * 数据库连接函数
     * @param array $config 数据库配置
     * @return resource
     * @throws Exception
     */
    public function connect($config)
    {
        $this->_dbLink = sqlite_open($config['file'], 0666, $error);
        if ($this->_dbLink){
            return $this->_dbLink;
        }

        // 数据库异常
        throw new Exception($error);
    }

    /**
     * 执行数据库查询
     * @param string $query 数据库查询SQL字符串
     * @return bool|resource
     */
    public function query($query)
    {
        $handle = $this->_dbLink;
        $resource = @sqlite_query($query, $handle);
        if ($resource) {
            return $resource;
        } else {
            return false;
        }
    }
}

定义一个工厂类，根据不同的参数生成不同的数据库类，并实现简单的查询：

2_4_sql_factory.php：

<?php
/**
 * 定义一个工厂类，可以根据参数的不同生成不同的数据库类
 */
class SqlFactory
{
    public static function factory($type)
    {
        if (include_once '2_Drivers/Db_Adapter_' . $type. '.php') {
            $classname = 'Db_Adapter_' . $type;
            return new $classname;
        } else {
            throw new Exception('Driver not found');
        }
    }
}
$db = SqlFactory::factory('Mysqli');
$config = [
    'host' => 'localhost',
    'user' => 'root',
    'password' => '123456',
    'database' => 'test_laravel',
];
$db->connect($config);
$res = $db->query('SELECT * FROM articles');
while ($row = mysqli_fetch_row($res)) {
    var_dump($row);
}

注意：要调用时，可以这样写：

$db = sqlFactory:factory('Mysqli');
$db = sqlFactory:factory('Sqlite');