// έχουμε μια μέθοδο για την λήψη πληροφοριών για τα προϊόντα, αυτή η μέθοδος καλείται πολύ συχνά // υπάρχουν προβλήματα σε αυτόν τον κώδικα και πώς να τα διορθώσουμε; βάση δεδομένων postgress
Principal
267
Data Analyst
287
0
// Έχουμε μια μέθοδο για την απόκτηση πληροφοριών σχετικά με τα προϊόντα, αυτή η μέθοδος καλείται πολύ συχνά // υπάρχουν προβλήματα σε αυτόν τον κώδικα και πώς μπορούμε να τα διορθώσουμε; βάση δεδομένων postgress func (r *ProductRepository) GetProductDetails(ctx context.Context, productIDs []int) []Product { products := make([]Product, 0, len(productIDs)) for _, id := range productIDs { go func(id int) { var p Product query := "SELECT name, price, description FROM products WHERE id = $1" err := r.db.QueryRowContext(ctx, query, id).Scan(&p.Name, &p.Price, &p.Desc) if err != nil { r.logger.Error("error get product", "err", err) return } products = append(products, p) }(id) } return products }
Principal
165
// Κατά την ενημέρωση παραγγελίας, πρέπει να στείλουμε τα δεδομένα της παραγγελίας σε πολλαπλές υπηρεσίες (τρίτων) // ο αριθμός των υπηρεσιών αυξάνεται (μπορεί να είναι χιλιάδες+) // γράψαμε τον κώδικα, αρχικά όλα πήγαιναν καλά, αλλά με τον καιρό η υπηρεσία μας άρχισε να καταναλώνει πολλούς πόρους // Πρέπει να βελτιστοποιήσουμε αυτόν τον κώδικα ώστε να λειτουργεί αποτελεσματικά με μεγάλο αριθμό υπηρεσιών func (s *orderService) SendOrder(ctx context.Context, hosts []string, order Order) { for i := 0; i < len(hosts); i++ { go func() { // Φανταστείτε ότι είναι μια μακράς διάρκειας δικτυακή κλήση response, err := s.httpClient.Send(ctx, hosts[i], order) if err != nil { s.logger.Error(ctx, "αποτυχία αποστολής", err) return } s.logger.Info(ctx, "επιτυχία", response) }() } }
Principal
152
Είναι το UPDATE από μόνο του μια συναλλαγή; Χρειάζεται ρητή συναλλαγή για ένα ατομικό UPDATE;
Principal
146
Τι θα συμβεί αν ξεκινήσουμε χιλιάδες συνδέσεις ταυτόχρονα;
Principal
125
// Tenemos una tabla con un producto que tiene un contador de vistas // tabla goods: // ID | cnt_view // ----------- // 1 | 100 // Dos usuarios comenzaron a ver el producto con id = 1 al mismo tiempo // y en nuestra base de datos se lanzaron 2 transacciones en paralelo // ¿Cuál será el resultado? postgress func IncrementView(ctx context.Context, db *sql.DB, id int64) error { tx, err := db.BeginTx(ctx, nil) if err != nil { return err } defer tx.Rollback() var cnt int err = tx.QueryRowContext(ctx, "SELECT cnt_view FROM goods WHERE id = $1", id, ).Scan(&cnt) if err != nil { return err } cnt++ _, err = tx.ExecContext(ctx, "UPDATE goods SET cnt_view = $1 WHERE id = $2", cnt, id, ) if err != nil { return err } return tx.Commit() }
Principal
124
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 }
Principal
124
// Κατά την ενημέρωση μιας παραγγελίας, πρέπει να στείλουμε τα δεδομένα της παραγγελίας σε πολλαπλές υπηρεσίες (τρίτων) // ο αριθμός των υπηρεσιών αυξάνεται (μπορεί να είναι χιλιάδες+) // γράψαμε τον κώδικα, στην αρχή όλα πήγαιναν καλά, αλλά με τον καιρό η υπηρεσία μας άρχισε να καταναλώνει πολλούς πόρους func (s *orderService) SendOrder(ctx context.Context, hosts []string, order Order) { for i := 0; i < len(hosts); i++ { go func() { // Ας υποθέσουμε ότι αυτό είναι μια μεγάλη κλήση δικτύου response, err := s.httpClient.Send(ctx, hosts[i], order) if err != nil { s.logger.Error(ctx, "αποτυχία αποστολής", err) return } s.logger.Info(ctx, "επιτυχία", response) }() } }
Principal
102