diff options
| author | Taras Madan <tarasmadan@google.com> | 2024-07-07 16:51:50 +0200 |
|---|---|---|
| committer | Taras Madan <tarasmadan@google.com> | 2024-07-08 06:38:57 +0000 |
| commit | eb4d8036c1b6035539881d798dd7e557b4a7d78f (patch) | |
| tree | 3d1dc8c74d5cc905213f861049c9ca1416936bd3 /dashboard | |
| parent | b03dfde25a58c76d9fc303af81f1e6102c4d73cb (diff) | |
dashboard/app/entities_spanner.go: select latest sessions
Diffstat (limited to 'dashboard')
| -rw-r--r-- | dashboard/app/entities_spanner.go | 19 |
1 files changed, 11 insertions, 8 deletions
diff --git a/dashboard/app/entities_spanner.go b/dashboard/app/entities_spanner.go index 450167977..ec8824e84 100644 --- a/dashboard/app/entities_spanner.go +++ b/dashboard/app/entities_spanner.go @@ -23,20 +23,23 @@ type CoverageHistory struct { // MergedCoverage uses dates, not time. func MergedCoverage(ctx context.Context, ns string, fromDate, toDate civil.Date) (*CoverageHistory, error) { projectID := os.Getenv("GOOGLE_CLOUD_PROJECT") - client, err := spanner.NewClient(ctx, "projects/"+projectID+"/instances/syzbot/databases/coverage") + database := "projects/" + projectID + "/instances/syzbot/databases/coverage" + client, err := spanner.NewClient(ctx, database) if err != nil { panic(fmt.Sprintf("spanner.NewClient() failed: %s", err.Error())) } defer client.Close() stmt := spanner.Statement{ - SQL: `select - dateto as targetdate, - cast(sum(instrumented) as INTEGER) as instrumented, - cast(sum(covered) as INTEGER) as covered - from "files" - where namespace=$1 and dateto>=$2 and dateto<=$3 - group by targetdate`, + SQL: ` +select + dateto as targetdate, + cast(sum(instrumented) as INTEGER) as instrumented, + cast(sum(covered) as INTEGER) as covered +from merge_history join files + on merge_history.session = files.session +where namespace=$1 and dateto>=$2 and dateto<=$3 +group by dateto`, Params: map[string]interface{}{ "p1": ns, "p2": fromDate, |