共计 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)
}
}
}