使 PDO 数据库连接在控制器和模型中可用

Question

现在，我有点沮丧，我希望有人能帮助我并指出正确的方向。

我有一个 "old" 项目，它使用 mysql 语句连接到数据库等。

在这个项目中我有以下内容：

一个索引文件包含

*
* load configuration and connect to database
*/
$projectConfiguration = new projectConfiguration();
$dbconnect = $projectConfiguration->connect($projectConfiguration->databaseHost, $projectConfiguration->databaseName, $projectConfiguration->databaseUser, $projectConfiguration->databasePass);

// load controller
$ReqMod = FatFramework\Functions::getRequestParameter("mod");
if (!$ReqMod) {
$ReqMod = FatFramework\Functions::getRequestParameter("controller");
}
$module = ($ReqMod) ? $ReqMod : 'default';

在这种风格中，我在 classes 中调用视图和操作，例如 SaveAction()

使用 mysql 总是可以非常简单地在控制器调用的模型中使用此数据库连接，例如

public function loadCustomersList($sAdditionalWhere = false)
{
    $sQuery = "SELECT * FROM customers WHERE 1 ";
    if ($sAdditionalWhere) {
        $sQuery .= "AND " . $sAdditionalWhere . " ";
    }
    $sQuery .= "ORDER BY company";
    $sql = mysql_query($sQuery);
    while (($customer = mysql_fetch_object($sql)) != false) {
        $aCustomers[] = $customer;
    }
    return $aCustomers;
}

我想完全折射这个项目并使用 PDO。在过去的 4 个小时里，我一直在努力寻找解决方案，但我不知道如何让它发挥作用。

我认为我不需要额外的 dbconnect class，因为 PDO 本身就是 class，对吗？

在新的索引文件中，我尝试了以下操作：

$db = new database();
try{
    $dbc = new PDO($db->get_DbConSettings());
    $dbc->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
}catch(PDOException $e)
{
    echo 'Verbindung fehlgeschlagen: '.$e->getMessage();
}

但是有了这个 $dbc 将无法在控制器或模型中使用。有办法让它在那里可用吗？如果不是，最好的解决方案是什么？我必须在每个模型中建立数据库连接吗？

我遇到的另一个问题是： $db->get_DbConSettings() 在 $dbc = 新 PDO

回馈

'mysql:host=127.0.0.1; dbname=c1virtbkk', 'root', '123'

($dbc = new PDO('mysql:host=127.0.0.1; dbname=c1virtbkk', 'root', '123');)

我无法连接到数据库。我得到以下信息：

Verbindung fehlgeschlagen: could not find driver

如果我不使用 $db->get_DbConSettings 并手动输入所需的信息，我不会得到任何错误并且可以进行查询。有什么提示吗？

非常感谢您的帮助。

提前致谢！

标记

Answer 1

绝对不要在每个模型中创建新的PDO 连接。创建 MySQL 数据库连接相当快，但这样做仍然存在一些开销。您希望在整个请求中重用一个连接。如果不出意外，它允许您跨多个模型共享一个事务。

一些框架将共享资源对象存储在 "registry" class 中，这是一个单例键值存储。它只不过是一个全局哈希数组，但将其设为 class 可以使注册表本身更容易使用 PHP 单元进行测试。有关注册表示例，请参阅 https://framework.zend.com/manual/1.12/en/zend.registry.using.html。

你说得对，PDO 是 class，尽管它是作为 C 扩展而不是 PHP class 实现的。但它是一个 class，new PDO(...) returns class 的一个对象。

创建您自己的数据库 class 的一个原因是帮助您进行单元测试，因为您可以为您的数据库创建一个模拟对象 class 这样您就可以测试您的其他 classes（甚至模型 classes），不需要实时数据库连接。您的数据库 class 可以扩展或包含 PDO 对象。

您关于错误 "could not find driver" 的问题可能是因为未安装 mysql 的 PDO 驱动程序。 PDO 是一个 PHP 扩展，然后每个品牌的 SQL 数据库都有一个单独的扩展。您可以通过以下方式确认：

$ php -i

...lots of output...

PDO

PDO support => enabled
PDO drivers => mysql, odbc, sqlite

pdo_mysql

PDO Driver for MySQL => enabled
Client API version => mysqlnd 5.0.11-dev - 20120503 - $Id: 76b08b24596e12d4553bd41fc93cccd5bac2fe7a $

...more output for other extensions...

请注意，PDO 会告诉我安装了哪些驱动程序：mysql、odbc 和 sqlite。

所以你需要安装pdo_mysql。我不确定你用的是什么 OS，但我经常用 CentOS Linux 或 Ubuntu Linux。 pdo_mysql 可通过 yum 或 apt 作为单独的软件包使用。

回复您的评论：

好的，这是一个注册表示例：

class registry {
  protected static $items = array();

  public static get($key) {
    return isset(self::$items[$key])?
      self::$items[$key] : null;
  }

  public static set($key, $object) {
    self::$items[$key] = $object;
  }
}

在您的控制器初始代码中，您将创建一个数据库对象并将其存储在注册表中：

$projectConfiguration = new projectConfiguration();
$dbconnect = $projectConfiguration->connect(
  $projectConfiguration->databaseHost, 
  $projectConfiguration->databaseName,
  $projectConfiguration->databaseUser,
  $projectConfiguration->databasePass);

registry::set('db', $dbconnect);

然后在您的模型 class 方法中（或任何您需要数据库的地方），从注册表中获取 db 对象并使用它：

public function loadCustomersList($sAdditionalWhere = false)
{
    $sQuery = "SELECT * FROM customers WHERE 1 ";
    if ($sAdditionalWhere) {
        $sQuery .= "AND " . $sAdditionalWhere . " ";
    }
    $sQuery .= "ORDER BY company";

    $db = registry::get('db');
    $stmt = $db->query($sQuery);
    $aCustomers = $stmt->fetchAll(PDO::FETCH_ASSOC);
    return $aCustomers;
}

使 PDO 数据库连接在控制器和模型中可用

Making PDO Database Connection available in controllers and models

mysql

connection

pdo