Merge pull request #240 from kevinbarbour/fix/spanner-shard-query

adamdecaf · web-flow · commit 2bcce1b15a0d · 2024-09-27T09:11:50.000-05:00
fix(repository): correct an issue with shard querying in spanner
diff --git a/internal/shards/repository.go b/internal/shards/repository.go
@@ -189,7 +189,12 @@ func (r *spannerRepository) Lookup(shardKey string) (string, error) {
 		return "", err
 	}
 
-	return row.String(), nil
+	var shardName string
+	if err := row.ColumnByName("shard_name", &shardName); err != nil {
+		return "", err
+	}
+
+	return shardName, nil
 }
 
 func (r *spannerRepository) List() ([]service.ShardMapping, error) {

Original file line number	Diff line number	Diff line change
`@@ -189,7 +189,12 @@ func (r *spannerRepository) Lookup(shardKey string) (string, error) {`
`189`	`189`	`return "", err`
`190`	`190`	`}`
`191`	`191`
`192`		`- return row.String(), nil`
	`192`	`+ var shardName string`
	`193`	`+ if err := row.ColumnByName("shard_name", &shardName); err != nil {`
	`194`	`+ return "", err`
	`195`	`+ }`
	`196`	`+`
	`197`	`+ return shardName, nil`
`193`	`198`	`}`
`194`	`199`
`195`	`200`	`func (r *spannerRepository) List() ([]service.ShardMapping, error) {`