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