php – 如何在phalcon框架中同时连接多个数据库同时在模型类中使

<?php

//This service returns a MySQL database
$di->set('dbMysql',function() {
     return new PhalconDbAdapterPdoMysql(array(
        "host" => "localhost","username" => "root","password" => "secret","dbname" => "invo"
    ));
});

//This service returns a PostgreSQL database
$di->set('dbPostgres',function() {
     return new PhalconDbAdapterPdoPostgreSQL(array(
        "host" => "localhost","username" => "postgres","password" => "","dbname" => "invo"
    ));
});

二

<?php

class Robots extends PhalconMvcModel
{
    public function initialize()
    {
        $this->setConnectionService('dbPostgres');
    }
}

三

<?php

    class Robots extends PhalconMvcModel
    {

        public function initialize()
        {
            $this->setReadConnectionService('dbSlave');
            $this->setWriteConnectionService('dbMaster');
        }

    }

四
????

class Robots extends PhalconMvcModel
{
    /**
     * Dynamically selects a shard
     *
     * @param array $intermediate
     * @param array $bindParams
     * @param array $bindTypes
     */
    public function selectReadConnection($intermediate,$bindParams,$bindTypes)
    {
        //Check if there is a 'where' clause in the select
        if (isset($intermediate['where'])) {

            $conditions = $intermediate['where'];

            //Choose the possible shard according to the conditions
            if ($conditions['left']['name'] == 'id') {
                $id = $conditions['right']['value'];
                if ($id > 0 && $id < 10000) {
                    return $this->getDI()->get('dbShard1');
                }
                if ($id > 10000) {
                    return $this->getDI()->get('dbShard2');
                }
            }
        }

        //Use a default shard
        return $this->getDI()->get('dbShard0');
    }

}

五

<?php

$robot = Robots::findFirst('id = 101');