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

云溪数据库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)
            }
        }
    }