(t table.Table, sctx sessionctx.Context)
| 194 | } |
| 195 | |
| 196 | func makeRowDecoder(t table.Table, sctx sessionctx.Context) (*decoder.RowDecoder, error) { |
| 197 | dbName := model.NewCIStr(sctx.GetSessionVars().CurrentDB) |
| 198 | exprCols, _, err := expression.ColumnInfos2ColumnsAndNames(sctx.GetExprCtx(), dbName, t.Meta().Name, t.Meta().Cols(), t.Meta()) |
| 199 | if err != nil { |
| 200 | return nil, err |
| 201 | } |
| 202 | mockSchema := expression.NewSchema(exprCols...) |
| 203 | decodeColsMap := decoder.BuildFullDecodeColMap(t.Cols(), mockSchema) |
| 204 | |
| 205 | return decoder.NewRowDecoder(t, t.Cols(), decodeColsMap), nil |
| 206 | } |
| 207 | |
| 208 | func iterRecords(sessCtx sessionctx.Context, retriever kv.Retriever, t table.Table, startKey kv.Key, cols []*table.Column, isGlobalIndex bool, fn table.RecordIterFunc) error { |
| 209 | prefix := t.RecordPrefix() |
no test coverage detected