lock pre-existing rows

stellar · Aug 15, 2024 · cbfed4b · cbfed4b
1 parent 94db9f5
commit cbfed4b
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/services/horizon/internal/db2/history/account_loader.go b/services/horizon/internal/db2/history/account_loader.go
@@ -328,8 +328,9 @@ func bulkGet(ctx context.Context, q *Q, table string, fields []columnValues, res
 			pq.Array(field.objects),
 		)
 	}
+	lockSuffix := "ORDER BY id ASC FOR KEY SHARE"
 	sql := `SELECT * FROM ` + table + ` WHERE (` + strings.Join(columns, ",") + `) IN 
-	(SELECT ` + strings.Join(unnestPart, ",") + `)`
+	(SELECT ` + strings.Join(unnestPart, ",") + `) ` + lockSuffix
 
 	return q.SelectRaw(
 		ctx,