PHP mysqli::rollback() / mysqli_rollback() 函数用于回滚数据库的当前事务.
语法
//面向对象风格
public mysqli::rollback(flags, name)
//面向过程风格
mysqli_rollback(mysql, flags, name)
参数
mysql | 必需。 仅适用于面向过程风格:指定 mysqli_connect() 或 mysqli_init() 返回的 mysqli 对象。 |
flags | 可选。 指定 MYSQLI_TRANS_COR_* 常量的位掩码。 |
name | 可选。 如果提供,则执行 ROLLBACK/*name*/。 |
返回值
成功时返回 true,否则返回 false
示例:面向对象风格
下面的示例展示了 mysqli::rollback() 方法的用法。
<?php
//建立与数据库的连接
$mysqli = new mysqli("localhost", "user", "password", "database");
if ($mysqli->connect_errno) {
echo "Failed to connect to MySQL: ". $mysqli->connect_error;
exit();
}
//表引擎必须支持事务
$mysqli->query("CREATE TABLE IF NOT EXISTS Employee (
Name VARCHAR(255) NOT NULL,
Salary DECIMAL(18,2)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;");
//开始事务
$mysqli->begin_transaction();
try {
//插入一些值
$mysqli->query("INSERT INTO Employee(Name, Salary) VALUES ('John', 3250)");
//尝试插入无效值
$name = 'Marry';
$salary = 'Unknown';
$stmt = $mysqli->prepare('INSERT INTO Employee(Name, Salary) VALUES (?,?)');
$stmt->bind_param('ss', $name, $salary);
$stmt->execute();
//如果代码到达此点且没有错误
//然后提交数据库中的数据
$mysqli->commit();
} catch (mysqli_sql_exception $exception) {
$mysqli->rollback();
throw $exception;
}
?>
示例:面向过程风格
下面的示例显示了 mysqli_rollback() 函数的用法。
<?php
//建立与数据库的连接
$mysqli = mysqli_connect("localhost", "user", "password", "database");
if (mysqli_connect_errno()) {
echo "Failed to connect to MySQL: ". mysqli_connect_error();
exit();
}
//表引擎必须支持事务
mysqli_query($mysqli, "CREATE TABLE IF NOT EXISTS Employee (
Name VARCHAR(255) NOT NULL,
Salary DECIMAL(18,2)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;");
//开始事务
mysqli_begin_transaction($mysqli);
try {
//插入一些值
mysqli_query($mysqli, "INSERT INTO Employee(Name, Salary) VALUES ('John', 3250)");
//尝试插入无效值
$name = 'Marry';
$salary = 'Unknown';
$stmt = mysqli_prepare($mysqli, 'INSERT INTO Employee(Name, Salary) VALUES (?,?)');
mysqli_stmt_bind_param($stmt, 'ss', $name, $salary);
mysqli_stmt_execute($stmt);
//如果代码到达此点且没有错误
//然后提交数据库中的数据
mysqli_commit($mysqli);
} catch (mysqli_sql_exception $exception) {
mysqli_rollback($mysqli);
throw $exception;
}
?>