Function getSequences

backend/plugin/db/oracle/sync.go:1168–1212

getSequences gets all sequences of a database.

(txn *sql.Tx, schemaName string)

// getSequences gets all sequences of a database.
func getSequences(txn *sql.Tx, schemaName string) ([]*storepb.SequenceMetadata, error) {
	var sequences []*storepb.SequenceMetadata

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

	query := fmt.Sprintf(`
		SELECT SEQUENCE_NAME FROM ALL_SEQUENCES
		WHERE SEQUENCE_OWNER = '%s'
		ORDER BY SEQUENCE_NAME`, schemaName)

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

	for rows.Next() {
		seq := &storepb.SequenceMetadata{}
		if err := rows.Scan(&seq.Name); err != nil {
			return nil, err
		}
		// Skip system-generated sequences (e.g., ISEQ$$_* for IDENTITY columns)
		if strings.HasPrefix(seq.Name, "ISEQ$$_") {
			continue
		}
		key := db.TableKey{Schema: schemaName, Table: seq.Name}
		if comment, ok := sequenceCommentMap[key]; ok {
			seq.Comment = comment
		}
		sequences = append(sequences, seq)
	}
	if err := rows.Err(); err != nil {
		return nil, err
	}
	if err := rows.Close(); err != nil {
		return nil, err
	}

	return sequences, nil
}

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