Method triggers

database/postgres/database.go:656–708

triggers fetches user-defined triggers from the database

()

// triggers fetches user-defined triggers from the database
func (d *PostgresDatabase) triggers() ([]string, error) {
	// Query to get user-defined triggers (excluding internal triggers and extension triggers)
	// We use pg_get_triggerdef to get the complete trigger definition
	rows, err := d.db.Query(`
		SELECT n.nspname AS trigger_schema,
		       c.relname AS table_name,
		       t.tgname AS trigger_name,
		       pg_get_triggerdef(t.oid) AS trigger_def,
		       obj_description(t.oid, 'pg_trigger') AS trigger_comment
		FROM pg_catalog.pg_trigger t
		INNER JOIN pg_catalog.pg_class c ON t.tgrelid = c.oid
		INNER JOIN pg_catalog.pg_namespace n ON c.relnamespace = n.oid
		WHERE n.nspname NOT IN ('pg_catalog', 'information_schema', 'pg_toast', 'sys')
		  AND NOT t.tgisinternal
		  AND NOT EXISTS (SELECT 1 FROM pg_depend d WHERE d.objid = t.oid AND d.classid = (SELECT oid FROM pg_catalog.pg_class WHERE relname = 'pg_trigger') AND d.deptype = 'e')
		ORDER BY n.nspname, c.relname, t.tgname;
	`)
	if err != nil {
		return nil, err
	}
	defer rows.Close()

	var ddls []string
	for rows.Next() {
		var triggerSchema, tableName, triggerName, triggerDef string
		var triggerComment sql.NullString
		if err := rows.Scan(&triggerSchema, &tableName, &triggerName, &triggerDef, &triggerComment); err != nil {
			return nil, err
		}
		if d.config.TargetSchema != nil && !slices.Contains(d.config.TargetSchema, triggerSchema) {
			continue
		}
		// pg_get_triggerdef returns the complete CREATE TRIGGER statement
		// We just need to ensure it ends with a semicolon
		triggerDef = strings.TrimSpace(triggerDef)
		if !strings.HasSuffix(triggerDef, ";") {
			triggerDef += ";"
		}
		ddls = append(ddls, triggerDef)

		// Add comment if exists
		if triggerComment.Valid {
			ddls = append(ddls, fmt.Sprintf(
				"COMMENT ON TRIGGER %s ON %s.%s IS %s;",
				d.quoteIdentifierIfNeeded(triggerName), d.quoteIdentifierIfNeeded(triggerSchema), d.quoteIdentifierIfNeeded(tableName), schemaLib.StringConstant(triggerComment.String),
			))
		}
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	return ddls, nil
}

// CheckConstraint holds a CHECK constraint's name and definition.
type CheckConstraint struct {