skip for the deleted temp key

pingcap · Dec 14, 2022 · 9ee3303 · 9ee3303
1 parent ba41383
commit 9ee3303
Show file tree

Hide file tree

Showing 3 changed files with 7 additions and 1 deletion.
diff --git a/executor/insert.go b/executor/insert.go
@@ -159,6 +159,9 @@ func prefetchConflictedOldRows(ctx context.Context, txn kv.Transaction, rows []t
 		for _, uk := range r.uniqueKeys {
 			if val, found := values[string(uk.newKey)]; found {
 				if tablecodec.IsTempIndexKey(uk.newKey) {
+					if tablecodec.CheckTempIndexValueIsDelete(val) {
+						continue
+					}
 					val = tablecodec.DecodeTempIndexOriginValue(val)
 				}
 				handle, err := tablecodec.DecodeHandleInUniqueIndexValue(val, uk.commonHandle)

diff --git a/executor/replace.go b/executor/replace.go
@@ -180,6 +180,9 @@ func (e *ReplaceExec) removeIndexRow(ctx context.Context, txn kv.Transaction, r
 			return false, false, err
 		}
 		if tablecodec.IsTempIndexKey(uk.newKey) {
+			if tablecodec.CheckTempIndexValueIsDelete(val) {
+				continue
+			}
 			val = tablecodec.DecodeTempIndexOriginValue(val)
 		}
 		handle, err := tablecodec.DecodeHandleInUniqueIndexValue(val, uk.commonHandle)

diff --git a/table/tables/index.go b/table/tables/index.go
@@ -225,7 +225,7 @@ func (c *index) Create(sctx sessionctx.Context, txn kv.Transaction, indexedValue
 	if err != nil && !kv.IsErrNotFound(err) {
 		return nil, err
 	}
-	if err != nil || len(value) == 0 {
+	if err != nil || len(value) == 0 || (keyIsTempIdxKey && tablecodec.CheckTempIndexValueIsDelete(value)) {
 		lazyCheck := sctx.GetSessionVars().LazyCheckKeyNotExists() && err != nil
 		var needPresumeKey TempIndexKeyState
 		if keyIsTempIdxKey {