thinkphp 的事宜回滚处理 和 原始PHP的事务回滚实例

thinkphp 的事务回滚处理 和 原始PHP的事务回滚实例

1.  要程序里面支持事务，首先连接的数据库和数据表必须支持事务 mysql   为例：

数据库InnoDB支持 transactions

 

数据表支持事务：InnoDB  支持transaction

2. 框架thinkphp  支持事务代码

<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span><span style="color: #000000;"> testrollback(){</span><span style="color: #800080;">$model1</span> = D('item'<span style="color: #000000;">);</span><span style="color: #800080;">$model2</span> = D('vote'<span style="color: #000000;">);</span><span style="color: #800080;">$model1</span>-><span style="color: #000000;">startTrans();</span><span style="color: #800080;">$res1</span> = <span style="color: #800080;">$model1</span>->where('id = 5')-><span style="color: #000000;">delete();</span><span style="color: #800080;">$res2</span> = <span style="color: #800080;">$model2</span>->where('id = 2')-><span style="color: #000000;">delete();dump(</span><span style="color: #800080;">$res1</span><span style="color: #000000;">);dump(</span><span style="color: #800080;">$res2</span><span style="color: #000000;">);</span><span style="color: #0000ff;">if</span>(<span style="color: #800080;">$res1</span> && <span style="color: #800080;">$res2</span><span style="color: #000000;">){</span><span style="color: #800080;">$model1</span>->commit();   <span style="color: #008000;">//</span><span style="color: #008000;">只有$res1 和  $res2  都执行成功是才真正执行上面的数据库操作</span>dump("commit"<span style="color: #000000;">);}</span><span style="color: #0000ff;">else</span><span style="color: #000000;">{</span><span style="color: #800080;">$model1</span>->rollback();  <span style="color: #008000;">//</span><span style="color: #008000;">  条件不满足，回滚</span>dump("rollback"<span style="color: #000000;">);}dump(</span>"over"<span style="color: #000000;">);</span><span style="color: #0000ff;">exit</span><span style="color: #000000;">;}</span>

 

 

 

3.  原始PHP 代码事务实例

方法一：只支持数据库和数据表都是 innoDB  的情况

<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span><span style="color: #000000;">  rollbackoriginal1(){        </span><span style="color: #800080;">$conn</span> = <span style="color: #008080;">mysql_connect</span>('127.0.0.1','summerzi','summerzi') or <span style="color: #0000ff;">die</span>('DB connection failed!'<span style="color: #000000;">);        </span><span style="color: #008080;">mysql_select_db</span>('summer',<span style="color: #800080;">$conn</span><span style="color: #000000;">);        </span><span style="color: #008080;">mysql_query</span>('set names "GBK"'<span style="color: #000000;">);        </span><span style="color: #008080;">mysql_query</span>('BEGIN'<span style="color: #000000;">);        </span><span style="color: #800080;">$sql1</span> = "INSERT INTO `summer_userdata`(`uid`,`type`,`target_id`) VALUES(41,1,233);"<span style="color: #000000;">;        </span><span style="color: #800080;">$sql2</span> = "INSERT INTO `summer_userdata`(`uid`,`type`,`target_id`) VALUES(fdfd,2,235);"<span style="color: #000000;">;        </span><span style="color: #800080;">$res1</span> = <span style="color: #008080;">mysql_query</span>(<span style="color: #800080;">$sql1</span><span style="color: #000000;">);        </span><span style="color: #800080;">$res2</span>  = <span style="color: #008080;">mysql_query</span>(<span style="color: #800080;">$sql2</span><span style="color: #000000;">);        dump(</span><span style="color: #800080;">$sql1</span><span style="color: #000000;">);        dump(</span><span style="color: #800080;">$sql2</span><span style="color: #000000;">);        dump(</span><span style="color: #800080;">$res1</span><span style="color: #000000;">);        dump(</span><span style="color: #800080;">$res2</span><span style="color: #000000;">);        </span><span style="color: #0000ff;">if</span>(<span style="color: #800080;">$res1</span> && <span style="color: #800080;">$res2</span><span style="color: #000000;">){            </span><span style="color: #008080;">mysql_query</span>('COMMIT'<span style="color: #000000;">);            dump(</span>'commit success!'<span style="color: #000000;">);        }</span><span style="color: #0000ff;">else</span><span style="color: #000000;">{            </span><span style="color: #008080;">mysql_query</span>('ROLLBACK'<span style="color: #000000;">);            dump(</span>'commit failed, rollback!'<span style="color: #000000;">);        }        </span><span style="color: #008080;">mysql_query</span>('END'<span style="color: #000000;">);    }</span>

方法二：（注意：对于不支持事务的MyISAM引擎数据库可以使用表锁定的方法）

<span style="color: #0000ff;">public</span> <span style="color: #0000ff;">function</span><span style="color: #000000;"> rollbackoriginal2(){        </span><span style="color: #800080;">$conn</span> = <span style="color: #008080;">mysql_connect</span>('127.0.0.1','summerzi','summerzi') or <span style="color: #0000ff;">die</span>('DB connection failed!'<span style="color: #000000;">);        </span><span style="color: #008080;">mysql_select_db</span>('summer',<span style="color: #800080;">$conn</span><span style="color: #000000;">);        </span><span style="color: #008080;">mysql_query</span>('set names "GBK"'<span style="color: #000000;">);        </span><span style="color: #008080;">mysql_query</span>('SET AUTOCOMMIT=0');<span style="color: #008000;">//</span><span style="color: #008000;">//设置mysql不自动提交，需自行用commit语句提交</span>        <span style="color: #800080;">$sql1</span> = "INSERT INTO `summer_userdata`(`uid`,`type`,`target_id`) VALUES(41,1,233);"<span style="color: #000000;">;        </span><span style="color: #800080;">$sql2</span> = "INSERT INTO `summer_userdata`(`uid`,`type`,`target_id`) VALUES(44,2,235);"<span style="color: #000000;">;        </span><span style="color: #008000;">//</span><span style="color: #008000;">mysql_query("LOCK TABLES `hmbl_userdata` WRITE");//锁定表</span>        <span style="color: #800080;">$res1</span> = <span style="color: #008080;">mysql_query</span>(<span style="color: #800080;">$sql1</span><span style="color: #000000;">);        </span><span style="color: #800080;">$res2</span>  = <span style="color: #008080;">mysql_query</span>(<span style="color: #800080;">$sql2</span><span style="color: #000000;">);        dump(</span><span style="color: #800080;">$sql1</span><span style="color: #000000;">);        dump(</span><span style="color: #800080;">$sql2</span><span style="color: #000000;">);        dump(</span><span style="color: #800080;">$res1</span><span style="color: #000000;">);        dump(</span><span style="color: #800080;">$res2</span><span style="color: #000000;">);        </span><span style="color: #008000;">//</span><span style="color: #008000;">mysql_query("UNLOCK TABLES");//解除锁定</span>        <span style="color: #0000ff;">if</span>(<span style="color: #800080;">$res1</span> && <span style="color: #800080;">$res2</span><span style="color: #000000;">){            </span><span style="color: #008080;">mysql_query</span>('COMMIT'<span style="color: #000000;">);            dump(</span>'commit success!'<span style="color: #000000;">);        }</span><span style="color: #0000ff;">else</span><span style="color: #000000;">{            </span><span style="color: #008080;">mysql_query</span>('ROLLBACK'<span style="color: #000000;">);            dump(</span>'commit failed, rollback!'<span style="color: #000000;">);        }        </span><span style="color: #008080;">mysql_query</span>("SET AUTOCOMMIT=1"<span style="color: #000000;">);        </span><span style="color: #008080;">mysql_query</span>('END'<span style="color: #000000;">);            }</span>

php + mysql  对事务的处理比较简单，涉及到业务中多个数据操作，就可以考虑用事务处理