database changes to include jobs

src/com/couchbase/perf/sdk/stages/OutputPerformerConfig.groovy

@@ -98,6 +98,7 @@ class OutputPerformerConfig extends Stage {
             }
             runs runsAsYaml
             settings topLevelSettings
+            jobId ctx.jc.jobId
         }
 
         def converted = YamlConverter.convertJsonToYaml(new StringReader(json.toString()))

src/com/couchbase/perf/shared/database/PerfDatabase.groovy

@@ -68,6 +68,16 @@ class PerfDatabase {
         // JSONB indexes
         execute(sql, env, "CREATE INDEX IF NOT EXISTS idx_runs_params ON runs USING gin (params)")
         execute(sql, env, "CREATE INDEX IF NOT EXISTS idx_runs_events_params ON run_events USING gin (params)")
+
+        // For FIT-as-a-Service:-
+        // New tables to hold an overlying job for grouping runs
+        execute(sql, env, "CREATE TABLE IF NOT EXISTS jobs (id uuid PRIMARY KEY, datetime timestamp NOT NULL DEFAULT now(), config jsonb, tags TEXT[] DEFAULT NULL)");
+        execute(sql, env, "CREATE TABLE IF NOT EXISTS job_run_join (job_id UUID REFERENCES jobs(id) ON DELETE CASCADE, run_id UUID REFERENCES runs(id) ON DELETE CASCADE, PRIMARY KEY (job_id, run_id))");
+        // Indexes for the new tables
+        execute(sql, env, "CREATE INDEX IF NOT EXISTS idx_jobs_datetime ON jobs (datetime)");
+        execute(sql, env, "CREATE INDEX IF NOT EXISTS idx_jobs_tags ON jobs USING gin (tags)");  
+        execute(sql, env, "CREATE INDEX IF NOT EXISTS idx_job_runs_job_id ON job_run_join (job_id)");
+        execute(sql, env, "CREATE INDEX IF NOT EXISTS idx_job_runs_run_id ON job_run_join (run_id)"); 
     }
 
     /**