免费注册 查看新帖 |

Chinaunix

  平台 论坛 博客 文库
› 论坛 › 数据库技术 › MySQL › PHP中mysql事务的完整性
最近访问板块 发新帖
查看: 14247 | 回复: 6
打印 上一主题 下一主题

PHP中mysql事务的完整性 [复制链接]

rsuhkoi

论坛徽章:
0
跳转到指定楼层
1楼 [收藏(0)] [报告]
发表于 2006-06-04 22:11 |只看该作者 |倒序浏览
小弟在写一个PHP程序,程序里的数据库操作和转帐的过程类似,把一个表中的金额转到另一个里头,突然想到一个问题:这在PHP里头必然涉及到两次对表的操作,那么事务指的什么?是单独的一次操作还是这两次?如果是指的单独的一次操作那么如何保证数据的一致性?如果指的是这两次操作,那么MYSQL中是如何来保证事务的完整性的?
rardge

论坛徽章:
0
2楼 [报告]
发表于 2006-06-05 00:02 |只看该作者
事务(transaction)是由查询和/或更新语句的序列组成。
用 begin、start transaction 开始一个事务，rollback 回滚事务，commit 提交事务。
在开始一个事务后，可以有若干个 SQL 查询或更新语句，每个 SQL 递交执行后，还应该有判断是否正确执行的语句，以确定下一步是否回滚，若都被正确执行则最后提交事务。
事务一旦回滚，数据库则保持开始事务前状态。就好象一个被编辑的文件不存盘退出，自然还是保持文件原来的样子。
所以，事务可被视为原子操作，事务中的 SQL，要么全部执行，要不一句都不执行。
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
rsuhkoi

论坛徽章:
0
3楼 [报告]
发表于 2006-06-06 12:51 |只看该作者
你说的是ODBC JDBC里的处理方法,可是PHP里头好像没有这样的COMMIT ROLLBACK,那么PHP里头是如何做的?
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
xinglp

论坛徽章:
5
2015年辞旧岁徽章 日期:2015-03-03 16:54:152015年迎新春徽章 日期:2015-03-04 09:53:172015亚冠之水原三星 日期:2015-06-02 16:34:202015年亚冠纪念徽章 日期:2015-10-19 18:13:37程序设计版块每日发帖之星 日期:2015-11-08 06:20:00
4楼 [报告]
发表于 2006-06-06 13:14 |只看该作者
首先要使用支持事务的数据库 后端比如 InnoDB
我只知道C_API有相关事物的函数PHP 应该也有吧 看看MySQL和PHP的手册
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
rardge

论坛徽章:
0
5楼 [报告]
发表于 2006-06-06 13:39 |只看该作者
原帖由 rsuhkoi 于 2006-6-6 12:51 发表
你说的是ODBC JDBC里的处理方法,可是PHP里头好像没有这样的COMMIT ROLLBACK,那么PHP里头是如何做的?

你理解上有问题，事务是数据库的东西，为什么需要在 PHP 这个编程语言中提供支持？
PHP + MySQL 用事务，就是直接在 PHP 中用：mysql_query("begin")、mysql_query("rollback")、mysql_query("commit") 来递交啊。
要注意的是，MySQL 总的数据表必须是 innodb 或者 bdb 等支持事务的表类型。更多的看 MySQL 手册。

[ 本帖最后由 rardge 于 2006-6-6 14:03 编辑 ]
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
rsuhkoi

论坛徽章:
0
6楼 [报告]
发表于 2006-06-06 23:28 |只看该作者
我才学PHP不过2个月,接触到的书上的例子基本上都没有提到这个问题,手册上也没有说明白,你能给个好点的参考书或是手册吗?
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
rardge

论坛徽章:
0
7楼 [报告]
发表于 2006-06-07 11:44 |只看该作者
请注意：把相关编码设定为 utf8，PHP 文件也存为 utf-8 编码，否则示例中中文乱码。

