PHP MySQLi 函数

PHP mysqli::begin_transaction() / mysqli_begin_transaction() 函数用于启动事务。它需要InnoDB引擎（默认情况下启用）。

语法

//面向对象风格
public mysqli::begin_transaction(flags, name)

//面向过程风格
mysqli_begin_transaction(mysql, flags, name)

参数

mysql必填。 仅适用于面向过程风格:指定 mysqli_connect() 或 mysqli_init() 返回的 mysqli 对象。
flags可选。 指定标志。有效标志为:
  • MYSQLI_TRANS_START_READ_ONLY:以"START TRANSACTION READ ONLY"启动事务。需要 MySQL 5.6 及更高版本。
  • MYSQLI_TRANS_START_READ_WRITE:以"START TRANSACTION READ WRITE"启动事务。需要 MySQL 5.6 及更高版本。
  • MYSQLI_TRANS_START_WITH_CONSISTENT_SNAPSHOT:以"START TRANSACTION WITH CONSISTENT SNAPSHOT"方式启动事务。
name可选。 指定事务的保存点名称。

返回值

成功时返回 true，失败时返回 false。

示例:面向对象风格

下面的示例展示了mysqli::begin_transaction()方法的用法。

<?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_begin_transaction() 函数的用法。

<?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;
}
?>