如何在mysql中事务处理

41次阅读
没有评论

共计 6036 个字符,预计需要花费 16 分钟才能阅读完成。

自动写代码机器人,免费开通

如何在 mysql 中事务处理?相信很多没有经验的人对此束手无策,为此本文总结了问题出现的原因和解决方法,通过这篇文章希望你能解决这个问题。

事务的特性: 

事务有以下四个标准属性的缩写 ACID,通常被称为:

原子性: 确保工作单元内的所有操作都成功完成,否则事务将被中止在故障点,和以前的操作将回滚到以前的状态。

一致性: 确保数据库正确地改变状态后,成功提交的事务。

隔离性: 使事务操作彼此独立的和透明的。

持久性: 确保提交的事务的结果或效果的系统出现故障的情况下仍然存在。

在 MySQL 中,事务开始使用 COMMITROLLBACK语句开始工作和结束。开始和结束语句的 SQL 命令之间形成了大量的事务。

COMMIT ROLLBACK:

这两个关键字提交和回滚主要用于 MySQL 的事务。

当一个成功的事务完成后,发出 COMMIT 命令应使所有参与表的更改才会生效。

如果发生故障时,应发出一个 ROLLBACK 命令返回的事务中引用的每一个表到以前的状态。

可以控制的事务行为称为 AUTOCOMMIT设置会话变量。如果 AUTOCOMMIT设置为 1(默认值),然后每一个 SQL 语句(在事务与否)被认为是一个完整的事务,并承诺在默认情况下,当它完成。AUTOCOMMIT设置为 0 时,发出 SET AUTOCOMMIT = 0 命令,在随后的一系列语句的作用就像一个事务,直到一个明确的 COMMIT 语句时,没有活动的提交。

可以通过使用 mysql_query()函数在 PHP 中执行这些 SQL 命令。

通用事务例子

这一系列事件是独立于所使用的编程语言,可以建立在任何使用的语言来创建应用程序的逻辑路径。

可以通过使用 mysql_query()函数在 PHP 中执行这些 SQL 命令。

BEGIN WORK 开始事务发出 SQL 命令

发出一个或多个 SQL 命令,如 SELECT,INSERT,UPDATE 或 DELETE

检查是否有任何错误,一切都依据的需要。

如果有任何错误,那么问题 ROLLBACK 命令,否则发出 COMMIT 命令。

在 MySQL 中的事务安全表类型:

如果打算使用 MySQL 事务编程,那么就需要一种特殊的方式创建表。有很多支持事务但最流行的是 InnoDB 表类型。

从源代码编译 MySQL 时,InnoDB 表支持需要特定的编译参数。如果 MySQL 版本没有 InnoDB 支持,请互联网服务提供商建立一个版本的 MySQL 支持 InnoDB 表类型,或者下载并安装 Windows 或 Linux/UNIX 的 MySQL-Max 二进制分发和使用的表类型在开发环境中。

如果 MySQL 安装支持 InnoDB 表,只需添加一个的 TYPE=InnoDB 定义表创建语句。例如,下面的代码创建 InnoDB 表 tcount_tbl:

root@host# mysql -u root -p password;
Enter password:*******
mysql  use TUTORIALS;
Database changed
mysql  create table tcount_tbl
 -  ( -  tutorial_author varchar(40) NOT NULL,
 -  tutorial_count INT
 -  ) TYPE=InnoDB;
Query OK, 0 rows affected (0.05 sec)

可以使用其他 GEMINI 或 BDB 表类型,但它取决于您的安装,如果它支持这两种类型。

由于项目设计里面,牵扯到了金钱的转移,于是就要用到 MYSQL 的事务处理,来保证一组处理结果的正确性。用了事务,就不可避免的要牺牲一部分速度,来保证数据的正确性。

只有 InnoDB 支持事务

事务 ACID Atomicity(原子性)、Consistency(稳定性)、Isolation(隔离性)、Durability(可靠性)

1、事务的原子性
一组事务,要么成功;要么撤回。

2、稳定性
有非法数据(外键约束之类),事务撤回。

3、隔离性
事务独立运行。
一个事务处理后的结果,影响了其他事务,那么其他事务会撤回。
事务的 100% 隔离,需要牺牲速度。

4、可靠性
软、硬件崩溃后,InnoDB 数据表驱动会利用日志文件重构修改。
可靠性和高速度不可兼得,innodb_flush_log_at_trx_commit 选项 决定什么时候吧事务保存到日志里。

