2

現在の ZF プロジェクトでは、読み取りと書き込みに異なる DB 接続を使用する必要があります。私のアプローチは、Zend_Db_Table_Abstract (および Zend_Db_Table_Row_Abstract) を拡張することでこれを行うことでした。

現時点では次のようになります。

class SomeNamespace_Db_Table extends Zend_Db_Table_Abstract {
/**
 * @var Zend_Db
 */ 
protected $read = NULL;

/**
 * @var Zend_Db
 */ 
protected $write = NULL;

/**
 * Constructor.
 *
 * Supported params for $config are:
 * - db              = user-supplied instance of database connector,
 *                     or key name of registry instance.
 * - name            = table name.
 * - primary         = string or array of primary key(s).
 * - rowClass        = row class name.
 * - rowsetClass     = rowset class name.
 * - referenceMap    = array structure to declare relationship
 *                     to parent tables.
 * - dependentTables = array of child tables.
 * - metadataCache   = cache for information from adapter describeTable().
 *
 * @param  mixed $config Array of user-specified config options, or just the Db Adapter.
 * @return void
 */ 
public function __construct($config=array()){       
    $this->read  = Zend_Registry::get('read');
    $this->write = Zend_Registry::get('write');

    $config['db'] = $this->read;              
    return parent::__construct($config);
}

/**
 * Inserts a new row.
 *
 * @param  array  $data  Column-value pairs.
 * @return mixed         The primary key of the row inserted.
 */    
public function insert(array $data){
    $this->setAdapter($this->write);
    $result = parent::insert($data);
    $this->setAdapter($this->read);

    return $result;
}

/**
 * Updates existing rows.
 *
 * @param  array        $data  Column-value pairs.
 * @param  array|string $where An SQL WHERE clause, or an array of SQL WHERE clauses.
 * @return int          The number of rows updated.
 */    
public function update(array $data, $where){
    $this->setAdapter($this->write);
    $result = parent::update($data,$where);
    $this->setAdapter($this->read);

    return $result;
}

/**
 * Fetches a new blank row (not from the database).
 *
 * @param  array $data OPTIONAL data to populate in the new row.
 * @param  string $defaultSource OPTIONAL flag to force default values into new row
 * @return Zend_Db_Table_Row_Abstract
 */    
public function createRow(array $data = array(), $defaultSource = NULL){
    $this->setAdapter($this->write);
    $result = parent::createRow($data, $defaultSource);
    $this->setAdapter($this->read);

    return $result;
}

/**
 * Deletes existing rows.
 *
 * @param  array|string $where SQL WHERE clause(s).
 * @return int          The number of rows deleted.
 */    
public function delete($where){
    $this->setAdapter($this->write);
    $result = parent::delete($where);
    $this->setAdapter($this->read);    

    return $result;
}

/**
 * Allow to set current used connection
 * from Enalog_Db_Table_Row
 * 
 * @param Zend_Db $db
 */    
public function setAdapter($db){
    $this->_db = self::_setupAdapter($db);
    return $this;
}

}

私の好みでは、これは多くの冗長なコードへの道です。(Zend_Db_Table_Row では、save メソッドと setFromArray メソッドも上書きする必要があります)

これに関する提案はありますか？2 つの DB 接続間の切り替えは、可能な限り透過的である必要があります。

ティア・ルフィヌス

4

3 に答える 3

2

あなたのコードはかなり良さそうです。いずれにせよ、サブクラスは適用可能な各メソッドをインターセプトする必要があり、バグがどのように侵入するかはわかりません。大きな問題は、コードがトリックを実行するかどうかです。

于 2009-12-14T22:25:38.730 に答える
1

これを行う別の方法があり、ここに示されています

于 2009-12-14T22:30:09.037 に答える
0

Zend_Db_Table でさまざまな接続アダプターを使用するのに役立つこの記事http://www.amazium.com/blog/using-different-databases-with-zend-frameworkを見つけました。

于 2011-06-23T16:08:34.640 に答える