前言MySQL的使用MySQL多表同时删除方案MySQL跨表、多表更新SQL语句总结MySQL存储引擎安装常规方式编译安装MySQL采用cmake方式编译安装MySQL使用rpm包安装MySQL使用yum方式安装MySQL采用二进制方式免编译安装MySQL多实例的安装什么是多实例多实例的作用、问题以及应用场景多实例安装01【推荐】多实例官方安装方案02启动、用户和权限管理单实例MySQL的启动和关闭的方法设置及修改MySQL root用户密码找回丢失的MySQL root用户密码创建MySQL用户及用户权限管理基础命令的操作MySQL库和表相关操作MySQL中的索引操作MySQL常用命令MySQL的错误代码MySQL复习秘籍备份与恢复备份恢复mysqlbinlog命令服务日志主从复制主从复制部署配置问题汇总主从复制读写分离灾难恢复配置phpmyadmin连接多实例MySQLMySQL语句大全用户创建、权限、删除数据库与表显示、创建、删除Mysql表复制及备份还原 数据库表中数据操作修改表中的指定一条数据查询表日志批量修改Mysql表引擎为InnoDB的方法数据库抽象层 PDOPDO对象常用方法PDO 事务处理PDO 与 MySQLi 二者效率简单比较大小写敏感性 lower_case_table_namesCentOS7安装MySQL5.7密码查看与修改
©
本文档使用
php.cn手册 发布
文字
PDO 事务处理
PDO 事务对象方法
| 方法 | 描述 |
|---|---|
beginTransaction() | 启动一个事务 |
commit() | 提交一个事务 |
rollBack() | 回滚一个事务 |
inTransaction() | 检测是否在一个事务内 |
注意：当需要使用事务的时候，数据库表引擎不能是
MyISAM，必须要是InnoDB。
<?php
try {
$host = 'mysql:host=localhost;dbname=test';
$pdo = new PDO($host, 'root', 'aaaaaa', [PDO::ATTR_AUTOCOMMIT => 0]);
// 建表 SQL
$sql = <<<EOF
CREATE TABLE IF NOT EXISTS user_account(
id INT UNSIGNED NOT NULL AUTO_INCREMENT,
username VARCHAR(20) NOT NULL UNIQUE,
money DECIMAL(8,2) NOT NULL,
PRIMARY KEY (id)
)ENGINE=InnoDB DEFAULT CHARSET UTF8 COMMENT "用户账户表";
EOF;
$pdo->exec($sql); // 使用 PDO 对象的 exec()方法执行建表语句
/*$sql = 'INSERT INTO user_account (username, money) VALUES (:username, :money),(:username2, :money2)';
$statement = $pdo->prepare($sql); // 预处理 SQL
$statement->bindParam(':username', $username, PDO::PARAM_STR);
$statement->bindParam(':money', $money);
$statement->bindParam(':username2', $username2, PDO::PARAM_STR);
$statement->bindParam(':money2', $money2);
$username = 'luo';
$money = 3000.00;
$username2 = 'li';
$money2 = 3000.00;
$statement->execute(); // 执行预处理*/
// 开启事务
$pdo->beginTransaction();
$res = $pdo->exec('UPDATE user_account SET money = money - 2000 WHERE username = "li"');
if ($res == 0) {
throw new PDOException('li 转账失败');
}
$res2 = $pdo->exec('UPDATE user_account SET money = money + 2000 WHERE username = "luo"');
if ($res2 == 0) {
throw new PDOException('luo 接受转账失败');
}
$pdo->commit();
} catch (PDOException $e) {
echo $e->getMessage();
}