feat(restore_test): add a way to compare table rows not only by a count

pkg/service/restore/helper_integration_test.go

@@ -9,6 +9,7 @@ import (
 	"context"
 	"encoding/json"
 	"fmt"
+	"maps"
 	"strings"
 	"testing"
 
@@ -316,6 +317,30 @@ func rowCount(t *testing.T, s gocqlx.Session, ks, tab string) int {
 	return cnt
 }
 
+func validateTableContent[K, V comparable](t *testing.T, src, dst gocqlx.Session, keyspace, tab, keyColumn, valueColumn string) {
+	srcM := selectTableAsMap[K, V](t, src, keyspace, tab, keyColumn, valueColumn)
+	dstM := selectTableAsMap[K, V](t, dst, keyspace, tab, keyColumn, valueColumn)
+	if !maps.Equal(srcM, dstM) {
+		t.Fatalf("tables have different contents\nsrc:\n%v\ndst:\n%v", srcM, dstM)
+	}
+}
+
+func selectTableAsMap[K, V comparable](t *testing.T, s gocqlx.Session, keyspace, tab, keyColumn, valueColumn string) map[K]V {
+	var (
+		k   K
+		v   V
+		out = make(map[K]V)
+	)
+	it := s.Session.Query(fmt.Sprintf("SELECT %s, %s FROM %q.%q", keyColumn, valueColumn, keyspace, tab)).Iter()
+	for it.Scan(&k, &v) {
+		out[k] = v
+	}
+	if err := it.Close(); err != nil {
+		t.Fatal(errors.Wrapf(err, "select rows %s, %s from %q.%q", keyColumn, valueColumn, keyspace, tab))
+	}
+	return out
+}
+
 func filteredTables(t *testing.T, s gocqlx.Session, filter []string) []string {
 	f, err := ksfilter.NewFilter(filter)
 	if err != nil {