MySQL事务之数据结构

事务是关系型数据库的核心,贯穿整个源代码,先来瞅瞅相关的数据结构,揭开面纱:

server层和innodb引擎层分别对应了不同的数据结构,但相互关联:

  1. server层需要引擎注册事务,以便server层能够引用。
  2. innodb层需要维持事务的状态,以及事务的状态转换的具体实现。

1. 相关数据结构

下面用一个简略图描述server和innodb的事务交互:

  

简单描述一下:

  server层通过stmt和all链表关联了所有参与事务的引擎。 每一个connection,在innodb引擎分配一个trx结构,维持到会话结束。

  无论一个事务有几条语句,有多少参与的table, 一个引擎只注册一次,因为一个session当前只有一个活动事务。server通过注册的引擎,通知引擎完成事务相关的操作。

相关的数据结构:

THD_TRANS
Ha_data
Ha_trx_info
trx_sys_struct
trx_struct

具体可以参考源码。

2.  事务如何开始

  测试: select * from t

    t表的引擎是innodb

1. 首次连接

  第一次连接,创建THD对象时,初始ha_data[MAX_HA]数组,但并为完成引擎的初始化。

  thd->transaction.stmt/all都为空。

2. 创建trx: 对应于每一个连接,表示连接的事务上下文

  当语句执行的时候,创建innodb的trx结构,对应ha_data[8].ha_ptr.

函数调用栈:

  ha_innobase::store_lock

    check_trx_exists
      innobase_trx_allocate
        trx_allocate_for_mysql:
          1. trx_create: 创建trx结构
          2. 递增trx_n_mysql_transactions全局计数
          3. 加入全局链表trx_sys->mysql_trx_list
        innobase_trx_init

          初始化 trx跟当前server 层thd关联

注:执行语句的过程中,轮询语句的所有table,在get_table_lock的过程分配trx,因为事务和锁是相关的。所有事务相关的注册等都和table_lock的过程紧密在一起。

3. 注册参与事务的引擎到thd->transaction

   ha_info->is_started()如果ha_info已经和引擎关联,那么说明这个事务已经开始,注册过了。

  这里要分两种情况:

  1. 如果autocommit=0

    innodb引擎需要注册stmt,all两个链表

  2. 如果autocommit=1

    innodb引擎只需要注册stmt链表即可

注册后的结果是:

(gdb) p thd->transaction.all.ha_list.m_ht.db_type
$66 = DB_TYPE_INNODB

4. 事务提交

  如果autocommit=0 ,在事务提交时:

  释放锁:

    ha_innobase::external_lock

      trx->n_mysql_tables_in_use--; 释放table lock的过程中,清理trx结构

  提交:

    trans_commit_stmt
      if(thd->transaction.stmt.ha_list)
        ha_commit_trans(thd, FALSE);

        thd->transaction.stmt.reset();  重置stmt链表
        commit_one_phase_low;    重置ha_trx_info为没有使用状态。

这里仅仅是事务的开始,未完待续......

MySQL事务之数据结构

时间: 2024-10-28 20:23:18

MySQL事务之数据结构的相关文章

sql点滴42—mysql中的数据结构

MySQL 的数值数据类型可以大致划分为两个类别,一个是整数,另一个是浮点数或小数.许多不同的子类型对这些类别中的每一个都是可用的,每个子类型支持不同大小的数据,并且 MySQL 允许我们指定数值字段中的值是否有正负之分或者用零填补. 表列出了各种数值类型以及它们的允许范围和占用的内存空间. 类型 大小 范围(有符号) 范围(无符号) 用途 TINYINT 1 字节 (-128,127) (0,255) 小整数值 SMALLINT 2 字节 (-32 768,32 767) (0,65 535)

MySQL事务四个隔离级别

MySQL事务隔离级别详解             MySQL数据结构SQL SQL标准定义了4类隔离级别,包括了一些具体规则,用来限定事务内外的哪些改变是可见的,哪些是不可见的.低级别的隔离级一般支持更高的并发处理,并拥有更低的系统开销. Read Uncommitted (读取未提交的内容)  在该隔离级别,所有事务都可以看到其他未提交事务的执行结果.本隔离级别很少用于实际应用,因为它的性能也不比其他级别好多少.读取未提交的数据,也被称之为脏读(Dirty Read).Read Commit

