理解 lastInsertId() 的工作原理
pdo::lastinsertid() 方法用于返回最后插入的行的id，前提是该表的主键是自增类型（如 auto_increment）。它的关键之处在于，它只能在生成该id的同一个数据库会话中正确获取到。这意味着，如果您在一个数据库会话中执行了 insert 操作，然后在另一个新的数据库会话中尝试调用 lastinsertid()，它将无法获取到之前会话生成的id，通常会返回 0。
问题根源：重复创建 PDO 连接
在许多不当的实现中，开发者可能会在每次需要执行数据库操作时，都调用一个方法来创建一个全新的数据库连接。以下是导致 lastInsertId() 返回 0 的典型代码结构：
class Db {
private $host = "localhost";
private $user = "root";
private $pwd = "";
private $dbName = "cms";
public function connect() {
// 每次调用都会创建一个新的 PDO 实例
$dsn = 'mysql:host=' . $this->host . ';dbname=' . $this->dbName;
$pdo = new PDO($dsn, $this->user, $this->pwd);
$pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
return $pdo;
}
}
class Jobs extends Db {
public function addJob($job_date_time, $job_type, $job_decs) {
$sql = "INSERT INTO jobs(job_date_time, job_type, job_decs) VALUES (?, ?, ?)";
// 第一次调用 connect()，创建连接 A
$stmt = $this->connect()->prepare($sql);
$stmt->execute([$job_date_time, $job_type, $job_decs]);
// 第二次调用 connect()，创建连接 B (与连接 A 是不同的会话)
$lastId = $this->connect()->lastInsertId();
echo $lastId; // 此时 lastId 将返回 0
}
}在上述代码中，Jobs 类的 addJob 方法内部，$this->connect()->prepare($sql) 会创建一个 PDO 实例（假设为连接 A），并执行 INSERT 操作。紧接着，$this->connect()->lastInsertId() 又会再次调用 connect() 方法，从而创建了一个全新的 PDO 实例（假设为连接 B）。由于 lastInsertId() 是在连接 B 上被调用的，而 INSERT 操作是在连接 A 上执行的，连接 B 对连接 A 中发生的插入操作一无所知，因此 lastInsertId() 返回 0。
解决方案：实现 PDO 连接的单例模式
为了解决这个问题，我们需要确保在整个请求生命周期内，Db 类只创建并复用一个 PDO 数据库连接实例。这可以通过在 Db 类中存储已创建的 PDO 实例，并在后续调用时返回该实例来实现，这是一种简单的单例模式实现方式。
以下是优化后的 Db 类示例：
立即学习“PHP免费学习笔记（深入）”；
<?php
class Db {
private $host = "localhost";
private $user = "root";
private $pwd = "";
private $dbName = "cms";
private $pdo; // 用于存储 PDO 实例的属性
public function connect() {
// 检查 $this->pdo 是否已经存在连接实例
if (!$this->pdo) {
// 如果不存在，则创建新的 PDO 连接
$dsn = 'mysql:host=' . $this->host . ';dbname=' . $this->dbName;
try {
$this->pdo = new PDO($dsn, $this->user, $this->pwd);
$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_ASSOC);
$this->pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); // 设置错误模式为抛出异常
} catch (PDOException $e) {
// 捕获连接错误，可以记录日志或抛出自定义异常
die("数据库连接失败: " . $e->getMessage());
}
}
// 返回已存在的或新创建的 PDO 实例
return $this->pdo;
}
}
class Jobs extends Db {
public function addJob($job_date_time, $job_type, $job_decs) {
$pdoInstance = $this->connect(); // 获取共享的 PDO 实例
$sql = "INSERT INTO jobs(job_date_time, job_type, job_decs) VALUES (?, ?, ?)";
$stmt = $pdoInstance->prepare($sql);
$stmt->execute([$job_date_time, $job_type, $job_decs]);
// 在同一个 PDO 实例上调用 lastInsertId()
$lastId = $pdoInstance->lastInsertId();
echo $lastId;
}
}
// 示例用法
$jobs = new Jobs();
$job_date_time = "2021-11-11T11:40";
$job_type = "Test Type";
$job_desc = "Test Desc";
$jobs->addJob($job_date_time, $job_type, $job_desc);
?>代码解析
- private $pdo;: 在 Db 类中新增一个私有属性 $pdo，用于存储创建的 PDO 实例。
- if (!$this->pdo): 在 connect() 方法内部，首先检查 $this->pdo 是否为空（即是否尚未创建 PDO 实例）。
- 创建并存储实例: 如果 $this->pdo 为空，则创建新的 PDO 实例，并将其赋值给 $this->pdo 属性。这样，该实例就会在 Db 对象的整个生命周期内被保留。
- 复用实例: 如果 $this->pdo 已经存在，则直接返回该已存在的实例，而不会再次创建新的连接。
- 错误处理: 添加了 try-catch 块来捕获 PDOException，以便在数据库连接失败时能进行适当的错误处理，而不是直接导致脚本崩溃。同时，设置 PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION 可以让 PDO 在执行语句失败时抛出异常，便于调试和错误处理。
- Jobs 类的修改: 在 Jobs 类的 addJob 方法中，现在只需要调用一次 $this->connect() 并将返回的 PDO 实例存储在一个局部变量（例如 $pdoInstance）中。后续的 prepare()、execute() 和 lastInsertId() 都将在这个共享的 $pdoInstance 上执行，确保它们都在同一个数据库会话中。
注意事项与最佳实践
- 错误模式: 务必设置 PDO::ATTR_ERRMODE 为 PDO::ERRMODE_EXCEPTION。这能让 PDO 在执行数据库操作失败时抛出异常，而不是返回 false 或 null，从而使错误处理更加健壮和直观。
- 连接作用域: 这种单例模式的实现方式使得数据库连接在 Db 类的实例生命周期内保持活跃。对于 Web 应用，这意味着连接在单个 HTTP 请求的处理过程中是持久的。
- 资源管理: 尽管 PDO 会在脚本执行结束时自动关闭连接，但在高并发场景下，频繁创建和关闭连接仍可能带来性能开销。复用连接是提升效率的有效手段。
- 事务管理: 当涉及到数据库事务时，确保所有事务相关的操作（beginTransaction(), commit(), rollBack()）都在同一个 PDO 实例上执行，这是至关重要的。
总结
lastInsertId() 返回 0 的问题，通常是由于对数据库连接生命周期管理不当所致。通过在数据库连接类中实现简单的单例模式，确保在应用程序的整个请求生命周期内复用同一个 PDO 实例，可以有效解决此问题，并提升数据库操作的效率和稳定性。正确管理数据库连接是编写健壮和高性能 PHP 应用程序的关键一环。