开启事务

START TRANSACTION  或  BEGIN

提交事务(关闭事务)

COMMIT

放弃事务(关闭事务)

ROLLBACK

折返点

SAVEPOINT adqoo_1
ROLLBACK TO SAVEPOINT adqoo_1

发生在折返点 adqoo_1 之前的事务被提交,之后的被忽略

事务的终止

设置“自动提交”模式
SET AUTOCOMMIT = 0
每条 SQL 都是同一个事务的不同命令,之间由 COMMITROLLBACK隔开
掉线后,没有 COMMIT 的事务都被放弃

事务锁定模式

系统默认:不需要等待某事务结束,可直接查询到结果,但不能再进行修改、删除。
缺点:查询到的结果,可能是已经过期的。
优点:不需要等待某事务结束,可直接查询到结果。

需要用以下模式来设定锁定模式

1、SELECT …… LOCK IN SHARE MODE(共享锁)
查询到的数据,就是数据库在这一时刻的数据(其他已 commit 事务的结果,已经反应到这里了)
SELECT 必须等待,某个事务结束后才能执行

2、SELECT …… FOR UPDATE(排它锁)
例如 SELECT * FROM tablename WHERE id 200
那么 id 200 的数据,被查询到的数据,都将不能再进行修改、删除、SELECT …… LOCK IN SHARE MODE 操作
一直到此事务结束
共享锁 和 排它锁 的区别:在于是否阻断其他客户发出的 SELECT …… LOCK IN SHARE MODE 命令

3、INSERT / UPDATE / DELETE
所有关联数据都会被锁定,加上排它锁

4、防插入锁
例如 SELECT * FROM tablename WHERE id 200
那么 id 200 的记录无法被插入

5、死锁
自动识别死锁
先进来的进程被执行,后来的进程收到出错消息,并按 ROLLBACK 方式回滚
innodb_lock_wait_timeout = n 来设置最长等待时间,默认是 50 秒

事务隔离模式

SET [SESSION|GLOBAL] TRANSACTION ISOLATION LEVEL
READ UNCOMMITTED | READ COMMITTED | REPEATABLE READ | SERIALIZABLE

1、不带 SESSION、GLOBAL 的 SET 命令
只对下一个事务有效

2、SET SESSION
为当前会话设置隔离模式

3、SET GLOBAL
为以后新建的所有 MYSQL 连接设置隔离模式(当前连接不包括在内)
隔离模式
  READ UNCOMMITTED
不隔离 SELECT
其他事务未完成的修改(未 COMMIT),其结果也考虑在内
  READ COMMITTED
把其他事务的 COMMIT 修改考虑在内
同一个事务中,同一 SELECT 可能返回不同结果
  REPEATABLE READ(默认)
不把其他事务的修改考虑在内,无论其他事务是否用 COMMIT 命令提交过
同一个事务中,同一 SELECT 返回同一结果(前提是本事务,不修改)
  SERIALIZABLE
和 REPEATABLE READ 类似,给所有的 SELECT 都加上了 共享锁

出错处理

根据出错信息,执行相应的处理

mysql 事物处理实例

MYSQL 的事务处理主要有两种方法

1. 用 begin,rollback,commit 来实现

begin 开始一个事务

rollback 事务回滚

commit 事务确认

2. 直接用 set 来改变 mysql 的自动提交模式

mysql 默认是自动提交的,也就是你提交一个 query,就直接执行!可以通过

set autocommit = 0 禁止自动提交

set autocommit = 1 开启自动提交

来实现事务的处理。

但要注意当用 set autocommit = 0 的时候,你以后所有的 sql 都将作为事务处理,直到你用 commit 确认或 rollback 结束,注意当你结束这个事务的同时也开启了新的事务!按第一种方法只将当前的做为一个事务!

MYSQL 只有 INNODB 和 BDB 类型的数据表才支持事务处理,其他的类型是不支持的!

mysql  use test;
 Database changed
 mysql  CREATE TABLE `dbtest`( -  id int(4)
 -  ) TYPE=INNODB;
Query OK, 0 rows affected, 1 warning (0.05 sec)
mysql  select * from dbtest
 -  ;