数据库-mysql事务

MySQL 事务 MySQL 事务主要用于处理操作量大,复杂度高的数据.比如说,在人员管理系统中,你删除一个人员,你即需要删除人员的基本资料,也要删除和该人员相关的信息,如信箱,文章等等,这样,这些数据库操作语句就构成一个事务! 在 MySQL 中只有使用了 Innodb 数据库引擎的数据库或表才支持事务. 事务处理可以用来维护数据库的完整性,保证成批的 SQL 语句要么全部执行,要么全部不执行. 事务用来管理 insert,update,delete 语句 一般来说,事务是必须满足4个条件(A

MySQL 事务

MySQL 事务 MySQL 事务主要用于处理操作量大,复杂度高的数据.比如说,在人员管理系统中,你删除一个人员,你即需要删除人员的基本资料,也要删除和该人员相关的信息,如信箱,文章等等,这样,这些数据库操作语句就构成一个事务! 在 MySQL 中只有使用了 Innodb 数据库引擎的数据库或表才支持事务. 事务处理可以用来维护数据库的完整性,保证成批的 SQL 语句要么全部执行,要么全部不执行. 事务用来管理 insert,update,delete 语句 一般来说,事务是必须满足4个条件(A

MySQL事务详解

事务:Transaction 多个sql语句,要么同时都执行,要么同时都不执行 事务就是一组原子性的(select)查询语句,也即将多个查询当作一个独立的工作单元 ACID测试:能够满足ACID测试就表示其支持事务,或兼容事务 A:Atomicity,原子性,都执行或者都不执行 C:Consistency,一致性,从一个一致性状态转到另外一个一致性状态 I:Isolaction,隔离性.一个事务的所有修改操作在提交前对其他事务是不可见的 D: Durability, 持久性,一旦事务得到提交,其

Mysql事务&字符集

Mysql事务 Innodb存储引擎的中的事务完全服务ACID: 原子性.2.一致性.3.隔离性.4.持久性 理解上和oracle类似. 事务隔离级别 1.Read uncommitted 读未提交: 2.Read committed 读已提交: 3.Repeatable read 可重复读,类似oracle利用undo的闪回查询: 4.Serializable 串行读,很少用. 隔离级别的修改: 通过set命令: 通过修改配置文件,启动数据库的默认隔离级别-mysqld Mysql字符集 My

MYSQL事务及存储引擎对比

Innodb支持事务,而myisam不支持事务. 事务的定义: 当多个用户访问同一份数据时,一个用户在更改数据的过程中可能有其他用户同时发起更改请求,为保证数据的更新从一个一致性状态变更为另一个一致性状态,这时有必要引入事务的概念. Mysql提供了多种引擎支持Innodb和BDB.Innodb存储引擎事务主要通过UNDO日志和REDO日志实现,Myisam和memory引擎则不支持事务.下图分别给出三种mysql引擎的区别和特性: Myisam存储引擎:由于该引擎不支持事务.也不支持外键,所以

十、mysql事务的简介

1. myisam跟memory支持表级别锁定 BDB 页级锁定 Innodb 行级锁定 2.表锁(不是表嫂哈) lock table read //只读表锁,也就是说执行了这个锁后,锁内的操作只能为读操作 select * from ..... unlock tables; lock table write //读写表锁,可读可写 insert ... update ... select ... delete ... unlock tables; PS::表被锁定后,其他连接的操作将被挂起,直

查询mysql事务隔离级别

查询mysql事务隔离级别 查询mysql事务隔离级别 分类: DB2011-11-26 13:12 2517人阅读 评论(0) 收藏 举报 mysqlsessionjava 1.查看当前会话隔离级别 select @@tx_isolation; 2.查看系统当前隔离级别 select @@global.tx_isolation; 3.设置当前会话隔离级别 set session transaction isolatin level repeatable read; 4.设置系统当前隔离级别 s