如何同时使用 \Zend\Cache 和 Zend\Db\RowGateway\RowGateway?

Question

我有一个抽象的表类，其代码类似于以下内容：

function fetchById($id) {
    $id = (int) $id;
    $cacheName = sprintf('%s-%s', stripslashes(get_class($this)), hash('sha256', sprintf(
                    '%s-%s-%s', get_class($this), __FUNCTION__, $id
    )));
    if (($row = $this->cache->getItem($cacheName)) == FALSE) {
        $rowset = $this->tableGateway->select(array('id' => $id));
        $row = $rowset->current();
        if (!$row) {
            throw new Exception("Could not find row $id");
        }
        $this->cache->setItem($cacheName, $row);
    }
    return $row;
}

这对于返回$row的默认ArrayObject来说已经足够了，但是我现在想在我的行对象中包含其他功能(以便该功能不包含在多个不相关的位置，例如不同的控制器等(。

为此，我创建了一个扩展ZendDbRowGatewayRowGateway ArrayObjectPrototype，但是当我尝试缓存该行时，我收到以下错误消息：You cannot serialize or unserialize PDO instances

哦，亲爱的。

我将 __wake 和 __sleep 函数添加到我的行对象没有问题，但是如何将 PDO 对象放入我的 __wake 函数中？

我正在application.config.php文件中创建缓存：

        'ZendCacheStorageFactory' => function() {
            return ZendCacheStorageFactory::factory(
                array(
                    'adapter' => array(
                        'name' => 'filesystem',
                        'options' => array(
                            'dirLevel' => 2,
                            'cacheDir' => 'data/cache',
                            'dirPermission' => 0755,
                            'filePermission' => 0666,
                        ),
                    ),
                    'plugins' => array('serializer'),
                )
            );
        },

我假设我必须创建一个将数据库适配器传递到的自定义插件？但我完全不知道该怎么做。

Answer 1

我所做的(也许是错误的(是创建一个不保存 pdo 实例的抽象行类。此类扩展了RowGateway类，但覆盖了__construct、initialize、save和delete函数(所有需要 pdo 的函数(

/**
 * Abstract table row class.
 * 
 * @package    RPK
 * @subpackage Db
 * @author     SuttonSilver
 */
namespace RPKDb;
use ZendDbAdapterAdapter;
use ZendDbRowGatewayExceptionRuntimeException;
use ZendDbRowGatewayRowGateway;
use ZendDbSqlSql;
use ZendDbSqlTableIdentifier;
use ZendDbRowGatewayFeatureFeatureSet;
abstract class RowAbstract extends RowGateway {
    /**
     * Constructor
     *
     * @param string $primaryKeyColumn
     * @param string|TableIdentifier $table
     * @param Adapter|Sql $adapterOrSql
     * @throws ExceptionInvalidArgumentException
     */
    public function __construct($primaryKeyColumn, $table, $adapterOrSql = null) {
        // setup primary key
        $this->primaryKeyColumn = empty($primaryKeyColumn) ? null : (array) $primaryKeyColumn;
        // set table
        $this->table = $table;
        $this->initialize();
    }
    /**
     * initialize()
     */
    public function initialize() {
        if ($this->isInitialized) {
            return;
        }
        if (!$this->featureSet instanceof FeatureSet) {
            $this->featureSet = new FeatureSet;
        }
        $this->featureSet->setRowGateway($this);
        $this->featureSet->apply('preInitialize', []);
        if (!is_string($this->table) && !$this->table instanceof TableIdentifier) {
            throw new RuntimeException('This row object does not have a valid table set.');
        }
        if ($this->primaryKeyColumn === null) {
            throw new RuntimeException('This row object does not have a primary key column set.');
        } elseif (is_string($this->primaryKeyColumn)) {
            $this->primaryKeyColumn = (array) $this->primaryKeyColumn;
        }
        $this->featureSet->apply('postInitialize', []);
        $this->isInitialized = true;
    }
    /**
     * Save any changes to this row to the table
     * @throws Exception
     */
    public function save() {
        throw new Exception('No PDO object available.');
    }
    /**
     * Delete this row from the table
     * @throws Exception
     */
    public function delete() {
        throw new Exception('No PDO object available.');
    }
}