func (r *OrderRepository) GetActiveOrderIDs(ctx context.Context, offset, limit int) ([]uint32, error) { var ( res []uint32 args []interface{} ) query := `SELECT id FROM "order" WHERE is_terminated = false LIMIT $1 OFFSET $2;` args = append(args, limit, offset) rows, err := r.slave.Query(ctx, query, args...) if err != nil { return nil, err } for rows.Next() { var orderID uint32 if err = rows.Scan(&orderID); err != nil { return nil, err } res = append(res, orderID) } return res, nil }

In dieser Methode in Go wird eine Datenbankabfrage durchgeführt, um die IDs aktiver Bestellungen mit Paginierung (Offset und Limit) zu erhalten.

Der Code verwendet korrekt eine vorbereitete Abfrage mit Parametern, was SQL-Injektionen verhindert.

Es gibt jedoch einige Empfehlungen zur Verbesserung:

• Es ist ratsam, rows nach der Verwendung zu schließen, um Ressourcenlecks zu vermeiden:

rows, err := r.slave.Query(ctx, query, args...)
if err != nil {
    return nil, err
}
defer rows.Close()

• Nach der Schleife kann rows.Err() verwendet werden, um Fehler bei der Iteration zu prüfen.

• Die Parameter LIMIT und OFFSET sind in der Regel in dieser Reihenfolge, aber in der Abfrage sind sie als LIMIT $1 OFFSET $2 angegeben, was korrekt ist, wenn limit und offset in dieser Reihenfolge übergeben werden.

• Wenn eine große Datenmenge erwartet wird, sollte die Verwendung von Cursor oder Streaming-Processing in Betracht gezogen werden.

Beispiel mit Schließen von rows und Fehlerprüfung:

rows, err := r.slave.Query(ctx, query, args...)
if err != nil {
    return nil, err
}
defer rows.Close()

for rows.Next() {
    var orderID uint32
    if err = rows.Scan(&orderID); err != nil {
        return nil, err
    }
    res = append(res, orderID)
}

if err = rows.Err(); err != nil {
    return nil, err
}

return res, nil