我表结构，注意表类型用的是 InnoDB。

  2. mysql> show create table test.i_t\G
  3. *************************** 1. row ***************************
  4.        Table: i_t
  5. Create Table: CREATE TABLE `i_t` (
  6.   `id` int(10) unsigned NOT NULL auto_increment,
  7.   `age` int(10) unsigned default NULL,
  8.   PRIMARY KEY  (`id`)
  9. ) ENGINE=InnoDB DEFAULT CHARSET=utf8
  10. 1 row in set (0.00 sec)
复制代码


  2. <?php
  3. function html_header() {
  4.         $content = <<<HTML
  5. <!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.0 Transitional//EN">
  6. <html>
  7. <head>
  8. <title>数据库事务处理示例</title>
  9. <meta HTTP-EQUIV="Content-Type" CONTENT="text/html; charset=utf-8">
  10. </head>
  11. <body>
  12. HTML;

  14.         echo $content;
  15. }

  17. function html_footer() {
  18.         $content = <<<HTML
  19. </body>
  20. </html>
  21. HTML;

  23.         echo $content;
  24. }

  26. function print_result(&$result, $caption) {
  27.         echo '<table width="500" border="1">';
  28.         echo '<caption>' . $caption . '</caption>';
  29.         echo '<tr height="22"><td>ID</td><td>AGE</td></tr>';

  31.         $rows = mysql_num_rows($result);
  32.         switch($rows) {
  33.         case 0:
  34.                 echo '<tr><td colspan=\'2\'>无记录</td></tr>';
  35.                 break;
  36.         default :
  37.                 for($i = 0; $i< $rows; $i++) {
  38.                         $row = mysql_fetch_array($result);
  39.                         echo '<tr><td>' . $row['id'] . '</td><td>' . $row['age'] . '</td></tr>';
  40.                 }
  41.                 break;
  42.         }

  44.         echo '</table>';
  45.         echo '<br>';
  46. }
  47. ?>
  48. <?php
  49.         html_header();

  51.         /* 参数定义 */
  52.         define('HOST', 'localhost');
  53.         define('USER', '');
  54.         define('PASSWD', '');
  55.         define('DB', 'test');
  56.         define('TB', 'i_t');

  58.         /* 示例 SQL 语句组 */
  59.         $SQL[] = 'INSERT INTO ' . TB . ' (age) VALUES (23)';
  60.         $SQL[] = 'INSERT INTO ' . TB . ' (age) VALUES (30)';
  61.         $SQL[] = 'INSERT INTO ' . TB . ' (age) VALUES (18)';

  63.         /* 连接 MySQL 服务器 */
  64.         $link_id = @ mysql_connect(HOST, USER, PASSWD) or exit(mysql_error());
  65.         mysql_select_db(DB, $link_id) or exit(mysql_error());

  67.         /*********************
  68.         * 例1
  69.         * 数据回卷的情形
  70.         *********************/

  72.         /* 查询当前数据表记录状态 */
  73.         $result = mysql_query('SELECT id, age FROM ' . TB, $link_id);
  74.         print_result($result, '例1，初始状态');

  76.         /* 创建事务 */
  77.         mysql_query('START TRANSACTION', $link_id) or exit(mysql_error());

  79.         /* 提交 SQL */
  80.         for($i = 0; $i < count($SQL); $i++) {
  81.                 mysql_query($SQL[$i], $link_id); // 假设无错误发生
  82.         }

  84.         /* 查询当前数据表记录状态 */
  85.         $result = mysql_query('SELECT id, age FROM ' . TB, $link_id);
  86.         print_result($result, '此状态仅在该事务中可见');

  88.         /* 回卷 －－ 也意味着中止此次事务 */
  89.         mysql_query('ROLLBACK', $link_id) or exit(mysql_error());

  91.         /* 查询当前数据表记录状态 */
  92.         $result = mysql_query('SELECT id, age FROM ' . TB, $link_id);
  93.         print_result($result, '人为回卷事务，数据表最终状态');


  96.         /*********************
  97.         * 例2
  98.         * 数据被正式提交的情形
  99.         *********************/

  101.         /* 查询当前数据表记录状态 */
  102.         $result = mysql_query('SELECT id, age FROM ' . TB, $link_id);
  103.         print_result($result, '例2，初始状态');

  105.         /* 创建事务 */
  106.         mysql_query('START TRANSACTION', $link_id) or exit(mysql_error());

  108.         /* 提交 SQL */
  109.         for($i = 0; $i < count($SQL); $i++) {
  110.                 mysql_query($SQL[$i], $link_id);
  111.         }

  113.         /* 查询当前数据表记录状态 */
  114.         $result = mysql_query('SELECT id, age FROM ' . TB, $link_id);
  115.         print_result($result, '此状态仅在该事务中可见');

  117.         /* 提交事务 */
  118.         mysql_query('COMMIT', $link_id) or exit(mysql_error());

  120.         /* 查询当前数据表记录状态 */
  121.         $result = mysql_query('SELECT id, age FROM ' . TB, $link_id);
  122.         print_result($result, '提交事务，数据表最终状态');


  125.         /*********************
  126.         * 例3
  127.         * 如果 SQL 执行过程中有错误发生的情形（数据应该被回卷）
  128.         *********************/

  130.         /* 查询当前数据表记录状态 */
  131.         $result = mysql_query('SELECT id, age FROM ' . TB, $link_id);
  132.         print_result($result, '例3，初始状态');

  134.         /* 创建事务 */
  135.         mysql_query('START TRANSACTION', $link_id) or exit(mysql_error());

  137.         /*
  138.         * 提交 SQL
  139.         * 人为添加一条错误的 SQL
  140.         */
  141.         $SQL[] = 'INSERT INTO ' . TB . ' (sex) VALUES (100)'; // 数据表中并无 sex 字段
  142.         for($i = 0; $i < count($SQL); $i++) {
  143.                 if(! mysql_query($SQL[$i], $link_id)) {
  144.                         /*
  145.                         * 按理每次更新查询都应该进行判断，前两个例子都没做处理。
  146.                         * 若 SQL 执行出错，回卷本次事务操作。
  147.                         */
  148.                         $err_msg = mysql_error();

  150.                         mysql_query('ROLLBACK', $link_id) or exit(mysql_error());

  152.                         /* 查询当前数据表记录状态 */
  153.                         $result = mysql_query('SELECT id, age FROM ' . TB, $link_id);
  154.                         print_result($result, '错误：' . $err_msg . '。回卷事务，数据表最终状态');

  156.                         html_footer();
  157.                         exit();
  158.                 }
  159.         }

  161.         /*
  162.         * 若上面执行无错误发生，则会运行到此。
  163.         * 提交事务
  164.         */
  165.         mysql_query('COMMIT', $link_id) or exit(mysql_error());

  167.         /* 查询当前数据表记录状态 */
  168.         $result = mysql_query('SELECT id, age FROM ' . TB, $link_id);
  169.         print_result($result, '提交事务，数据表最终状态');
  170.         html_footer();
  171. ?>
复制代码


以上是事务的基础应用，更多关于事务特性的资料，要么看 MySQL 手册(主要在 InnoDB 手册)，要么找本数据库系统理论方面的书籍去看。
实战分享：从技术角度谈机器学习入门| 【大话IT】RadonDB低门槛向MySQL集群下战书 | ChinaUnix打赏功能已上线！ | 新一代分布式关系型数据库RadonDB知多少？
返回列表 发新帖
高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 注册

本版积分规则 发表回复

  

北京盛拓优讯信息技术有限公司. 版权所有 京ICP备16024965号-6 北京市公安局海淀分局网监中心备案编号：11010802020122 niuxiaotong@pcpop.com 17352615567
未成年举报专区
中国互联网协会会员  联系我们：huangweiwei@itpub.net
感谢所有关心和支持过ChinaUnix的朋友们 转载本站内容请注明原作者名及出处

清除 Cookies - ChinaUnix - Archiver - WAP - TOP