动态数据源和CakePHP 3中的全局？

Question

我有一个将被许多数据库使用的应用程序。要选择具有应用程序数据的数据库，我有一个包含连接参数（主机，用户名，密码，数据库等）的数据库。

问题是，此动态创建的数据源不适用于其他应用程序。

控制器代码

$data  = $this->request->data; 
$connection = ConnectionManager::get("default"); 
$query  = "SELECT * FROM clients WHERE client_id = ".$data['codigo']; 
$result  = $connection->execute($query)->fetchAll('assoc'); 

ConnectionManager::drop('default');    

$config = ConnectionManager::config('connection', [ 
     'className' => 'Cake\Database\Connection', 
     'driver' => 'Cake\Database\Driver\Mysql', 
     'persistent' => false, 
     'host' => $result[0]['host'], 
     'username' => $result[0]['username'], 
     'password' => $result[0]['password'], 
     'database' => $result[0]['database'], 
     'encoding' => 'utf8', 
     'timezone' => 'UTC', 
     'flags' => [], 
     'cacheMetadata' => true, 
     'log' => false, 
     'quoteIdentifiers' => false, 
     'url' => env('DATABASE_URL', null), 
    ]); 

$connection = ConnectionManager::get('connection'); 
ConnectionManager::alias('connection', 'default'); 

return $this->redirect(['controller' => 'Mains', 'action' => 'index']); 

此重定向后，显然其他控制器没有这个数据源。

Answer 1

根据请求数据中的内容交换数据库肯定有点不寻常 - 但通常数据库连接只需要在Cake的初始设置中完成，因为每个Controller的连接资源已经设置为default。

如果你只是交换一次，你可以在（其中Cake通常设置它的ConnectionManager）中进行管理。

您将无法访问$this->request，但可能只是从$ _REQUEST抓住它代替，例如：

在，改变这些行：

Cache::config(Configure::consume('Cache')); 
ConnectionManager::config(Configure::consume('Datasources')); 
Email::configTransport(Configure::consume('EmailTransport')); 

要这样：

Cache::config(Configure::consume('Cache')); 

ConnectionManager::config(Configure::consume('Datasources')); 
$connection = ConnectionManager::get("default"); 
$client = TableRegistry::get('Clients')->find() 
    ->where(['client_id'=> $_REQUEST['client_id']])->firstOrFail(); 

ConnectionManager::drop('default'); 

$config = ConnectionManager::config('connection', [ 
    'className' => 'Cake\Database\Connection', 
    'driver' => 'Cake\Database\Driver\Mysql', 
    'persistent' => false, 
    'host' => $client->host, 
    'username' => $client->username, 
    'password' => $client->password, 
    'database' => $client->database, 
    'encoding' => 'utf8', 
    'timezone' => 'UTC', 
    'flags' => [], 
    'cacheMetadata' => true, 
    'log' => false, 
    'quoteIdentifiers' => false, 
    'url' => env('DATABASE_URL', null), 
]); 

ConnectionManager::get('connection'); 

Email::configTransport(Configure::consume('EmailTransport')); 

被修改：从原始SQL切换到Table :: find（）