Function getTriggerComments

backend/plugin/db/oracle/sync.go:1556–1604

getTriggerComments gets comments for triggers from Oracle system views

(txn *sql.Tx, schemaName string)

// getTriggerComments gets comments for triggers from Oracle system views
func getTriggerComments(txn *sql.Tx, schemaName string) (map[db.TableKey]string, error) {
	triggerCommentMap := make(map[db.TableKey]string)

	// Oracle doesn't have a standard trigger comments view
	// Trigger comments might be stored in ALL_TAB_COMMENTS with TABLE_TYPE = 'TRIGGER'
	// or in some Oracle versions, they might not be available at all
	query := ""
	if schemaName == "" {
		query = fmt.Sprintf(`
		SELECT OWNER, TABLE_NAME, COMMENTS
		FROM all_tab_comments
		WHERE OWNER NOT IN (%s) AND OWNER NOT LIKE 'APEX_%%' AND COMMENTS IS NOT NULL
		AND TABLE_TYPE = 'TRIGGER'
		ORDER BY OWNER, TABLE_NAME`, systemSchema)
	} else {
		query = fmt.Sprintf(`
		SELECT OWNER, TABLE_NAME, COMMENTS
		FROM all_tab_comments
		WHERE OWNER = '%s' AND COMMENTS IS NOT NULL
		AND TABLE_TYPE = 'TRIGGER'
		ORDER BY TABLE_NAME`, schemaName)
	}

	slog.Debug("running get trigger comments query")
	rows, err := txn.Query(query)
	if err != nil {
		// If the query fails (e.g., TABLE_TYPE = 'TRIGGER' not supported), return empty map
		slog.Debug("trigger comments query failed, returning empty map", slog.String("error", err.Error()))
		return triggerCommentMap, nil
	}
	defer rows.Close()

	for rows.Next() {
		var schemaName, triggerName, comment string
		if err := rows.Scan(&schemaName, &triggerName, &comment); err != nil {
			return nil, err
		}
		key := db.TableKey{Schema: schemaName, Table: triggerName}
		triggerCommentMap[key] = common.SanitizeUTF8String(comment)
	}
	if err := rows.Err(); err != nil {
		return nil, util.FormatErrorWithQuery(err, query)
	}
	if err := rows.Close(); err != nil {
		return nil, errors.Wrapf(err, "failed to close rows")
	}

	return triggerCommentMap, nil
}