sql: add SHOW CREATE ALL TRIGGERS

and implement it with optimized query.

Implemented `SHOW CREATE ALL TRIGGERS` command.
This consists on parser changes (sql.y), generator functions,
addition of the command to delegator, and also creation of
`crdb_internal.create_trigger_statements` as a virtual table.
The generators query the table, which is indexed on `table_id`
and the query result contains the create statements of all triggers.
This is a useful change for the task of a `SHOW CREATE` statement
that returns create statements for all objects of the database.

Release note (sql): Add `SHOW CREATE ALL TRIGGERS` as a command
to CockroachDB

Epic: CRDB-49582

Author: OriSavir

docs/generated/sql/bnf/show_create_stmt.bnf

@@ -2,5 +2,6 @@ show_create_stmt ::=
 	'SHOW' 'CREATE' object_name opt_show_create_format_options
 	| 'SHOW' 'CREATE' 'ALL' 'SCHEMAS'
 	| 'SHOW' 'CREATE' 'ALL' 'TABLES'
+	| 'SHOW' 'CREATE' 'ALL' 'TRIGGERS'
 	| 'SHOW' 'CREATE' 'ALL' 'TYPES'
 	| 'SHOW' 'CREATE' 'ALL' 'ROUTINES'

docs/generated/sql/bnf/stmt_block.bnf

@@ -854,6 +854,7 @@ show_create_stmt ::=
 	'SHOW' 'CREATE' table_name opt_show_create_format_options
 	| 'SHOW' 'CREATE' 'ALL' 'SCHEMAS'
 	| 'SHOW' 'CREATE' 'ALL' 'TABLES'
+	| 'SHOW' 'CREATE' 'ALL' 'TRIGGERS'
 	| 'SHOW' 'CREATE' 'ALL' 'TYPES'
 	| 'SHOW' 'CREATE' 'ALL' 'ROUTINES'
 

pkg/ccl/logictestccl/tests/3node-tenant/generated_test.go

@@ -14,6 +14,7 @@ debug/crdb_internal.create_function_statements.txt
 debug/crdb_internal.create_procedure_statements.txt
 debug/crdb_internal.create_schema_statements.txt
 debug/crdb_internal.create_statements.txt
+debug/crdb_internal.create_trigger_statements.txt
 debug/crdb_internal.create_type_statements.txt
 debug/crdb_internal.default_privileges.txt
 debug/crdb_internal.index_usage_statistics.txt
@@ -156,6 +157,7 @@ debug/crdb_internal.create_function_statements.txt
 debug/crdb_internal.create_procedure_statements.txt
 debug/crdb_internal.create_schema_statements.txt
 debug/crdb_internal.create_statements.txt
+debug/crdb_internal.create_trigger_statements.txt
 debug/crdb_internal.create_type_statements.txt
 debug/crdb_internal.default_privileges.txt
 debug/crdb_internal.index_usage_statistics.txt
@@ -305,6 +307,7 @@ debug/crdb_internal.create_function_statements.txt
 debug/crdb_internal.create_procedure_statements.txt
 debug/crdb_internal.create_schema_statements.txt
 debug/crdb_internal.create_statements.txt
+debug/crdb_internal.create_trigger_statements.txt
 debug/crdb_internal.create_type_statements.txt
 debug/crdb_internal.default_privileges.txt
 debug/crdb_internal.index_usage_statistics.txt
@@ -448,6 +451,7 @@ debug/crdb_internal.create_function_statements.txt
 debug/crdb_internal.create_procedure_statements.txt
 debug/crdb_internal.create_schema_statements.txt
 debug/crdb_internal.create_statements.txt
+debug/crdb_internal.create_trigger_statements.txt
 debug/crdb_internal.create_type_statements.txt
 debug/crdb_internal.default_privileges.txt
 debug/crdb_internal.index_usage_statistics.txt
@@ -559,6 +563,7 @@ debug/crdb_internal.create_function_statements.txt
 debug/crdb_internal.create_procedure_statements.txt
 debug/crdb_internal.create_schema_statements.txt
 debug/crdb_internal.create_statements.txt
+debug/crdb_internal.create_trigger_statements.txt
 debug/crdb_internal.create_type_statements.txt
 debug/crdb_internal.default_privileges.txt
 debug/crdb_internal.index_usage_statistics.txt

pkg/ccl/logictestccl/tests/local-read-committed/generated_test.go

@@ -272,6 +272,19 @@ var zipInternalTablesPerCluster = DebugZipTableRegistry{
 			"crdb_internal.hide_sql_constants(create_statement) as create_statement",
 		},
 	},
