动态创建的数据源未传递给 CakePHP 中的关联模型

Question

我有一个模型 - 汽车 - 汽车有几个关联的模型，让我们考虑其中一个与 hasMany 关系链接的模型 - 车轮

在我的 CarsController 中，我使用以下代码动态生成数据源 -

$schemaName = $this->Session->read('User.schema'); 
$config = ConnectionManager::getDataSource('default')->config;
$config['database'] = $schemaName;
ConnectionManager::create($schemaName, $config);

然后我使用以下代码行在我的汽车模型中设置此数据源

$this->Car->setDataSource($schemaName);

在此之后我可以查询和操作 Car，但是，如果我尝试使用以下语句在 Wheel 上操作 - 我会收到错误

$this->Car->Wheel->create();
$this->Car->Wheel->save($wheelData);

我得到的错误是 - 错误：[MissingTableException] 模型 Wheel 的表轮在数据源默认值中找不到。

由于某种原因，数据源没有从父模型传递到关联的子模型。如果我使用以下行在 Wheel 中明确设置数据源，那么一切正常。

$this->Car->Wheel->setDataSource($schemaName);

谁能帮助阐明这种行为以及如何解决这个问题？我觉得这不方便的原因是我的父模型有几个关联模型（它们还有关联模型）并且在每个模型上单独设置数据源听起来不正确。

附带问题 - 有没有办法在尝试动态创建数据源之前检查数据源是否已经存在？我有一个包装整个代码的 for 循环，每次循环迭代最终都会创建一个新的数据源

我使用的是 CakePHP 2.5.4

Answer 1

这里有一些代码会将 setDatasource() 调用传递给关联的模型，如果您只想让 Car 模型通过其数据源，则将此代码放入 Car 模型中，如果您希望所有模型都通过，则将其放入在AppModel.php

public function setDatasource($datasource = null) {
    foreach (array_keys($this->getAssociated()) as $modelName) {
        $this->{$modelName}->setDatasource($datasource);
    }
    parent::setDatasource($datasource);
}

为了回答您的评论，我将在AppModel.php 中添加public $dynamicDb = false，这意味着此变量的默认值为false，然后在您的模型中通过添加public $dynamicDb = true 覆盖它，然后将上述函数更改为：

public function setDatasource($datasource = null) {
    foreach (array_keys($this->getAssociated()) as $modelName) {
        if ($this->{$modelName}->dynamicDb === true) {
            $this->{$modelName}->setDatasource($datasource);
        }
    }
    parent::setDatasource($datasource);
}

（我没有测试这个修改后的功能，因为我现在不在我的开发 PC 上，但它是一个相当简单的更改，它应该可以工作）

要在创建数据源之前检查数据源是否已经存在，我可以看到两种可能的方法，一种是调用ConnectionManager::getDatasource($schemaName) 并在数据源不存在时捕获异常，或者调用ConnectionManager::sourceList() 并检查您的@ 987654329@ 在返回的数组中，这是第一个选项的实现：

$schemaName = $this->Session->read('User.schema'); 
try {
    ConnectionManager::getDatasource($schemaName)
} catch (MissingDatasourceException $e) {
    $config = ConnectionManager::getDataSource('default')->config;
    $config['database'] = $schemaName;
    ConnectionManager::create($schemaName, $config);
}

第二个选项：

$datasources = ConnectionManager::sourceList();
$schemaName = $this->Session->read('User.schema'); 
if (!in_array($schemaName, $datasources)) {
    $config = ConnectionManager::getDataSource('default')->config;
    $config['database'] = $schemaName;
    ConnectionManager::create($schemaName, $config);
}

希望对你有帮助