aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChristopher Baines <mail@cbaines.net>2021-02-05 09:16:08 +0000
committerChristopher Baines <mail@cbaines.net>2021-02-05 09:16:08 +0000
commit02b75d857aadda35cb7c6afb416c248ada435df2 (patch)
tree90333a3eeb8aae163c35026d8009af34b66af838
parent39f52e3a2ea126a08d60e087d1f6b83f8e00f5d4 (diff)
downloaddata-service-02b75d857aadda35cb7c6afb416c248ada435df2.tar
data-service-02b75d857aadda35cb7c6afb416c248ada435df2.tar.gz
Reformat queries in the load-new-guix-revision module
-rw-r--r--guix-data-service/jobs/load-new-guix-revision.scm51
1 files changed, 29 insertions, 22 deletions
diff --git a/guix-data-service/jobs/load-new-guix-revision.scm b/guix-data-service/jobs/load-new-guix-revision.scm
index 21ce9be..317c647 100644
--- a/guix-data-service/jobs/load-new-guix-revision.scm
+++ b/guix-data-service/jobs/load-new-guix-revision.scm
@@ -90,8 +90,9 @@
(exec-query
conn
(string-append
- "INSERT INTO load_new_guix_revision_job_log_parts (id, job_id, contents) "
- "VALUES (nextval('" (log-part-sequence-name job_id) "'), $1, $2)")
+ "
+INSERT INTO load_new_guix_revision_job_log_parts (id, job_id, contents)
+VALUES (nextval('" (log-part-sequence-name job_id) "'), $1, $2)")
(list job_id s)))
(define (log-string s)
@@ -283,13 +284,14 @@ WHERE job_id = $1"
(exec-query
conn
(string-append
- "UPDATE load_new_guix_revision_job_logs SET contents = "
- "("
- "SELECT STRING_AGG(contents, '' ORDER BY id ASC) FROM "
- "load_new_guix_revision_job_log_parts WHERE job_id = $1 "
- "GROUP BY job_id"
- ")"
- "WHERE job_id = $1")
+ "
+UPDATE load_new_guix_revision_job_logs SET contents = (
+ SELECT STRING_AGG(contents, '' ORDER BY id ASC)
+ FROM load_new_guix_revision_job_log_parts
+ WHERE job_id = $1
+ GROUP BY job_id
+)
+WHERE job_id = $1")
(list job-id))
(exec-query
conn
@@ -1650,37 +1652,42 @@ SELECT EXISTS(
(let ((result
(exec-query
conn
- (string-append
- "SELECT id, commit, source, git_repository_id "
- "FROM load_new_guix_revision_jobs ORDER BY id ASC LIMIT $1")
+ "
+SELECT id, commit, source, git_repository_id
+FROM load_new_guix_revision_jobs
+ORDER BY id ASC
+LIMIT $1"
(list (number->string n)))))
result))
(define (select-job-for-update conn id)
(exec-query
conn
- (string-append
- "SELECT id, commit, source, git_repository_id "
- "FROM load_new_guix_revision_jobs "
- "WHERE id = $1 AND succeeded_at IS NULL "
- "FOR NO KEY UPDATE SKIP LOCKED")
+ "
+SELECT id, commit, source, git_repository_id
+FROM load_new_guix_revision_jobs
+WHERE id = $1
+ AND succeeded_at IS NULL
+FOR NO KEY UPDATE SKIP LOCKED"
(list id)))
(define (record-job-event conn job-id event)
(exec-query
conn
(string-append
- "INSERT INTO load_new_guix_revision_job_events (job_id, event) "
- "VALUES ($1, $2)")
+ "
+INSERT INTO load_new_guix_revision_job_events (job_id, event)
+VALUES ($1, $2)")
(list job-id event)))
(define (record-job-succeeded conn id)
(exec-query
conn
(string-append
- "UPDATE load_new_guix_revision_jobs "
- "SET succeeded_at = clock_timestamp() "
- "WHERE id = $1 ")
+ "
+UPDATE load_new_guix_revision_jobs
+SET succeeded_at = clock_timestamp()
+WHERE id = $1 ")
(list id)))
(define (fetch-unlocked-jobs conn)