+	`"".crdb_internal.create_trigger_statements`: {
+		nonSensitiveCols: NonSensitiveColumns{
+			"database_id",
+			"database_name",
+			"schema_id",
+			"schema_name",
+			"table_id",
+			"table_name",
+			"trigger_id",
+			"trigger_name",
+			"crdb_internal.hide_sql_constants(create_statement) as create_statement",
+		},
+	},
 	`"".crdb_internal.create_procedure_statements`: {
 		nonSensitiveCols: NonSensitiveColumns{
 			"database_id",

pkg/ccl/logictestccl/tests/local-repeatable-read/generated_test.go

@@ -99,6 +99,7 @@ var clusterWideTableDumps = map[string]columnParserMap{
 	"crdb_internal.create_type_statements.txt":      {},
 	"crdb_internal.create_procedure_statements.txt": {},
 	"crdb_internal.create_function_statements.txt":  {},
+	"crdb_internal.create_trigger_statements.txt":   {},
 	"crdb_internal.logical_replication_spans.txt":   {},
 	"crdb_internal.cluster_replication_spans.txt":   {},
 	"system.protected_ts_records.txt":               {},

pkg/cli/testdata/zip/file-filters/testzip_file_filters

@@ -3458,7 +3458,8 @@ func (ex *connExecutor) makeExecPlan(
 			// session var is set to 'true' ('false' is the default).
 			catalog = planner.optPlanningCtx.catalog
 		}
-		_, err := explain.DecodePlanGistToRows(ctx, &planner.extendedEvalCtx.Context, ih.planGist.String(), catalog)
+		planStr := ih.planGist.String()
+		_, err := explain.DecodePlanGistToRows(ctx, &planner.extendedEvalCtx.Context, planStr, catalog)
 		if err != nil {
 			return ctx, errors.NewAssertionErrorWithWrappedErrf(err, "failed to decode plan gist: %q", ih.planGist.String())
 		}

pkg/cli/zip_table_registry.go

@@ -143,6 +143,7 @@ var crdbInternal = virtualSchema{
 		catconstants.CrdbInternalClusterSettingsTableID:             crdbInternalClusterSettingsTable,
 		catconstants.CrdbInternalClusterStmtStatsTableID:            crdbInternalClusterStmtStatsTable,
 		catconstants.CrdbInternalCreateFunctionStmtsTableID:         crdbInternalCreateFunctionStmtsTable,
+		catconstants.CrdbInternalCreateTriggerStmtsTableID:          crdbInternalCreateTriggerStmtsTable,
 		catconstants.CrdbInternalCreateProcedureStmtsTableID:        crdbInternalCreateProcedureStmtsTable,
 		catconstants.CrdbInternalCreateSchemaStmtsTableID:           crdbInternalCreateSchemaStmtsTable,
 		catconstants.CrdbInternalCreateStmtsTableID:                 crdbInternalCreateStmtsTable,
@@ -3943,6 +3944,189 @@ CREATE TABLE crdb_internal.create_procedure_statements (
 	populate: createRoutinePopulate(true /* procedure */),
 }
 
+func renderCreateTriggerStatement(
+	ctx context.Context,
+	p *planner,
+	trigger *descpb.TriggerDescriptor,
+	tableDesc catalog.TableDescriptor,
+) (string, error) {
+	tableTyp, err := p.ResolveTypeByOID(ctx, typedesc.TableIDToImplicitTypeOID(tableDesc.GetID()))
+	if err != nil {
+		return "", err
+	}
+
+	funcName, err := p.GetQualifiedFunctionNameByID(ctx, int64(trigger.FuncID))
+	if err != nil {
+		return "", err
+	}
+
+	tableName, err := p.getQualifiedTableName(ctx, tableDesc)
+	if err != nil {
+		return "", err
+	}
+
+	events := make([]*tree.TriggerEvent, len(trigger.Events))
+	for j := range events {
+		descEvent := trigger.Events[j]
+		events[j] = &tree.TriggerEvent{
+			EventType: tree.TriggerEventTypeToTree[descEvent.Type],
+			Columns:   make(tree.NameList, 0, len(descEvent.ColumnNames)),
+		}
+		for _, colName := range descEvent.ColumnNames {
+			events[j].Columns = append(events[j].Columns, tree.Name(colName))
+		}
+	}
+
+	var transitions []*tree.TriggerTransition
+	if trigger.NewTransitionAlias != "" {
+		transitions = append(transitions, &tree.TriggerTransition{
+			IsNew: true,
+			Name:  tree.Name(trigger.NewTransitionAlias),
+		})
+	}
+	if trigger.OldTransitionAlias != "" {
+		transitions = append(transitions, &tree.TriggerTransition{
+			IsNew: false,
+			Name:  tree.Name(trigger.OldTransitionAlias),
+		})
+	}
+
+	forEach := tree.TriggerForEachStatement
+	if trigger.ForEachRow {
+		forEach = tree.TriggerForEachRow
+	}
+
+	var whenExpr tree.Expr
+	if trigger.WhenExpr != "" {
+		whenExpr, err = schemaexpr.ParseTriggerWhenExprForDisplay(
+			ctx, tableTyp, trigger.WhenExpr, p.EvalContext(), p.SemaCtx(), tree.FmtParsable,
+		)
+		if err != nil {
+			return "", err
+		}
+	}
+
+	createTrigger := &tree.CreateTrigger{
+		Replace:     false,
+		Name:        tree.Name(trigger.Name),
+		ActionTime:  tree.TriggerActionTimeToTree[trigger.ActionTime],
+		Events:      events,
+		TableName:   tableName.ToUnresolvedObjectName(),
+		Transitions: transitions,
+		ForEach:     forEach,
+		When:        whenExpr,
+		FuncName:    funcName.ToUnresolvedObjectName().ToUnresolvedName(),
+		FuncArgs:    trigger.FuncArgs,
+	}
+
+	f := tree.NewFmtCtx(
+		tree.FmtParsable,
+		tree.FmtDataConversionConfig(p.SessionData().DataConversionConfig),
+		tree.FmtLocation(p.SessionData().Location),
+	)
+	f.FormatNode(createTrigger)
+
+	return f.CloseAndGetString(), nil
+}
+
+func createTriggerPopulate(
+	ctx context.Context, p *planner, db catalog.DatabaseDescriptor, addRow func(...tree.Datum) error,
+) error {
+	// Skip virtual tables by setting virtualOpts to hideVirtual since they do not have triggers.
+	options := forEachTableDescOptions{virtualOpts: hideVirtual}
+	return forEachTableDesc(ctx, p, db, options, func(ctx context.Context, tblCtx tableDescContext) error {
+		tbl := tblCtx.table
+		curDB := tblCtx.database
+		sc := tblCtx.schema
+
+		for _, trig := range tbl.GetTriggers() {
+			sql, err := renderCreateTriggerStatement(ctx, p, &trig, tbl)
+			if err != nil {
+				return err
+			}
+
+			err = addRow(
+				tree.NewDInt(tree.DInt(curDB.GetID())), // database_id
+				tree.NewDString(curDB.GetName()),       // database_name
+				tree.NewDInt(tree.DInt(sc.GetID())),    // schema_id
+				tree.NewDString(sc.GetName()),          // schema_name
+				tree.NewDInt(tree.DInt(tbl.GetID())),   // table_id
+				tree.NewDString(tbl.GetName()),         // table_name
+				tree.NewDInt(tree.DInt(trig.ID)),       // trigger_id
+				tree.NewDString(trig.Name),             // trigger_name
+				tree.NewDString(sql),                   // create_statement
+			)
+			if err != nil {
+				return err
+			}
+		}
+		return nil
+	},
+	)
+}
+
+var crdbInternalCreateTriggerStmtsTable = virtualSchemaTable{
+	comment: "CREATE statements for all user-defined triggers.",
+	schema: `
+CREATE TABLE crdb_internal.create_trigger_statements (
+  database_id INT,
+  database_name STRING,
+  schema_id INT,
+  schema_name STRING,
+  table_id INT,
+  table_name STRING,
+  trigger_id INT,
+  trigger_name STRING,
+  create_statement STRING,
+  INDEX (table_id)
+)`,
+	populate: createTriggerPopulate,
+	indexes: []virtualIndex{
+		{
+			populate: func(
+				ctx context.Context,
+				unwrappedConstraint tree.Datum,
+				p *planner,
+				db catalog.DatabaseDescriptor,
+				addRow func(...tree.Datum) error,
+			) (matched bool, err error) {
+				tableID := descpb.ID(tree.MustBeDInt(unwrappedConstraint))
+				tableDesc, err := p.LookupTableByID(ctx, tableID)
+				if err != nil || tableDesc == nil {
+					return false, err
+				}
+				triggers := tableDesc.GetTriggers()
+				schemaID := tableDesc.GetParentSchemaID()
+				sc, err := p.LookupSchemaByID(ctx, schemaID)
+				if err != nil {
+					return false, err
+				}
+				for _, trig := range triggers {
+					sql, err := renderCreateTriggerStatement(ctx, p, &trig, tableDesc)
+					if err != nil {
+						return false, err
+					}
+					err = addRow(
+						tree.NewDInt(tree.DInt(db.GetID())),
+						tree.NewDString(db.GetName()),
+						tree.NewDInt(tree.DInt(sc.GetID())),
+						tree.NewDString(sc.GetName()),
+						tree.NewDInt(tree.DInt(tableDesc.GetID())),
+						tree.NewDString(tableDesc.GetName()),
+						tree.NewDInt(tree.DInt(trig.ID)),
+						tree.NewDString(trig.Name),
+						tree.NewDString(sql),
+					)
+					if err != nil {
+						return false, err
+					}
+				}
+				return true, nil
+			},
+		},
+	},
+}
+
 // Prepare the row populate function.
 var typeView = tree.NewDString("view")
 var typeTable = tree.NewDString("table")