feat(exporter): increase validator status update query speed (#899)

Author: peterbitfly

backend/pkg/exporter/db/db.go

@@ -523,6 +523,14 @@ func SaveValidators(epoch uint64, validators []*types.Validator, client rpc.Clie
 		return fmt.Errorf("error preparing insert validator statement: %w", err)
 	}
 
+	validatorStatusUpdateStmt, err := tx.Prepare(`UPDATE validators SET status = $1 WHERE validatorindex = $2;`)
+	if err != nil {
+		return fmt.Errorf("error preparing update validator status statement: %w", err)
+	}
+
+	log.Info("updating validator status and metadata")
+	valiudatorUpdateTs := time.Now()
+
 	updates := 0
 	for _, v := range validators {
 		// exchange farFutureEpoch with the corresponding max sql value
@@ -610,10 +618,14 @@ func SaveValidators(epoch uint64, validators []*types.Validator, client rpc.Clie
 			}
 
 			if c.Status != v.Status {
-				log.Infof("Status changed for validator %v from %v to %v", v.Index, c.Status, v.Status)
-				log.Infof("v.ActivationEpoch %v, latestEpoch %v, lastAttestationSlots[v.Index] %v, thresholdSlot %v, lastGlobalAttestedEpoch: %v, lastValidatorAttestedEpoch: %v", v.ActivationEpoch, latestEpoch, lastAttestationSlot, thresholdSlot, lastGlobalAttestedEpoch, lastValidatorAttestedEpoch)
-				queries.WriteString(fmt.Sprintf("UPDATE validators SET status = '%s' WHERE validatorindex = %d;\n", v.Status, c.Index))
-				updates++
+				log.Debugf("Status changed for validator %v from %v to %v", v.Index, c.Status, v.Status)
+				log.Debugf("v.ActivationEpoch %v, latestEpoch %v, lastAttestationSlots[v.Index] %v, thresholdSlot %v, lastGlobalAttestedEpoch: %v, lastValidatorAttestedEpoch: %v", v.ActivationEpoch, latestEpoch, lastAttestationSlot, thresholdSlot, lastGlobalAttestedEpoch, lastValidatorAttestedEpoch)
+				//queries.WriteString(fmt.Sprintf("UPDATE validators SET status = '%s' WHERE validatorindex = %d;\n", v.Status, c.Index))
+				_, err := validatorStatusUpdateStmt.Exec(v.Status, c.Index)
+				if err != nil {
+					return fmt.Errorf("error updating validator status: %w", err)
+				}
+				//updates++
 			}
 			// if c.Balance != v.Balance {
 			// 	// log.LogInfo("Balance changed for validator %v from %v to %v", v.Index, c.Balance, v.Balance)
@@ -658,6 +670,11 @@ func SaveValidators(epoch uint64, validators []*types.Validator, client rpc.Clie
 		}
 	}
 
+	err = validatorStatusUpdateStmt.Close()
+	if err != nil {
+		return fmt.Errorf("error closing validator status update statement: %w", err)
+	}
+
 	err = insertStmt.Close()
 	if err != nil {
 		return fmt.Errorf("error closing insert validator statement: %w", err)
@@ -673,6 +690,7 @@ func SaveValidators(epoch uint64, validators []*types.Validator, client rpc.Clie
 		}
 		log.Infof("validator table update completed, took %v", time.Since(updateStart))
 	}
+	log.Infof("updating validator status and metadata completed, took %v", time.Since(valiudatorUpdateTs))
 
 	s := time.Now()
 	newValidators := []struct {