PHP PDO Transactions?

2022-08-30 12:29:29

我有一个注册页面,基本上我需要将数据插入到4个表中。我是PDO的新手,对某些事情感到困惑。

基本上,如果任何插入失败,我不希望将任何内容添加到数据库中,这似乎很简单。

我的困惑是,我需要首先在我的表中插入用户的用户名,电子邮件,密码等,以便我可以使用PDO(不确定如何)使用uid MySQL给我的用户(由mysql自动递增)。我需要用户uid MySQL为我的用户提供其他表,因为其他表需要uid,以便所有内容都正确链接在一起。我的表是InnoDB,我有从users_profiles(user_uid),users_status(user_uid),users_roles(user_uid)到users.user_uid的外键,因此它们都链接在一起。users

但与此同时,我想确保例如在将数据插入表中之后(这样我就可以获得MySQL给用户的uid),如果任何其他插入失败,它将删除插入到表中的数据。usersusers

我认为最好展示我的代码;我已经注释掉了代码,并在代码中进行了解释,这可能会使其更容易理解。

// 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的新手,上面可能有错误或问题我还没有注意到,因为在我找出我的问题之前,我还不能测试。

  1. 我需要知道如何首先在用户表中插入用户数据,以便我可以获得mySQL给我的用户的uid

  2. 然后获取 uid,因为我需要它用于其他表

  3. 但与此同时,如果在插入用户表后查询因任何原因失败,则该数据也会从用户表中删除。


答案 1

此函数返回刚刚插入的记录的主键:PDO::lastInsertId 您将需要它作为参数。在 INSERT 语句之后使用它。NEED_USERS_UID_FOR_HERE

由于您启动了事务,因此,如果您对MySQL表使用InnoDB引擎(MyISAM不支持事务),如果发生任何错误,则不会将数据插入到任何表中。


答案 2

推荐