PHP MySQLi 函数

PHP mysqli::commit() / mysqli_commit() 函数用于提交数据库的当前事务

语法

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

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

参数

mysql必需。 仅适用于面向过程风格:指定 mysqli_connect() 或 mysqli_init() 返回的 mysqli 对象。
flags可选。 指定 MYSQLI_TRANS_COR_* 常量的位掩码。
name可选。 如果提供，则执行 COMMIT/*name*/。

返回值

成功时返回 true，否则返回 false

示例:面向对象风格

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

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

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