Function getRoutines

backend/plugin/db/oracle/sync.go:1214–1317

(txn *sql.Tx, schemaName string)

}

func getRoutines(txn *sql.Tx, schemaName string) ([]*storepb.FunctionMetadata, []*storepb.ProcedureMetadata, []*storepb.PackageMetadata, error) {
	var functions []*storepb.FunctionMetadata
	var procedures []*storepb.ProcedureMetadata
	var packages []*storepb.PackageMetadata

	// Get function comments
	functionCommentMap, err := getFunctionComments(txn, schemaName)
	if err != nil {
		return nil, nil, nil, errors.Wrapf(err, "failed to get function comments")
	}

	query := fmt.Sprintf(`
		SELECT
			NAME,
			TYPE,
			TEXT
		FROM ALL_SOURCE
		WHERE
			TYPE IN ('FUNCTION', 'PROCEDURE', 'PACKAGE')
			AND
			OWNER = '%s'
		ORDER BY NAME, TYPE, LINE`, schemaName)

	slog.Debug("running get routines query")
	rows, err := txn.Query(query)
	if err != nil {
		return nil, nil, nil, util.FormatErrorWithQuery(err, query)
	}
	defer rows.Close()

	var currentName, currentType string
	var defText []string
	for rows.Next() {
		var name, t, def string
		if err := rows.Scan(&name, &t, &def); err != nil {
			return nil, nil, nil, err
		}
		if name == currentName && t == currentType {
			defText = append(defText, def)
		} else {
			// Oracle may include a trailing C-string null terminator via the go-ora driver.
			switch currentType {
			case "FUNCTION":
				function := &storepb.FunctionMetadata{
					Name:       currentName,
					Definition: strings.TrimRight(strings.Join(defText, ""), "\x00"),
				}
				key := db.TableKey{Schema: schemaName, Table: currentName}
				if comment, ok := functionCommentMap[key]; ok {
					function.Comment = comment
				}
				functions = append(functions, function)
			case "PROCEDURE":
				procedures = append(procedures, &storepb.ProcedureMetadata{
					Name:       currentName,
					Definition: strings.TrimRight(strings.Join(defText, ""), "\x00"),
				})
			case "PACKAGE":