关于mysql:云溪数据库delete流程解读

55次阅读

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

云溪数据库 delete 语句 delete from table where xxx 的执行流程为:

delete 次要分为两个局部,一个局部为 scan 过程,拉取表中的数据,第二局部,依据过滤条件,调用 b.Del() 函数删除对应的数据。相干逻辑打算对象图为:

deleteNode 下蕴含一个 scanNode,负责拉取表中数据,deleteRun 包含理论执行 delete 操作的信息,包含表中数据的索引信息,事务相干信息 txn,batch…,还有 tabledesc 等等信息。

其中在构建逻辑打算时,有一个 maybeCreateDeleteFastNode 函数,来判断是否能够执行 deleterange 操作,判断条件为:

1. 表中是否具备索引,如果有,不能够执行 deleterange

2. 该表是否为交织表,如果是,不能够执行 deleterange

3. 该表主键是否关联了其余表的外键,如果是,不能够执行 deleterange

4.renderNode 下是否为 scanNode,如果不是,不能够执行 deleterange

5. 过滤条件没有被下推为 span,不能够执行 deleterange

6. 有 limit 关键字时,不能够执行 deleterange

在满足以上过滤条件后,如果能够执行 deleterange,就会把其中的 deleteNode 转化为 deleteRangeNode,在执行时,rowCountNode 的 startExec 会间接调用到 deleteRangeNode 的 startExec,通过间接下发对 span 的 DelRange 操作来删除数据,不会调用到 BatchNext 中。

deleteRange 过程局部代码:

spans := make([]roachpb.Span, len(d.spans))
    copy(spans, d.spans)
    for len(spans) != 0 {b := params.p.txn.NewBatch()
        for _, span := range spans {
            if traceKV {log.VEventf(ctx, 2, "DelRange %s - %s", span.Key, span.EndKey)
            }
            b.DelRange(span.Key, span.EndKey, true /* returnKeys */)
        }
        b.Header.MaxSpanRequestKeys = TableTruncateChunkSize
 
        if err := params.p.txn.Run(ctx, b); err != nil {return err}
 
        spans = spans[:0]
        for _, r := range b.Results {var prev []byte
            for _, keyBytes := range r.Keys {
                // If prefix is same, don't bother decoding key.
                if len(prev) > 0 && bytes.HasPrefix(keyBytes, prev) {continue}
 
                after, ok, err := d.fetcher.ReadIndexKey(keyBytes)
                if err != nil {return err}
                if !ok {return pgerror.NewAssertionErrorf("key did not match descriptor")
                }
                k := keyBytes[:len(keyBytes)-len(after)]
                if !bytes.Equal(k, prev) {
                    prev = k
                    d.rowCount++
                }
            }
            if r.ResumeSpan != nil && r.ResumeSpan.Valid() {spans = append(spans, *r.ResumeSpan)
            }
        }
    }

正文完
 0