diff options
Diffstat (limited to 'syz-cluster/pkg/db/series_repo.go')
| -rw-r--r-- | syz-cluster/pkg/db/series_repo.go | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/syz-cluster/pkg/db/series_repo.go b/syz-cluster/pkg/db/series_repo.go index 0ac32415d..bb8bf7a8d 100644 --- a/syz-cluster/pkg/db/series_repo.go +++ b/syz-cluster/pkg/db/series_repo.go @@ -38,7 +38,7 @@ func NewSeriesRepository(client *spanner.Client) *SeriesRepository { func (repo *SeriesRepository) PatchByID(ctx context.Context, id string) (*Patch, error) { return readEntity[Patch](ctx, repo.client.Single(), spanner.Statement{ SQL: "SELECT * FROM Patches WHERE ID=@id", - Params: map[string]interface{}{"id": id}, + Params: map[string]any{"id": id}, }) } @@ -46,7 +46,7 @@ func (repo *SeriesRepository) PatchByID(ctx context.Context, id string) (*Patch, func (repo *SeriesRepository) GetByExtID(ctx context.Context, extID string) (*Series, error) { return readEntity[Series](ctx, repo.client.Single(), spanner.Statement{ SQL: "SELECT * FROM Series WHERE ExtID=@extID", - Params: map[string]interface{}{"extID": extID}, + Params: map[string]any{"extID": extID}, }) } @@ -74,7 +74,7 @@ func (repo *SeriesRepository) Insert(ctx context.Context, series *Series, // Check if the series already exists. stmt := spanner.Statement{ SQL: "SELECT 1 from `Series` WHERE `ExtID`=@extID", - Params: map[string]interface{}{"ExtID": series.ExtID}, + Params: map[string]any{"ExtID": series.ExtID}, } iter := txn.Query(ctx, stmt) defer iter.Stop() @@ -142,7 +142,7 @@ func (repo *SeriesRepository) ListLatest(ctx context.Context, filter SeriesFilte stmt := spanner.Statement{ SQL: "SELECT Series.* FROM Series WHERE 1=1", - Params: map[string]interface{}{}, + Params: map[string]any{}, } if !maxPublishedAt.IsZero() { stmt.SQL += " AND PublishedAt < @toTime" @@ -226,7 +226,7 @@ func (repo *SeriesRepository) querySessions(ctx context.Context, ro *spanner.Rea } sessions, err := readEntities[Session](ctx, ro, spanner.Statement{ SQL: "SELECT * FROM Sessions WHERE ID IN UNNEST(@ids)", - Params: map[string]interface{}{ + Params: map[string]any{ "ids": keys, }, }) @@ -265,7 +265,7 @@ func (repo *SeriesRepository) queryFindingCounts(ctx context.Context, ro *spanne SQL: "SELECT `SessionID`, COUNT(`ID`) as `Count` FROM `Findings` " + "WHERE `SessionID` IN UNNEST(@ids) AND `Findings`.`InvalidatedAt` IS NULL " + "GROUP BY `SessionID`", - Params: map[string]interface{}{ + Params: map[string]any{ "ids": keys, }, }) @@ -283,7 +283,7 @@ func (repo *SeriesRepository) queryFindingCounts(ctx context.Context, ro *spanne func (repo *SeriesRepository) ListPatches(ctx context.Context, series *Series) ([]*Patch, error) { return readEntities[Patch](ctx, repo.client.Single(), spanner.Statement{ SQL: "SELECT * FROM `Patches` WHERE `SeriesID` = @seriesID ORDER BY `Seq`", - Params: map[string]interface{}{ + Params: map[string]any{ "seriesID": series.ID, }, }) |