PHP如何处理mysql事务控制

本篇博客将教大家如何进行PHP处理mysql事务控制

      博主最近在开发一个项目的时候,由于需要使用mysql事务进行控制,防止业务出错,所以就想到了用mysql事务控制来完成,因为是第一次使用原生的PHP处理mysql事务控制,自然也是百度了一番,最后还是自己总结出了方法,大家可以参考参考,代码如下:

#链接数据库
$conSW = mysqli_connect("数据库地址", "账户", "密码", "数据库名称");
if (!$conSW) {
    $json = json_encode(array(
        'code' => 404,
        'data' => '',
        'error' => "数据库链接失败"
    ));
    echo($json);
    exit();
}
#事务开启【事务头】
mysqli_query($conSW, "set names utf8");
mysqli_select_db($conSW, '表名2');
mysqli_query($conSW, "SET AUTOCOMMIT=0"); // 设置为不自动提交,因为MYSQL默认立即执行
mysqli_begin_transaction($conSW);
#事务操作一
$insertSql = "INSERT INTO 表名1(字段1,字段2) VALUES  ('值1','值2')";
$insertMember = mysqli_query($conSW, $insertSql);
if (empty($insertMember)) {
    mysqli_query($conSW, "ROLLBACK");   //数据回滚
    $json = json_encode(array(
        'code' => 404,
        'data' => '',
        'error' => "添加参与记录失败"
    ));
    echo($json);
    exit();
}
#事务操作二
$updateSql = "UPDATE 表名2 SET 字段1='值1',字段2='值2'  WHERE 条件1='条件值'";
$updateMember = mysqli_query($conSW, $updateSql );
if (empty($updateMember)) {
    mysqli_query($conSW, "ROLLBACK");   //数据回滚
    $json = json_encode(array(
        'code' => 404,
        'data' => '',
        'error' => "状态更新失败"
    ));
    echo($json);
    exit();
}
#结束提交本次事务
mysqli_commit($conSW);
mysqli_close($conSW);
#返回
$json = json_encode(array(
    'code' => 200,
    'data' => '恭喜你事务成功',
    'error' => ""
));
echo($json);
exit();

       以上就是博主使用的事务操作代码,主要是开头的事务开始头,中间的事务回滚代码,以及最后的事务提交,如果不提交事务,之前的数据是不会产生改变,如果中间因为出问题而不事务回滚,则之前产生的数据会改变,小伙伴们可以试试。

0条评论

发表评论