PHP简单的事务测试用例
程序员文章站
2022-05-12 23:15:52
...
show engines; +--------------------+---------+----------------------------------------------------------------+--------------+------+------------+ | Engine | Support | Comment | Transactions | XA | Savepoints | +--------------------+---------+----------------------------------------------------------------+--------------+------+------------+ | FEDERATED | NO | Federated MySQL storage engine | NULL | NULL | NULL | | MRG_MYISAM | YES | Collection of identical MyISAM tables | NO | NO | NO | | MyISAM | YES | MyISAM storage engine | NO | NO | NO | | BLACKHOLE | YES | /dev/null storage engine (anything you write to it disappears) | NO | NO | NO | | CSV | YES | CSV storage engine | NO | NO | NO | | MEMORY | YES | Hash based, stored in memory, useful for temporary tables | NO | NO | NO | | ARCHIVE | YES | Archive storage engine | NO | NO | NO | | InnoDB | DEFAULT | Supports transactions, row-level locking, and foreign keys | YES | YES | YES | | PERFORMANCE_SCHEMA | YES | Performance Schema | NO | NO | NO | +--------------------+---------+----------------------------------------------------------------+--------------+------+------------+ // schemal create table transaction_tbl ( name char(10) not null ) engine=innodb; */ class Transaction { // 判断插入查询是否成功 private $error = 0; // 连接资源 private $conn_id = null; public function __construct() { $this->connect(); } public function test() { echo "BEGIN TEST\n"; //开始事务 $this->beginTransaction(); // 插入测试数据 // name 的大小限制为10 $str1 = str_repeat("a", mt_rand(1, 13)); $str2 = str_repeat("b", mt_rand(1, 13)); $this->query("INSERT INTO `transaction_tbl` (`name`) VALUES ('$str1')"); $this->query("INSERT INTO `transaction_tbl` (`name`) VALUES ('$str2')"); //提交查询 if ($this->error == 0) { $this->commit(); } else { $this->rollback(); } echo "END TEST\n"; } private function query($sql) { echo $sql."\n"; (mysql_query($sql, $this->conn_id) == FALSE) && ++$this->error; } // 开始事务 private function beginTransaction() { mysql_query("BEGIN", $this->conn_id); } //回滚 private function rollback() { echo "ROLLBACK\n"; mysql_query("ROLLBACK", $this->conn_id); } //提交 private function commit() { echo "save done\n"; mysql_query("COMMIT", $this->conn_id); } // 连接数据库 private function connect() { $this->conn_id = @mysql_connect("127.0.0.1", "root", "") or die("can\'t connect: ". mysql_error()); mysql_select_db("test", $this->conn_id) or die("can\'t use test: ". mysql_error()); } // 关闭数据 private function close() { mysql_close($this->conn_id); } public function __destruct() { $this->close(); } } $trans = new Transaction(); $trans->test();
上一篇: 构建工具Gulp的详细介绍