(ctx context.Context, txn kv.Transaction, rows []toBeCheckedRow)
| 180 | } |
| 181 | |
| 182 | func (e *InsertValues) prefetchDataCache(ctx context.Context, txn kv.Transaction, rows []toBeCheckedRow) error { |
| 183 | // Temporary table need not to do prefetch because its all data are stored in the memory. |
| 184 | if e.Table.Meta().TempTableType != model.TempTableNone { |
| 185 | return nil |
| 186 | } |
| 187 | |
| 188 | defer tracing.StartRegion(ctx, "prefetchDataCache").End() |
| 189 | values, err := prefetchUniqueIndices(ctx, txn, rows) |
| 190 | if err != nil { |
| 191 | return err |
| 192 | } |
| 193 | return prefetchConflictedOldRows(ctx, txn, rows, values) |
| 194 | } |
| 195 | |
| 196 | // updateDupRow updates a duplicate row to a new row. |
| 197 | func (e *InsertExec) updateDupRow( |
no test coverage detected