2012-04-16 110 views
0

我想在zend框架中执行下面的查询。谁能告诉我我该怎么做?在zend框架中执行查询

(SELECT `msg`.`message_sender_id`, `msg`.`message_receiver_id`, `msg`.`message_content`, `msg`.`message_sent_on`, `usr`.`user_name` AS `sender_name` 
FROM `sc_message` AS `msg` INNER JOIN `sc_user` AS `usr` ON `msg`.`message_sender_id` = `usr`.`user_id` 
WHERE `msg`.`message_id` = 3 ORDER BY `msg`.`message_sent_on`) 

UNION 

(SELECT `msg_slv`.`message_slave_sender_id`, `msg_slv`.`message_slave_receiver_id`, `msg_slv`.`message_slave_content`, `msg_slv`.`message_slave_sent_on`, `usr`.`user_name` AS `sender_name` 
FROM `sc_message_slave` AS `msg_slv` INNER JOIN `sc_user` AS `usr` ON `msg_slv`.`message_slave_sender_id` = `usr`.`user_id` 
WHERE `msg_slv`.`message_id` = 3 ORDER BY `msg_slv`.`message_slave_sent_on`) 

我已经写了下面的代码

$Query_1 = $this ->select() 
        ->from(array('msg' => 'sc_message'), array('msg.message_sender_id', 'msg.message_receiver_id', 'msg.message_content', 'msg.message_sent_on')) 
        ->joinInner(array('usr' => 'sc_user'), 'msg.message_sender_id = usr.user_id', array('usr.user_name as sender_name')) 
        ->where('msg.message_id = ?',$message_id) 
        ->setIntegrityCheck(false); 

    $this->_name = "sc_message_slave"; 
    $this->_primary = "message_slave_id"; 
    $Query_2 = $this ->select() 
        ->from(array('msg_slv' => 'sc_message_slave'), array('msg_slv.message_slave_sender_id', 'msg_slv.message_slave_receiver_id','msg_slv.message_slave_content', 'msg_slv.message_slave_sent_on')) 
        ->joinInner(array('usr' => 'sc_user'), 'msg_slv.message_slave_sender_id = usr.user_id', array('usr.user_name as sender_name')) 
        ->where('msg_slv.message_id = ?',$message_id) 
        ->setIntegrityCheck(false); 
+0

工作可能是重复的: http://stackoverflow.com/questions/ 6161370/raw-sql-query-with-zend-framework – Gavriel 2012-04-16 09:19:10

+0

@Garviel:不,它不是..我知道如何在zend中执行简单的查询。唯一的问题是UNION关键字。即使我执行简单的UNION查询,它也不会被执行。 – 2012-04-16 10:30:57

+0

@Pushpendra:是的,我正在研究它.. – 2012-04-16 10:32:03

回答

0

假设你一些方法的Zend_Db_Table

//your code... 

$unionSelect = $this->getAdapter()->select()->union(array($Query_1, $Query_2)); 
//no you can execute it 
$rows = $this->getAdapter()->fetchAll($unionSelect);