Function tidbCreateTable

backend/plugin/schema/tidb/walk_through.go:936–1025

(d *model.DatabaseMetadata, node *tidbast.CreateTableStmt)

}

func tidbCreateTable(d *model.DatabaseMetadata, node *tidbast.CreateTableStmt) *storepb.Advice {
	if node.Table.Schema.O != "" && !isCurrentDatabase(d, node.Table.Schema.O) {
		content := fmt.Sprintf("Database `%s` is not the current database `%s`", node.Table.Schema.O, d.GetProto().Name)
		return &storepb.Advice{
			Status:        storepb.Advice_WARNING,
			Code:          code.NotCurrentDatabase.Int32(),
			Title:         content,
			Content:       content,
			StartPosition: &storepb.Position{Line: 0},
		}
	}

	schema := d.GetSchemaMetadata("")
	if schema == nil {
		schema = d.CreateSchema("")
	}

	if schema.GetTable(node.Table.Name.O) != nil {
		if node.IfNotExists {
			return nil
		}
		content := fmt.Sprintf("Table `%s` already exists", node.Table.Name.O)
		return &storepb.Advice{
			Status:        storepb.Advice_ERROR,
			Code:          code.TableExists.Int32(),
			Title:         content,
			Content:       content,
			StartPosition: &storepb.Position{Line: 0},
		}
	}

	if node.Select != nil {
		// Trim leading whitespace for display - node.Text() may include leading whitespace
		// to maintain position consistency, but error messages should show clean SQL.
		content := fmt.Sprintf("CREATE TABLE AS statement is used in \"%s\"", strings.TrimSpace(node.Text()))
		return &storepb.Advice{
			Status:        storepb.Advice_WARNING,
			Code:          code.StatementCreateTableAs.Int32(),
			Title:         content,
			Content:       content,
			StartPosition: &storepb.Position{Line: 0},
		}
	}

	if node.ReferTable != nil {
		return tidbCopyTable(d, node)
	}

	table, createErr := schema.CreateTable(node.Table.Name.O)
	if createErr != nil {
		return &storepb.Advice{
			Status:        storepb.Advice_ERROR,
			Code:          code.TableExists.Int32(),
			Title:         createErr.Error(),
			Content:       createErr.Error(),
			StartPosition: &storepb.Position{Line: 0},
		}
	}