add check index and some other ddl type

ddl/ddl.go

@@ -88,8 +88,12 @@ func (c *DDLCase) Execute(ctx context.Context, dbss [][]*sql.DB, exeDDLFunc Exec
 							disableTiKVGC(db)
 						}
 					}
-					// os.Exit(-1)
-					log.Fatalf("[error] [instance %d] ERROR: %s", i, errors.ErrorStack(err))
+					if Chaos {
+						log.Warnf("[error] [instance %d] ERROR: %s", i, errors.ErrorStack(err))
+					} else {
+						// os.Exit(-1)
+						log.Fatalf("[error] [instance %d] ERROR: %s", i, errors.ErrorStack(err))
+					}
 				}
 			}
 		}(i)
@@ -149,14 +153,15 @@ func NewDDLCase(cfg *DDLCaseConfig) *DDLCase {
 	cases := make([]*testCase, cfg.Concurrency)
 	for i := 0; i < cfg.Concurrency; i++ {
 		cases[i] = &testCase{
-			cfg:       cfg,
-			tables:    make(map[string]*ddlTestTable),
-			schemas:   make(map[string]*ddlTestSchema),
-			views:     make(map[string]*ddlTestView),
-			ddlOps:    make([]ddlTestOpExecutor, 0),
-			dmlOps:    make([]dmlTestOpExecutor, 0),
-			caseIndex: i,
-			stop:      0,
+			cfg:               cfg,
+			tables:            make(map[string]*ddlTestTable),
+			schemas:           make(map[string]*ddlTestSchema),
+			views:             make(map[string]*ddlTestView),
+			placementPolicies: map[string]*ddlTestPlacementPolicy{},
+			ddlOps:            make([]ddlTestOpExecutor, 0),
+			dmlOps:            make([]dmlTestOpExecutor, 0),
+			caseIndex:         i,
+			stop:              0,
 		}
 	}
 	b := &DDLCase{
@@ -417,8 +422,7 @@ func (c *testCase) execute(ctx context.Context, executeDDL ExecuteDDLFunc, exeDM
 	log.Infof("[ddl] [instance %d] Executing post round operations...", c.caseIndex)
 
 	if !c.cfg.MySQLCompatible {
-		err := c.executeAdminCheck()
-		if err != nil {
+		if err := c.executeAdminCheck(); err != nil {
 			return errors.Trace(err)
 		}
 	}
@@ -601,6 +605,8 @@ func (c *testCase) executeAdminCheck() error {
 		return nil
 	}
 
+	c.tablesLock.Lock()
+	defer c.tablesLock.Unlock()
 	// build SQL
 	sql := "ADMIN CHECK TABLE "
 	i := 0
@@ -610,6 +616,16 @@ func (c *testCase) executeAdminCheck() error {
 		}
 		sql += fmt.Sprintf("`%s`", table.name)
 		i++
+		for _, index := range table.indexes {
+			checkIndexSQL := fmt.Sprintf("admin check index `%s` `%s`", table.name, index.name)
+			_, err := c.pickupDB().Exec(checkIndexSQL)
+			if ddlIgnoreError(err) {
+				continue
+			}
+			if err != nil {
+				return errors.Annotatef(err, "Error when executing SQL: %s", checkIndexSQL)
+			}
+		}
 	}
 	dbIdx := rand.Intn(len(c.dbs))
 	db := c.dbs[dbIdx]