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