Zend Framework - 数据库表递归级联删除问题

Question

我的情况可能有点异常，但我在 MySQL 数据库中定义了外键，同时在 Zend_Db_Table 类中强制引用完整性。这些表使用 InnoDB 存储引擎。

删除记录时，Zend 框架将通过表模型中的 $_referenceMap 正确识别直接子项并删除它们。但是，如果直接子项有任何子项，我会从数据库收到有关违反该外键的引用完整性的错误：SQLSTATE[23000]：完整性约束违规：1451 无法删除或更新父项行：外键约束失败。看来 Zend_Db_Table_Abstract 并没有以递归方式强制引用完整性。

还有其他人遇到过这种情况吗？这是一个 Zend Framework 错误吗？解决方法？修复？

---

更新

近一周后，我没有回复这个问题。我想我必须自己扩展 Zend_Db_Table_Row_Abstract 类才能完成此任务。

Answer 1

我最终扩展了 Zend_Db_Table_Abstract 类来完成此任务。 _cascadeDelete 公共函数调用数据库适配器delete 函数。我进行了更改，以便调用 Zend_Db_Table_Row_Abstract 中的 delete 函数。这使得记录删除是递归的。

更新：我添加了删除时设置为self::SET_NULL的代码。

这是我修改后的 _cascadeDelete 版本：

/**
 * Called by parent table's class during delete() method.
 *
 * @param  string $parentTableClassname
 * @param  array  $primaryKey
 * @return int    Number of affected rows
 */
public function _cascadeDelete($parentTableClassname, array $primaryKey)
{
    $this->_setupMetadata();
    $rowsAffected = 0;
    foreach ($this->_getReferenceMapNormalized() as $map) {
        if ($map[self::REF_TABLE_CLASS] == $parentTableClassname && isset($map[self::ON_DELETE])) {
            switch ($map[self::ON_DELETE]) {
                case self::CASCADE:
                    $select = $this->select();
                    for ($i = 0; $i < count($map[self::COLUMNS]); ++$i) {
                        $col = $this->_db->foldCase($map[self::COLUMNS][$i]);
                        $refCol = $this->_db->foldCase($map[self::REF_COLUMNS][$i]);
                        $type = $this->_metadata[$col]['DATA_TYPE'];
                        $select->where($this->_db->quoteIdentifier($col, true) . ' = ?',
                            $primaryKey[$refCol], $type);
                    }
                    $rows = $this->fetchAll($select);
                    $rowsAffected += count($rows);
                    foreach ($rows as $row) {
                        $row->delete();
                    }
                    break;
                case self::SET_NULL: {
                    $update = array();
                    $where = array();
                    for ($i = 0; $i < count($map[self::COLUMNS]); ++$i) {
                        $col = $this->_db->foldCase($map[self::COLUMNS][$i]);
                        $refCol = $this->_db->foldCase($map[self::REF_COLUMNS][$i]);
                        $type = $this->_metadata[$col]['DATA_TYPE'];
                        $update[$col] = null;
                        $where[] = $this->_db->quoteInto(
                            $this->_db->quoteIdentifier($col, true) . ' = ?',
                            $primaryKey[$refCol], $type);
                    }
                    $rowsAffected += $this->update($update, $where);
                    break;
                }
                default:
                    // no action
                    break;
            }
        }
    }
    return $rowsAffected;
}