【发布时间】:2012-04-26 17:02:12
【问题描述】:
我有一个注册页面,基本上我需要将数据插入 4 个表中。我是 PDO 的新手,对某些事情感到困惑。
基本上,如果任何插入失败,我不希望将任何内容添加到数据库中,这似乎很简单。
我的困惑是,我需要先在我的users 表中插入用户的用户名、电子邮件、密码等,这样我才能使用 PDO 获取(不知道如何)MySQL 给我的用户的 uid(由 mysql 自动递增) .我需要用户 uid MySQL 为其他表提供了我的用户,因为其他表需要 uid,因此所有内容都正确链接在一起。我的表是 InnoDB,我有从 users_profiles(user_uid)、users_status(user_uid)、users_roles(user_uid) 到 users.user_uid 的外键,所以它们都链接在一起。
但同时我想确保如果例如在users 表中插入数据之后(这样我就可以获得 MySQL 给用户的 uid),如果任何其他插入失败,它会删除数据插入到users 表中。
我认为最好展示我的代码;我把代码注释掉了,在代码中做了解释,可能会更容易理解。
// Begin our transaction, we need to insert data into 4 tables:
// users, users_status, users_roles, users_profiles
// connect to database
$dbh = sql_con();
// begin transaction
$dbh->beginTransaction();
try {
// this query inserts data into the `users` table
$stmt = $dbh->prepare('
INSERT INTO `users`
(users_status, user_login, user_pass, user_email, user_registered)
VALUES
(?, ?, ?, ?, NOW())');
$stmt->bindParam(1, $userstatus, PDO::PARAM_STR);
$stmt->bindParam(2, $username, PDO::PARAM_STR);
$stmt->bindParam(3, $HashedPassword, PDO::PARAM_STR);
$stmt->bindParam(4, $email, PDO::PARAM_STR);
$stmt->execute();
// get user_uid from insert for use in other tables below
$lastInsertID = $dbh->lastInsertId();
// this query inserts data into the `users_status` table
$stmt = $dbh->prepare('
INSERT INTO `users_status`
(user_uid, user_activation_key)
VALUES
(?, ?)');
$stmt->bindParam(1, $lastInsertID, PDO::PARAM_STR);
$stmt->bindParam(2, $activationkey, PDO::PARAM_STR);
$stmt->execute();
// this query inserts data into the `users_roles` table
$stmt = $dbh->prepare('
INSERT INTO `users_roles`
(user_uid, user_role)
VALUES
(?, ?)');
$stmt->bindParam(1, $lastInsertID, PDO::PARAM_STR);
$stmt->bindParam(2, SUBSCRIBER_ROLE, PDO::PARAM_STR);
$stmt->execute();
// this query inserts data into the `users_profiles` table
$stmt = $dbh->prepare('
INSERT INTO `users_profiles`
(user_uid)
VALUES
(?)');
$stmt->bindParam(1, $lastInsertID, PDO::PARAM_STR);
$stmt->execute();
// commit transaction
$dbh->commit();
} // any errors from the above database queries will be catched
catch (PDOException $e) {
// roll back transaction
$dbh->rollback();
// log any errors to file
ExceptionErrorHandler($e);
require_once($footer_inc);
exit;
}
我是 PDO 的新手,上面可能存在我尚未注意到的错误或问题,因为在找出问题之前我无法测试。
-
我需要知道如何首先在 users 表中插入用户数据,以便获取 MySQL 给我的用户的 uid
-
然后获取其他表需要的 uid
-
但同时,如果在插入用户表后查询因任何原因失败,则数据也会从用户表中删除。
【问题讨论】:
-
a) 将
$dbh->beginTransaction();和之前的行放在 try/catch 块之外 - 在事务启动之前,您无法回滚任何内容。 b)什么不适合这个?照常使用 lastInsertId 即可。 -
@Niko,我马上就做,谢谢 phplover
-
@Niko,我编辑了上面的代码以反映您所说的更改,我能问一下为什么
$dbh->beginTransaction();也不能在 try 块中吗?有点不太明白,谢谢phplover -
只检索 ID 而不使用它没有任何意义,对吧?应该是这样的:
$userId = $dbh->lastInsertId();- 我不认为从 try/catch 块中调用 beginTransaction() 真的会导致问题,但是如果开始事务失败并且引发了 PDO 异常,你会在开始之前尝试回滚事务。这会导致未定义的行为,很可能是一个新错误。除此之外,您一切都做得很好。
标签: php pdo transactions