Empty set (0.01 sec)
mysql  begin;
Query OK, 0 rows affected (0.00 sec)
mysql  insert into dbtest values(5);
Query OK, 1 row affected (0.00 sec)
mysql  insert into dbtest value(6);
Query OK, 1 row affected (0.00 sec)
mysql  commit;
Query OK, 0 rows affected (0.00 sec)
mysql  select * from dbtest;
+------+
| id |
+------+
| 5 |
| 6 |
+------+
2 rows in set (0.00 sec)
mysql  begin;
Query OK, 0 rows affected (0.00 sec)
mysql  insert into dbtest values(7);
Query OK, 1 row affected (0.00 sec)
mysql  rollback;
Query OK, 0 rows affected (0.00 sec)
mysql  select * from dbtest;
+------+
| id |
+------+
| 5 |
| 6 |
+------+
2 rows in set (0.00 sec)

mysql 事务处理

php 代码实现事务的处理可以通过 PHP 预定义类 mysqli 的以下方法实现。

autocommit(boolean):该方法用于限定查询结果是否自动提交,如果该方法的参数为 true 则自动提交,如果参数为 false 则关闭自动提交。MySQL 数据库默认为自动提交。

rollback():利用 mysqli 类中的该方法可以实现事务的回滚。

commit():利用该方法可以实现提交所有查询。

?php
include_once( conn.php 
$id=$_GET[id];
$conn- autocommit(false);
if(!$conn- query( delete from tb_sco where id= .$id.))
 $conn- rollback();
if(!$conn- query( delete from tb_stu where id= .$id.))
 $conn- rollback();
 $conn- commit();
 $conn- autocommit(true);
 echo  ok 
?
 ?php
require( connectDB.php  // 建立数据库连接
mssql_query( BEGIN TRANSACTION DEPS02_DEL  // 开始事务
$delete_dep_sql= DELETE FROM TBLDEPARTMENT WHERE DEPTID= {$_GET[deptid]} 
// echo $delete_dep_sql. br 
mssql_query($delete_dep_sql); // 操作数据库
// var_dump($del_result);
$delete_result = mssql_query( select @@ROWCOUNT as id 
$delete_info = mssql_fetch_array($delete_result);
$delete_rows = $delete_info[0];
// var_dump($delete_rows);
mssql_free_result($delete_result);
echo  script language=javascript 
if(true){ // 判断是否回滚提交
mssql_query(COMMIT TRANSACTION DEPS02_DEL  // 提交事务
echo  alert(delete success!}else{mssql_query( ROLLBACK TRANSACTION DEPS02_DEL  // 回滚事务
echo  alert( delete faile! 
echo  /script mssql_close();
? 

MySQL 的事务处理在处理实际问题中有着广泛且重要的应用,最常见的应用如银行转账业务、电子商务支付业务等等。但是,值得注意的是,MySQL 的事务处理功能在 MYSIAM 存储引擎中是不支持的,在 InnoDB 存储引擎中是支持的。现在上传一段代码,作为引导认识 MySQL 事务处理的开始,简单的实例,但融汇思想,相信会有很大的帮助。

 ?php
$conn=mysql_connect(localhost , root , yourpassword)or die(mysql_error());
mysql_select_db(transaction ,$conn);
mysql_query( set names utf8 
// 创建事务
mysql_query(START TRANSACTION) or die(mysql_error());
$sqlA= update A set account=account-1 
if(!mysql_query($sqlA)){nbsp; nbsp; nbsp; mysql_query( ROLLBACK ) or exit(mysql_error());// 判断当执行失败时回滚
 nbsp; exit();
$sqlB= update B set account=account+1 
if(!mysql_query($sqlB)){nbsp; nbsp; nbsp; mysql_query( ROLLBACK ) or exit(mysql_error());// 判断当执行失败时回滚
 nbsp; exit();
mysql_query(COMMIT )or die(mysql_error());// 执行事务
mysql_close($conn);
? 

看完上述内容,你们掌握如何在 mysql 中事务处理的方法了吗?如果还想学到更多技能或想了解更多相关内容,欢迎关注丸趣 TV 行业资讯频道,感谢各位的阅读!

向 AI 问一下细节

正文完
 
丸趣
版权声明:本站原创文章,由 丸趣 2023-12-04发表,共计6036字。
转载说明:除特殊说明外本站除技术相关以外文章皆由网络搜集发布,转载请注明出处。
评论(没有评论)