`
mw666666
  • 浏览: 23750 次
  • 性别: Icon_minigender_1
  • 来自: 保定
社区版块
存档分类
最新评论

php事务处理

    博客分类:
  • php
阅读更多
转自:http://hi.baidu.com/nan_feiyan/blog/item/cea1e6d37b79c03e960a1654.html

MySQL5.X都已经发布好久了,但是还有很多人认为MySQL是不支持事务处理的,这不得不怪他们是孤陋寡闻的,其实,只要你的MySQL版本支持BDB或InnoDB表类型,那么你的MySQL就具有事务处理的能力。这里面,又以InnoDB表类型用的最多,虽然后来发生了诸如Oracle收购InnoDB等令MySQL不爽的事情,但那些商业上的斗争与技术无关,下面以InnoDB表类型为例简单说一下MySQL中的事务。

先来明确一下事务涉及的相关知识:

事务都应该具备ACID特征。所谓ACID是Atomic(原子性),Consistent(一致性),Isolated(隔离性),Durable(持续性)四个词的首字母所写,下面以“银行转帐”为例来分别说明一下它们的含义:

原子性:组成事务处理的语句形成了一个逻辑单元,不能只执行其中的一部分。换句话说,事务是不可分割的最小单元。比如:银行转帐过程中,必须同时从一个帐户减去转帐金额,并加到另一个帐户中,只改变一个帐户是不合理的。

一致性:在事务处理执行前后,数据库是一致的。也就是说,事务应该正确的转换系统状态。比如:银行转帐过程中,要么转帐金额从一个帐户转入另一个帐户,要么两个帐户都不变,没有其他的情况。

隔离性:一个事务处理对另一个事务处理没有影响。就是说任何事务都不可能看到一个处在不完整状态下的事务。比如说,银行转帐过程中,在转帐事务没有提交之前,另一个转帐事务只能处于等待状态。

持续性:事务处理的效果能够被永久保存下来。反过来说,事务应当能够承受所有的失败,包括服务器、进程、通信以及媒体失败等等。比如:银行转帐过程中,转帐后帐户的状态要能被保存下来。

再来看看哪些问题会用到事务处理:


这里不说“银行转帐”的例子了,说一个大家实际更容易遇到的“网上购书”的例子。先假设一下问题的背景:网上购书,某书(数据库编号为123)只剩最后一本,而这个时候,两个用户对这本书几乎同时发出了购买请求,让我们看看整个过程:

在具体分析之前,先来看看数据表的定义:

-------------------------------------------------------------------------------

create table book
(
    book_id unsigned int(10) not null auto_increment,
    book_name varchar(100) not null,
    book_price float(5, 2) not null, #我假设每本书的价格不会超过999.99元
    book_number int(10) not null,
    primary key (book_id)
)
type = innodb; #engine = innodb也行

-------------------------------------------------------------------------------

对于用户甲来说,他的动作稍微比乙快一点点,其购买过程所触发的动作大致是这样的:

-------------------------------------------------------------------------------

1. SELECT book_number FROM book WHERE book_id = 123;

book_number大于零,确认购买行为并更新book_number

2. UPDATE book SET book_number = book_number - 1 WHERE book_id = 123;

购书成功

-------------------------------------------------------------------------------

而对于用户乙来说,他的动作稍微比甲慢一点点,其购买过程所触发的动作和甲相同:

-------------------------------------------------------------------------------

1. SELECT book_number FROM book WHERE book_id = 123;

这个时候,甲刚刚进行完第一步的操作,还没来得及做第二步操作,所以book_number一定大于零

2. UPDATE book SET book_number = book_number - 1 WHERE book_id = 123;

购书成功

-------------------------------------------------------------------------------

表面上看甲乙的操作都成功了,他们都买到了书,但是库存只有一本,他们怎么可能都成功呢?再看看数据表里book_number的内容,已经变成“-1”了,这当然是不能允许的(实际上,声明这样的列类型应该加上unsigned的属性,以保证其不能为负,这里是为了说明问题所以没有这样设置)

好了,问题陈述清楚了,再来看看怎么利用事务来解决这个问题,打开MySQL手册,可以看到想用事务来保护你的SQL正确执行其实很简单,基本就是三个语句:开始,提交,回滚。

-------------------------------------------------------------------------------

开始:START TRANSACTION或BEGIN语句可以开始一项新的事务

提交:COMMIT可以提交当前事务,是变更成为永久变更

回滚:ROLLBACK可以回滚当前事务,取消其变更

此外,SET AUTOCOMMIT = {0 | 1}可以禁用或启用默认的autocommit模式,用于当前连接。

-------------------------------------------------------------------------------

那是不是只要用事务语句包一下我们的SQL语句就能保证正确了呢?比如下面代码:

-------------------------------------------------------------------------------

BEGIN;

SELECT book_number FROM book WHERE book_id = 123;

// ...

UPDATE book SET book_number = book_number - 1 WHERE book_id = 123;

COMMIT;

-------------------------------------------------------------------------------

答案是否定了,这样依然不能避免问题的发生,如果想避免这样的情况,实际应该如下:

-------------------------------------------------------------------------------

BEGIN;

SELECT book_number FROM book WHERE book_id = 123 FOR UPDATE;

// ...

UPDATE book SET book_number = book_number - 1 WHERE book_id = 123;

COMMIT;

-------------------------------------------------------------------------------

由于加入了FOR UPDATE,所以会在此条记录上加上一个行锁,如果此事务没有完全结束,那么其他的事务在使用SELECT ... FOR UPDATE请求的时候就会处于等待状态,直到上一个事务结束,它才能继续,从而避免了问题的发生,需要注意的是,如果你其他的事务使用的是不带FOR UPDATE的SELECT语句,将得不到这种保护。

最后看看PHP + MySQL事务操作的代码演示:

实际LAMP应用中,一般PHP使用AdoDB操作MySQL,下面给出AdoDB相应的代码方便大家查阅:

-------------------------------------------------------------------------------
<?php 
// ...

$adodb->startTrans();

//实际,getOne所调用的查询也可以直接放到rowLock来进行,这里只是为了演示效果能更明显些。

$adodb->rowLock('book', 'book_id = 123');

$bookNumber = $adodb->getOne("SELECT book_number FROM book WHERE book_id = 123");

$adodb->execute("UPDATE book SET book_number = book_number - 1 WHERE book_id = 123");

$adodb->completeTrans();

// ... 
?>


-------------------------------------------------------------------------------

其中,rowLock的方法就是调用的FOR UPDATE来实现的行锁,你可能会想把“FOR UPDATE”直接写到$adodb->getOne()调用的那条SQL语句里面去实现行锁的功能,不错,那样确实可以,但是并不是所有的数据库都使用“FOR UPDATE”语法来实现行锁功能,比如Sybase使用“HOLDLOCK”的语法来实现行锁功能,所以为了你的数据库抽象层保持可移植性,我还是劝你用rowLock来实现行锁功能,至于可移植性就交给AdoDB好了,嗯,有点扯远了,今儿就说到这里了。

-------------------------------------------------------------------------------

附:

AdoDB中存在一个setTransactionMode()方法,能够设置事务的隔离级别,如下:

SetTransactionMode allows you to pass in the transaction mode to use for all subsequent transactions for that connection session. Note: if you have persistent connections and using mysql or mssql, you might have to explicitly reset your transaction mode at the beginning of each page request. This is only supported in postgresql, mssql, mysql with InnoDB and oci8 currently. For example:

$db->SetTransactionMode("SERIALIZABLE");
$db->BeginTrans();
$db->Execute(...); $db->Execute(...);
$db->CommiTrans();

$db->SetTransactionMode(""); // restore to default
$db->StartTrans();
$db->Execute(...); $db->Execute(...);
$db->CompleteTrans();

Supported values to pass in:

    * READ UNCOMMITTED (allows dirty reads, but fastest)
    * READ COMMITTED (default postgres, mssql and oci8)
    * REPEATABLE READ (default mysql)
    * SERIALIZABLE (slowest and most restrictive)

You can also pass in database specific values such as 'SNAPSHOT' for mssql or 'READ ONLY' for oci8/postgres.
分享到:
评论

相关推荐

    mySQL事务处理

    关于mysql的事务处理 public static void StartTransaction(Connection con, String[] sqls) throws Exception { if (sqls == null) { return; } Statement sm = null; try { // 事务开始 System....

    php事务处理实例详解

    一、php事务处理概述: 事务:是若干事件的集合 事务处理:当所有事件执行成功,事务才执行;若有任何一个事件不能成功执行,事务的其它事件也不被执行。 只要你的MySQL版本支持BDB或InnoDB表类型,那么你的MySQL就具有...

    PHP 事务处理数据实现代码

    本文将详细解析一个具体的PHP事务处理示例代码,帮助读者更好地理解其工作原理及应用场景。 #### 二、事务处理基础知识 在深入分析代码之前,我们先回顾一下事务处理的基本概念: - **事务**(Transaction):是由...

    PHP+Mysql基于事务处理实现转账功能的方法

    本文实例讲述了PHP+Mysql基于事务处理实现转账功能的方法。分享给大家供大家参考。具体如下: &lt;?php header("Content-Type:text/html;charset=utf-8"); $mysqli=new mysqli("localhost","root","","test"); ...

    简易之PHP通过OCI访问Oracle数据库可做事务处理

    以上知识点涵盖了从Oracle数据库的配置到PHP通过OCI扩展访问Oracle数据库,并进行基本的数据库操作以及事务处理的全过程。要实现这些功能,还需要对oci8扩展的API有一定的了解,包括oci_connect、oci_parse、oci_...

    基于MySQL和PHP的分布式事务处理.pdf

    ### 基于MySQL和PHP的分布式事务处理 #### 一、引言 随着互联网技术的发展,越来越多的应用程序需要跨越多个服务器或者多个地理位置的数据中心来处理数据。这导致了分布式事务处理的需求日益增长。分布式事务处理...

    PHP分布式事务 YiMQ库

    本文将深入探讨PHP中的分布式事务以及YiMQ库的使用,帮助开发者更好地理解如何在PHP环境中实现高效、可靠的分布式事务处理。 首先,让我们了解什么是分布式事务。分布式事务是指跨越多个数据库或服务的单个逻辑操作...

    解析php mysql 事务处理回滚操作(附实例)

    以下是一个简单的PHP事务处理回滚操作示例: ```php mysql_query("BEGIN"); // 开启事务 $sql = "INSERT INTO ..."; // 第一条SQL语句 $sql2 = "INSERT INTO ..."; // 第二条SQL语句 // 执行SQL语句 $res = mysql_...

    php实现mysql事务处理的方法

    本文实例讲述了php实现mysql事务处理的方法。分享给大家供大家参考。具体分析如下: 要实现本功能的条件是环境 mysql 5.2 /php 5 支持事务的table 类型,需要InnoDB,有了这些条件你就可以做上面的实现了,这个事物回滚...

    基于Hyperf框架的TCC分布式事务组件.zip

    在分布式系统中,事务处理是确保数据一致性的重要环节。TCC(Try-Confirm-Cancel)模式是一种著名的分布式事务解决方案,它适用于大型微服务架构。本资料"基于Hyperf框架的TCC分布式事务组件"旨在帮助开发者理解如何...

    PHP+MySQL高并发加锁事务处理问题解决方法

    本文将深入探讨如何解决在高并发条件下,使用PHP进行加锁事务处理的问题,以确保数据的正确性和唯一性。 首先,让我们回顾一下问题背景。假设我们需要在数据库中插入一条数据,条件是当`username`字段为`'mraz'`时...

    Zend Framework 多表关联 数据库操作、事务处理

    **标题详解:** "Zend Framework 多表关联 数据库操作、事务处理" Zend Framework 是一个开源的PHP框架,用于...对于想要深入学习 Zend Framework 数据库操作和事务处理的PHP开发者来说,这是一个非常有价值的资源。

    php使用PDO事务配合表格读取大量数据插入操作实现方法

    以下是一个具体的PHP PDO事务处理的例子: ```php try { $dbms = 'mysql'; $dbname = 'biaoge'; $user = 'root'; $pwd = '123456'; $host = 'localhost'; $dsn = "$dbms:host=$host;dbname=$dbname"; $pdo ...

    PHP使用pdo实现事务处理操作示例

    在PHP编程中,数据库操作是不可或缺的一部分,尤其是在处理复杂的数据变更时,事务处理显得尤为重要。PDO(PHP Data Objects)扩展为PHP提供了一种统一的方式来访问各种数据库,同时也支持事务处理,确保数据的一致...

    PHP ADODB实现事务处理功能示例

    本文标题为“PHP ADODB实现事务处理功能示例”,将详细介绍如何使用PHP ADODB库来实现事务处理。首先,需要明确ADODB是什么。ADODB是Active Data Objects Data Base的缩写,它是一套用于数据库访问的开源PHP类库。...

Global site tag (gtag.js) - Google Analytics