chore: improved records fetch via one call

Author: michaelwenk

pkg/database/db_interface.go

@@ -141,6 +141,8 @@ type MB3Database interface {
 	// database.
 	GetRecord(*string) (*string, error)
 
+	GetRecords(*[]string) (*[]string, error)
+
 	// GetSimpleRecord gets a single simple MassBank record by the Accession string.
 	// It should return nil and a [NotFoundError] if the record is not in the
 	// database.

pkg/database/postgres.go

@@ -315,6 +315,31 @@ func (p *PostgresSQLDB) GetMetadata() (*massbank.MbMetaData, error) {
 	return result, nil
 }
 
+func (p *PostgresSQLDB) GetRecords(s *[]string) (*[]string, error) {
+
+	var query = "SELECT record_text FROM records WHERE accession = ANY ($1);"
+	stmt, err := p.database.Prepare(query)
+	if err != nil {
+		return nil, err
+	}
+	var recordStrings = []string{}
+	rows, err := stmt.Query(pq.Array(s))
+	stmt.Close()
+	if err != nil {
+		return nil, err
+	}
+	defer rows.Close()
+	for rows.Next() {
+		var record string
+		if err := rows.Scan(&record); err != nil {
+			return nil, err
+		}
+		recordStrings = append(recordStrings, record)
+	}
+
+	return &recordStrings, nil
+}
+
 // GetRecord see [MB3Database.GetRecord]
 func (p *PostgresSQLDB) GetRecord(s *string) (*string, error) {
 

pkg/mb3server/api-impl.go

@@ -526,12 +526,16 @@ func GetRecords(contributor []string, instrumentType []string, msType []string,
 	}
 
 	result := []MbRecord{}
+	accessions := []string{}
 	for _, searchResultDataInner := range searchResult.Data {
-		mb3RecordJson, err := db.GetRecord(&searchResultDataInner.Accession)
-		if err != nil {
-			return nil, err
-		}
-		record, err := ConvertJsonStringToMb3Record(*mb3RecordJson)
+		accessions = append(accessions, searchResultDataInner.Accession)
+	}
+	recordStrings, err := db.GetRecords(&accessions)
+	if err != nil {
+		return nil, err
+	}
+	for _, recordString := range *recordStrings {
+		record, err := ConvertJsonStringToMb3Record(recordString)
 		if err != nil {
 			return nil, err
 		}