Phalcon sharding DB connection selection

<?php
// First of all connections have to be configured in the configuration
// This service returns a MySQL database
$di->set('dbMysql', function () {
return new MysqlPdo(
array(
"host" => "localhost",
"username" => "root",
"password" => "secret",
"dbname" => "invo"
)
);
});
// This service returns a PostgreSQL database
$di->set('dbPostgres', function () {
return new PostgreSQLPdo(
array(
"host" => "localhost",
"username" => "postgres",
"password" => "",
"dbname" => "invo"
)
);
});
?>
<?php
/**
* then on the model level could be used different DB connections
*
*/
class Robots extends Model
{
public function initialize()
{
$this->setConnectionService('dbPostgres');
}
}
// or like this
use Phalcon\Mvc\Model;
class Robots extends Model
{
public function initialize()
{
$this->setReadConnectionService('dbSlave');
$this->setWriteConnectionService('dbMaster');
}
}
<?php
/**
* Another very custom connection selection
* By simply override the getWriteConnection in a model you can dynamically change the connection used to write data
*/
class Robots extends Phalcon\Mvc\Model
{
public static function getWriteConnection()
{
if ($this->shardKey == 'abcd') {
return $this->getDI()->get('dbMysql1');
}
if ($this->shardKey == 'efgh') {
return $this->getDI()->get('dbMysql2');
}
return $this->getDI()->get('dbMysql3');
}
}
?>