Zend_Db_Table and tables relationships

Geoffrey — Mon, 13 Aug 2007 15:39:00 +0200

When developping a database tied application, you eventually come to a point where you get (at least) two tables with a parent/child relationship, such as for example a User table referenced by, say, a Post table (each post belonging to a specific user). That's basically the point where you need Zend_Db_Table relationships mechanism. the drawback of this mechanism is that, as far as I know, it does not produce joined queries to retrieve the parent data, but fires a query for each parent row. Thus instead of just using Zend_Db Relationships, I developped a simple yet effective auto-join mechanism that I called, in great simplicity, parent mapping. It supports multiple joins from multiple tables, remote fields specification and prefixing.

It is included in my db table class and you can see the interesting part of the code below for your convenience (Ignore the 3 first lines of the function as it is used for something else in my version of the framework).

/**

         * Holds the parent mapping for join in fetchAll

         *

         * <code>

         * array(

         *      'remote_table' => array(

         *           'remote' => 'id'

         *           'local' => 'remote_id',

         *           'fields' => array('foo', 'bar', 'prefix' => 'remote_'),

         *      ),

         * );

         * </code>

         *

         * @var array

         */



        protected $_parentMap = array();



        /**

         * Honors the parent mapping from self::_parentMap

         *

         * @param string|array $where

         * @param string|array $order

         * @param integer $count

         * @param integer $offset

         * @return Zend_Db_Table_Rowset

         */



        public function fetchAll($where = null, $order = null, $count = null, $offset = null) {

                if (!is_array($this->_cols)) {

                        return parent::fetchAll($where, $order, $count, $offset);

                } else {

                        $db = $this->getAdapter();

                        $select = $db->select();

                        $select ->from($this->_name, $this->_cols, $this->_schema)

                                        ->order($order)

                                        ->limit($offset, $count);



                        if (!is_null($where)) {

                                $select->where($where);

                        }



                        if (!empty($this->_parentMap)) {

                                foreach($this->_parentMap as $parentTable => $specs) {

                                        $fields = array();

                                        if (isset($specs['fields']['prefix'])) {

                                                $prefix = $specs['fields']['prefix'];

                                                unset($specs['fields']['prefix']);

                                                foreach($specs['fields'] as $key => $field) {

                                                        if (is_int($key)) {

                                                                $key = $prefix.$field;

                                                        }

                                                        $fields[$key] = $field;

                                                }

                                        } else {

                                                $fields = $specs['fields'];

                                        }

                                        $select->join(

                                                $parentTable,

                                                sprintf('%s.%s = %s.%s',

                                                        $db->quoteIdentifier($this->_name),

                                                        $db->quoteIdentifier($specs['local']),

                                                        $db->quoteIdentifier($parentTable),

                                                        $db->quoteIdentifier($specs['remote'])

                                                ),

                                                $fields

                                        );

                                }

                        }



                        $stmt = $db->query($select);

                        return $this->_makeRowset($stmt);

                }

        }

Mirmo Dynamics - Tag - join

Zend_Db_Table and tables relationships