add ErrIncorrectIndexCount

Signed-off-by: ekexium <ekexium@gmail.com>

errno/errcode.go

@@ -1011,6 +1011,7 @@ const (
 	ErrAsOf                                = 8135
 	ErrVariableNoLongerSupported           = 8136
 	ErrAnalyzeMissColumn                   = 8137
+	ErrIncorrectIndexCount                 = 8140
 
 	// Error codes used by TiDB ddl package
 	ErrUnsupportedDDLOperation            = 8200

errno/errname.go

@@ -1009,6 +1009,7 @@ var MySQLErrName = map[uint16]*mysql.ErrMessage{
 	ErrInvalidIncrementAndOffset:     mysql.Message("Invalid auto_increment settings: auto_increment_increment: %d, auto_increment_offset: %d, both of them must be in range [1..65535]", nil),
 	ErrDataInconsistentMismatchCount: mysql.Message("data inconsistency in table: %s, index: %s, index-count:%d != record-count:%d", nil),
 	ErrDataInconsistentMismatchIndex: mysql.Message("data inconsistency in table: %s, index: %s, col: %s, handle: %#v, index-values:%#v != record-values:%#v, compare err:%#v", []int{3, 4, 5, 6}),
+	ErrIncorrectIndexCount:           mysql.Message("incorrect index count in txn, row insertions: %d, index insertions: %d", nil),
 
 	ErrWarnOptimizerHintInvalidInteger:  mysql.Message("integer value is out of range in '%s'", nil),
 	ErrWarnOptimizerHintUnsupportedHint: mysql.Message("Optimizer hint %s is not supported by TiDB and is ignored", nil),

errors.toml

@@ -1801,6 +1801,11 @@ error = '''
 column %s can't be in none state
 '''
 
+["table:8140"]
+error = '''
+incorrect index count in txn, row insertions: %d, index insertions: %d
+'''
+
 ["tikv:1105"]
 error = '''
 Unknown error

session/session.go

@@ -73,8 +73,8 @@ import (
 	"github.com/pingcap/tidb/sessionctx/variable"
 	"github.com/pingcap/tidb/statistics"
 	"github.com/pingcap/tidb/statistics/handle"
-	"github.com/pingcap/tidb/table/tables"
 	storeerr "github.com/pingcap/tidb/store/driver/error"
+	"github.com/pingcap/tidb/table/tables"
 	"github.com/pingcap/tidb/tablecodec"
 	"github.com/pingcap/tidb/telemetry"
 	"github.com/pingcap/tidb/types"
@@ -89,12 +89,9 @@ import (
 	"github.com/pingcap/tidb/util/sqlexec"
 	"github.com/pingcap/tidb/util/tableutil"
 	"github.com/pingcap/tidb/util/timeutil"
-	"github.com/pingcap/tidb/util/topsql"
-	"github.com/pingcap/tipb/go-binlog"
 	tikvstore "github.com/tikv/client-go/v2/kv"
 	"github.com/tikv/client-go/v2/tikv"
 	tikvutil "github.com/tikv/client-go/v2/util"
-	"go.uber.org/zap"
 )
 
 var (

table/tables/mutation_checker.go

@@ -18,18 +18,23 @@ import (
 	"fmt"
 
 	"github.com/pingcap/errors"
+	"github.com/pingcap/tidb/errno"
 	"github.com/pingcap/tidb/kv"
 	"github.com/pingcap/tidb/parser/model"
 	"github.com/pingcap/tidb/sessionctx/stmtctx"
 	"github.com/pingcap/tidb/sessionctx/variable"
 	"github.com/pingcap/tidb/table"
 	"github.com/pingcap/tidb/tablecodec"
 	"github.com/pingcap/tidb/types"
+	"github.com/pingcap/tidb/util/dbterror"
 	"github.com/pingcap/tidb/util/logutil"
 	"github.com/pingcap/tidb/util/rowcodec"
 	"go.uber.org/zap"
 )
 
+// ErrIncorrectIndexCount indicates that #(index_insertion) is not a multiple of #(row_insertion).
+var ErrIncorrectIndexCount = dbterror.ClassTable.NewStd(errno.ErrIncorrectIndexCount)
+
 type mutation struct {
 	key     kv.Key
 	flags   kv.KeyFlags
@@ -404,8 +409,7 @@ func CheckTxnConsistency(txn kv.Transaction) error {
 	for tableID, count := range indexInsertionCount {
 		// TODO: always? what if like backfilling?
 		if rowInsertionCount[tableID] > 0 && count%rowInsertionCount[tableID] != 0 {
-			return errors.Errorf("inconsistent index insertion count %d and row insertion count %d",
-				count, rowInsertionCount[tableID])
+			return ErrIncorrectIndexCount.GenWithStackByArgs(count, rowInsertionCount[tableID])
 		}
 	}
 	return nil